@@ -419,90 +419,6 @@ impl DfSessionService {
419419 }
420420 }
421421
422- /// Legacy string-based SET statement handler (deprecated - use structured AST instead)
423- #[ deprecated( note = "Use try_handle_structured_statement instead" ) ]
424- async fn try_respond_set_statements < ' a , C > (
425- & self ,
426- client : & mut C ,
427- query_lower : & str ,
428- ) -> PgWireResult < Option < Response < ' a > > >
429- where
430- C : ClientInfo ,
431- {
432- if query_lower. starts_with ( "set" ) {
433- if query_lower. starts_with ( "set time zone" ) {
434- let parts: Vec < & str > = query_lower. split_whitespace ( ) . collect ( ) ;
435- if parts. len ( ) >= 4 {
436- let tz = parts[ 3 ] . trim_matches ( '"' ) ;
437- let mut timezone = self . timezone . lock ( ) . await ;
438- * timezone = tz. to_string ( ) ;
439- Ok ( Some ( Response :: Execution ( Tag :: new ( "SET" ) ) ) )
440- } else {
441- Err ( PgWireError :: UserError ( Box :: new (
442- pgwire:: error:: ErrorInfo :: new (
443- "ERROR" . to_string ( ) ,
444- "42601" . to_string ( ) ,
445- "Invalid SET TIME ZONE syntax" . to_string ( ) ,
446- ) ,
447- ) ) )
448- }
449- } else if query_lower. starts_with ( "set statement_timeout" ) {
450- let parts: Vec < & str > = query_lower. split_whitespace ( ) . collect ( ) ;
451- if parts. len ( ) >= 3 {
452- let timeout_str = parts[ 2 ] . trim_matches ( '"' ) . trim_matches ( '\'' ) ;
453-
454- let timeout = if timeout_str == "0" || timeout_str. is_empty ( ) {
455- None
456- } else {
457- // Parse timeout value (supports ms, s, min formats)
458- let timeout_ms = if timeout_str. ends_with ( "ms" ) {
459- timeout_str. trim_end_matches ( "ms" ) . parse :: < u64 > ( )
460- } else if timeout_str. ends_with ( "s" ) {
461- timeout_str
462- . trim_end_matches ( "s" )
463- . parse :: < u64 > ( )
464- . map ( |s| s * 1000 )
465- } else if timeout_str. ends_with ( "min" ) {
466- timeout_str
467- . trim_end_matches ( "min" )
468- . parse :: < u64 > ( )
469- . map ( |m| m * 60 * 1000 )
470- } else {
471- // Default to milliseconds
472- timeout_str. parse :: < u64 > ( )
473- } ;
474-
475- match timeout_ms {
476- Ok ( ms) if ms > 0 => Some ( std:: time:: Duration :: from_millis ( ms) ) ,
477- _ => None ,
478- }
479- } ;
480-
481- Self :: set_statement_timeout ( client, timeout) ;
482- Ok ( Some ( Response :: Execution ( Tag :: new ( "SET" ) ) ) )
483- } else {
484- Err ( PgWireError :: UserError ( Box :: new (
485- pgwire:: error:: ErrorInfo :: new (
486- "ERROR" . to_string ( ) ,
487- "42601" . to_string ( ) ,
488- "Invalid SET statement_timeout syntax" . to_string ( ) ,
489- ) ,
490- ) ) )
491- }
492- } else {
493- // pass SET query to datafusion
494- if let Err ( e) = self . session_context . sql ( query_lower) . await {
495- warn ! ( "SET statement {query_lower} is not supported by datafusion, error {e}, statement ignored" ) ;
496- }
497-
498- // Always return SET success
499- Ok ( Some ( Response :: Execution ( Tag :: new ( "SET" ) ) ) )
500- }
501- } else {
502- Ok ( None )
503- }
504- }
505-
506422 async fn try_respond_transaction_statements < ' a , C > (
507423 & self ,
508424 client : & C ,
@@ -555,7 +471,7 @@ impl DfSessionService {
555471 }
556472
557473 /// Legacy string-based SHOW statement handler (deprecated - use structured AST instead)
558- #[ deprecated ( note = "Use try_handle_structured_statement instead" ) ]
474+ #[ allow ( dead_code ) ]
559475 async fn try_respond_show_statements < ' a , C > (
560476 & self ,
561477 client : & C ,
0 commit comments