@@ -935,7 +935,7 @@ impl PgCatalogSchemaProvider {
935935 None ,
936936 None ,
937937 ) ;
938-
938+
939939 // current_setting(setting_name) function
940940 data. add_function (
941941 2077 ,
@@ -956,7 +956,7 @@ impl PgCatalogSchemaProvider {
956956 "s" ,
957957 1 ,
958958 0 ,
959- 25 , // returns TEXT
959+ 25 , // returns TEXT
960960 "25" , // takes TEXT parameter
961961 None ,
962962 None ,
@@ -2059,20 +2059,20 @@ pub fn create_current_setting_udf() -> ScalarUDF {
20592059 let func = move |args : & [ ColumnarValue ] | {
20602060 let args = ColumnarValue :: values_to_arrays ( args) ?;
20612061 let setting_names = & args[ 0 ] ;
2062-
2062+
20632063 // Handle different setting name requests with reasonable defaults
20642064 let mut builder = StringBuilder :: new ( ) ;
2065-
2065+
20662066 for i in 0 ..setting_names. len ( ) {
20672067 let setting_name = setting_names
20682068 . as_any ( )
20692069 . downcast_ref :: < StringArray > ( )
20702070 . ok_or_else ( || DataFusionError :: Internal ( "Expected string array" . to_string ( ) ) ) ?
20712071 . value ( i) ;
2072-
2072+
20732073 // Provide reasonable defaults for common PostgreSQL settings
20742074 let value = match setting_name. to_lowercase ( ) . as_str ( ) {
2075- "server_version" => "16.0" , // Match modern PostgreSQL version
2075+ "server_version" => "16.0" , // Match modern PostgreSQL version
20762076 "server_version_num" => "160000" ,
20772077 "client_encoding" => "UTF8" ,
20782078 "timezone" => "UTC" ,
@@ -2093,7 +2093,7 @@ pub fn create_current_setting_udf() -> ScalarUDF {
20932093 "default_text_search_config" => "pg_catalog.english" ,
20942094 _ => "" , // Return empty string for unknown settings
20952095 } ;
2096-
2096+
20972097 builder. append_value ( value) ;
20982098 }
20992099
0 commit comments