Merge branch 'main' into dependabot/cargo/rand-0.9.1

Author: phillipleblanc

Cargo.lock

@@ -183,8 +183,8 @@ pub struct InsertBuilder {
 }
 
 pub fn use_json_insert_for_type<T: QueryBuilder + 'static>(
-    data_type: &DataType,
-    query_builder: &T,
+    #[allow(unused_variables)] data_type: &DataType,
+    #[allow(unused_variables)] query_builder: &T,
 ) -> bool {
     #[cfg(feature = "sqlite")]
     {

core/src/sql/arrow_sql_gen/statement.rs

@@ -13,10 +13,25 @@ use datafusion::{
     arrow::datatypes::SchemaRef,
     error::{DataFusionError, Result as DataFusionResult},
     physical_plan::{stream::RecordBatchStreamAdapter, SendableRecordBatchStream},
-    sql::{unparser::dialect::Dialect, TableReference},
+    sql::{
+        unparser::dialect::{DefaultDialect, Dialect},
+        TableReference,
+    },
 };
 
 impl<T, P> SqlTable<T, P> {
+    // Return the current memory location of the object as a unique identifier
+    fn unique_id(&self) -> usize {
+        std::ptr::from_ref(self) as usize
+    }
+
+    fn arc_dialect(&self) -> Arc<dyn Dialect + Send + Sync> {
+        match &self.dialect {
+            Some(dialect) => Arc::clone(dialect),
+            None => Arc::new(DefaultDialect {}),
+        }
+    }
+
     fn create_federated_table_source(
         self: Arc<Self>,
     ) -> DataFusionResult<Arc<dyn FederatedTableSource>> {

core/src/sql/sql_provider_datafusion/federation.rs

@@ -156,11 +156,6 @@ impl<T, P> SqlTable<T, P> {
         )?))
     }
 
-    // Return the current memory location of the object as a unique identifier
-    fn unique_id(&self) -> usize {
-        std::ptr::from_ref(self) as usize
-    }
-
     #[must_use]
     pub fn with_dialect(self, dialect: Arc<dyn Dialect + Send + Sync>) -> Self {
         Self {
@@ -185,13 +180,6 @@ impl<T, P> SqlTable<T, P> {
             None => &DefaultDialect {},
         }
     }
-
-    fn arc_dialect(&self) -> Arc<dyn Dialect + Send + Sync> {
-        match &self.dialect {
-            Some(dialect) => Arc::clone(dialect),
-            None => Arc::new(DefaultDialect {}),
-        }
-    }
 }
 
 #[async_trait]