Merge pull request #68 from supabase/deji/fix/use-backticks-for-cols

fix: wrap bq column names in backticks
supabase · Nov 29, 2024 · 14be796 · 14be796
2 parents 662de0e + aedd10b
commit 14be796
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pg_replicate/src/clients/bigquery.rs b/pg_replicate/src/clients/bigquery.rs
@@ -132,7 +132,9 @@ impl BigQueryClient {
     }
 
     fn column_spec(column_schema: &ColumnSchema, s: &mut String) {
+        s.push('`');
         s.push_str(&column_schema.name);
+        s.push('`');
         s.push(' ');
         let typ = Self::postgres_to_bigquery_type(&column_schema.typ);
         s.push_str(typ);
@@ -147,7 +149,9 @@ impl BigQueryClient {
         s.push_str("primary key (");
 
         for column in identity_columns {
+            s.push('`');
             s.push_str(&column.name);
+            s.push('`');
             s.push(',');
         }