quote table names for drop,fallback rename (#2235)

PeerDB-io · Nov 8, 2024 · e05ce07 · e05ce07
1 parent 5f431bb
commit e05ce07
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flow/connectors/clickhouse/cdc.go b/flow/connectors/clickhouse/cdc.go
@@ -20,7 +20,7 @@ import (
 
 const (
 	checkIfTableExistsSQL = `SELECT exists(SELECT 1 FROM system.tables WHERE database = ? AND name = ?) AS table_exists;`
-	dropTableIfExistsSQL  = `DROP TABLE IF EXISTS %s;`
+	dropTableIfExistsSQL  = "DROP TABLE IF EXISTS `%s`;"
 )
 
 // getRawTableName returns the raw table name for the given table identifier.
@@ -215,7 +215,7 @@ func (c *ClickHouseConnector) RenameTables(
 			}
 
 			if err := c.execWithLogging(ctx,
-				fmt.Sprintf("RENAME TABLE %s TO %s", renameRequest.CurrentName, renameRequest.NewName),
+				fmt.Sprintf("RENAME TABLE `%s` TO `%s`", renameRequest.CurrentName, renameRequest.NewName),
 			); err != nil {
 				return nil, fmt.Errorf("unable to rename table %s to %s: %w", renameRequest.CurrentName, renameRequest.NewName, err)
 			}