fix: update rust toolchain and fix lint issues

Author: sunng87

datafusion-postgres-cli/src/main.rs

@@ -105,7 +105,7 @@ impl Opt {
                     }
                 }
                 Err(e) => {
-                    return Err(format!("Failed to load directory {}: {}", directory, e).into());
+                    return Err(format!("Failed to load directory {directory}: {e}").into());
                 }
             }
         }
@@ -122,17 +122,17 @@ async fn setup_session_context(
         session_context
             .register_csv(table_name, table_path, CsvReadOptions::default())
             .await
-            .map_err(|e| format!("Failed to register CSV table '{}': {}", table_name, e))?;
-        println!("Loaded {} as table {}", table_path, table_name);
+            .map_err(|e| format!("Failed to register CSV table '{table_name}': {e}"))?;
+        println!("Loaded {table_path} as table {table_name}");
     }
 
     // Register JSON tables
     for (table_name, table_path) in opts.json_tables.iter().map(|s| parse_table_def(s.as_ref())) {
         session_context
             .register_json(table_name, table_path, NdJsonReadOptions::default())
             .await
-            .map_err(|e| format!("Failed to register JSON table '{}': {}", table_name, e))?;
-        println!("Loaded {} as table {}", table_path, table_name);
+            .map_err(|e| format!("Failed to register JSON table '{table_name}': {e}"))?;
+        println!("Loaded {table_path} as table {table_name}");
     }
 
     // Register Arrow tables
@@ -144,8 +144,8 @@ async fn setup_session_context(
         session_context
             .register_arrow(table_name, table_path, ArrowReadOptions::default())
             .await
-            .map_err(|e| format!("Failed to register Arrow table '{}': {}", table_name, e))?;
-        println!("Loaded {} as table {}", table_path, table_name);
+            .map_err(|e| format!("Failed to register Arrow table '{table_name}': {e}"))?;
+        println!("Loaded {table_path} as table {table_name}");
     }
 
     // Register Parquet tables
@@ -157,17 +157,17 @@ async fn setup_session_context(
         session_context
             .register_parquet(table_name, table_path, ParquetReadOptions::default())
             .await
-            .map_err(|e| format!("Failed to register Parquet table '{}': {}", table_name, e))?;
-        println!("Loaded {} as table {}", table_path, table_name);
+            .map_err(|e| format!("Failed to register Parquet table '{table_name}': {e}"))?;
+        println!("Loaded {table_path} as table {table_name}");
     }
 
     // Register Avro tables
     for (table_name, table_path) in opts.avro_tables.iter().map(|s| parse_table_def(s.as_ref())) {
         session_context
             .register_avro(table_name, table_path, AvroReadOptions::default())
             .await
-            .map_err(|e| format!("Failed to register Avro table '{}': {}", table_name, e))?;
-        println!("Loaded {} as table {}", table_path, table_name);
+            .map_err(|e| format!("Failed to register Avro table '{table_name}': {e}"))?;
+        println!("Loaded {table_path} as table {table_name}");
     }
 
     // Register pg_catalog
@@ -194,7 +194,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     serve(Arc::new(session_context), &server_options)
         .await
-        .map_err(|e| format!("Failed to run server: {}", e))?;
+        .map_err(|e| format!("Failed to run server: {e}"))?;
 
     Ok(())
 }

datafusion-postgres/src/lib.rs

@@ -47,7 +47,7 @@ pub async fn serve(
     // Bind to the specified host and port
     let server_addr = format!("{}:{}", opts.host, opts.port);
     let listener = TcpListener::bind(&server_addr).await?;
-    info!("Listening on {}", server_addr);
+    info!("Listening on {server_addr}");
 
     // Accept incoming connections
     loop {