WIP: ODBC

Author: georgestagg

src/execute/casting.rs

@@ -216,7 +216,7 @@ pub fn determine_layer_source(
     match &layer.source {
         Some(DataSource::Identifier(name)) => {
             if materialized_ctes.contains(name) {
-                naming::cte_table(name)
+                naming::quote_ident(&naming::cte_table(name))
             } else {
                 name.clone()
             }
@@ -227,7 +227,7 @@ pub fn determine_layer_source(
         None => {
             // Layer uses global data - caller must ensure has_global is true
             debug_assert!(has_global, "Layer has no source and no global data");
-            naming::global_table()
+            naming::quote_ident(&naming::global_table())
         }
     }
 }

src/execute/cte.rs

@@ -94,7 +94,7 @@ pub fn transform_cte_references(sql: &str, cte_names: &HashSet<String>) -> Strin
     let mut result = sql.to_string();
 
     for cte_name in cte_names {
-        let temp_table_name = naming::cte_table(cte_name);
+        let temp_table_name = naming::quote_ident(&naming::cte_table(cte_name));
 
         // Replace table references: FROM cte_name, JOIN cte_name, cte_name.column
         // Use word boundary matching to avoid replacing substrings
@@ -360,26 +360,26 @@ mod tests {
             (
                 "SELECT * FROM sales WHERE year = 2024",
                 vec!["sales"],
-                vec!["FROM __ggsql_cte_sales_", "__ WHERE year = 2024"],
+                vec!["FROM \"__ggsql_cte_sales_", "__\" WHERE year = 2024"],
                 None,
             ),
             // Multiple CTE references with qualified columns
             (
                 "SELECT sales.date, targets.revenue FROM sales JOIN targets ON sales.id = targets.id",
                 vec!["sales", "targets"],
                 vec![
-                    "FROM __ggsql_cte_sales_",
-                    "JOIN __ggsql_cte_targets_",
-                    "__ggsql_cte_sales_",  // qualified reference sales.date
-                    "__ggsql_cte_targets_", // qualified reference targets.revenue
+                    "FROM \"__ggsql_cte_sales_",
+                    "JOIN \"__ggsql_cte_targets_",
+                    "\"__ggsql_cte_sales_",  // qualified reference sales.date
+                    "\"__ggsql_cte_targets_", // qualified reference targets.revenue
                 ],
                 None,
             ),
             // Qualified column references only (no FROM/JOIN transformation needed)
             (
                 "WHERE sales.date > '2024-01-01' AND sales.revenue > 100",
                 vec!["sales"],
-                vec!["__ggsql_cte_sales_"],
+                vec!["\"__ggsql_cte_sales_"],
                 None,
             ),
             // No matching CTE (unchanged)

src/naming.rs

@@ -88,6 +88,18 @@ pub const SOURCE_COLUMN: &str = concatcp!(GGSQL_PREFIX, "source", GGSQL_SUFFIX);
 /// Alias for schema extraction queries
 pub const SCHEMA_ALIAS: &str = concatcp!(GGSQL_SUFFIX, "schema", GGSQL_SUFFIX);
 
+// ============================================================================
+// Quoting
+// ============================================================================
+
+/// Quote a SQL identifier with double quotes (ANSI SQL).
+///
+/// This ensures case-preserving behavior on backends like Snowflake that
+/// uppercase unquoted identifiers.
+pub fn quote_ident(name: &str) -> String {
+    format!("\"{}\"", name.replace('"', "\"\""))
+}
+
 // ============================================================================
 // Constructor Functions
 // ============================================================================