[clickhouse] fix checkTablesEmptyAndEngine sql query (#2163)

PeerDB-io · Oct 19, 2024 · 9f49ea6 · 9f49ea6
1 parent e4f940e
commit 9f49ea6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go
@@ -372,7 +372,7 @@ func (c *ClickHouseConnector) checkTablesEmptyAndEngine(ctx context.Context, tab
 		queryInput = append(queryInput, table)
 	}
 	rows, err := c.query(ctx,
-		fmt.Sprintf("SELECT name,engine,total_rows FROM system.tables WHERE database=? AND table IN (%s)",
+		fmt.Sprintf("SELECT name,engine,total_rows FROM system.tables WHERE database=? AND name IN (%s)",
 			strings.Join(slices.Repeat([]string{"?"}, len(tables)), ",")), queryInput...)
 	if err != nil {
 		return fmt.Errorf("failed to get information for destination tables: %w", err)