fix: resolves lint issues

Author: sunng87

arrow-pg/src/datatypes/df.rs

@@ -160,7 +160,7 @@ where
                 return Err(PgWireError::UserError(Box::new(ErrorInfo::new(
                     "FATAL".to_string(),
                     "XX000".to_string(),
-                    format!("Unsupported parameter type: {}", pg_type),
+                    format!("Unsupported parameter type: {pg_type}"),
                 ))));
             }
         }

arrow-pg/src/encoder.rs

@@ -496,8 +496,7 @@ pub fn encode_value<T: Encoder>(
                 postgres_types::Kind::Composite(fields) => fields,
                 _ => {
                     return Err(PgWireError::ApiError(ToSqlError::from(format!(
-                        "Failed to unwrap a composite type from type {}",
-                        type_
+                        "Failed to unwrap a composite type from type {type_}"
                     ))));
                 }
             };
@@ -529,8 +528,7 @@ pub fn encode_value<T: Encoder>(
                 .or_else(|| get_dict_values!(UInt64Type))
                 .ok_or_else(|| {
                     ToSqlError::from(format!(
-                        "Unsupported dictionary key type for value type {}",
-                        value_type
+                        "Unsupported dictionary key type for value type {value_type}",
                     ))
                 })?;
 

datafusion-postgres/src/handlers.rs

@@ -156,7 +156,7 @@ impl DfSessionService {
                     pgwire::error::ErrorInfo::new(
                         "ERROR".to_string(),
                         "42704".to_string(),
-                        format!("Unrecognized SHOW command: {}", query_lower),
+                        format!("Unrecognized SHOW command: {query_lower}"),
                     ),
                 ))),
             }

datafusion-postgres/src/lib.rs

@@ -5,6 +5,7 @@ use std::sync::Arc;
 
 use datafusion::prelude::SessionContext;
 use getset::{Getters, Setters, WithSetters};
+use log::{info, warn};
 use pgwire::tokio::process_socket;
 use tokio::net::TcpListener;
 
@@ -46,23 +47,23 @@ 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?;
-    println!("Listening on {}", server_addr);
+    info!("Listening on {}", server_addr);
 
     // Accept incoming connections
     loop {
         match listener.accept().await {
             Ok((socket, addr)) => {
                 let factory_ref = factory.clone();
-                println!("Accepted connection from {}", addr);
+                info!("Accepted connection from {addr}");
 
                 tokio::spawn(async move {
                     if let Err(e) = process_socket(socket, None, factory_ref).await {
-                        eprintln!("Error processing socket: {}", e);
+                        warn!("Error processing socket: {e}");
                     }
                 });
             }
             Err(e) => {
-                eprintln!("Error accept socket: {}", e);
+                info!("Error accept socket: {e}");
             }
         }
     }

datafusion-postgres/src/pg_catalog.rs

@@ -662,8 +662,7 @@ pub fn setup_pg_catalog(
         .catalog(catalog_name)
         .ok_or_else(|| {
             DataFusionError::Configuration(format!(
-                "Catalog not found when registering pg_catalog: {}",
-                catalog_name
+                "Catalog not found when registering pg_catalog: {catalog_name}",
             ))
         })?
         .register_schema("pg_catalog", Arc::new(pg_catalog))?;