reintroduce more brittle sql-replacements

ADBond · Sep 30, 2024 · d53d856 · d53d856
1 parent 3ce1327
commit d53d856
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/splinkclickhouse/chdb/database_api.py b/splinkclickhouse/chdb/database_api.py
@@ -73,6 +73,9 @@ def _setup_for_execute_sql(self, sql: str, physical_name: str) -> str:
         # workaround for https://github.com/ClickHouse/ClickHouse/issues/61004
         sql = sql.replace("count(*)", "count()")
         sql = sql.replace("COUNT(*)", "COUNT()")
+        # TODO: very sorry for this
+        # avoids 'double selection' issue in creating __splink__block_counts
+        sql = sql.replace(", count_l, count_r,", ",")
 
         sql = f"CREATE TABLE {physical_name} ORDER BY tuple() AS {sql}"
         return sql

diff --git a/splinkclickhouse/clickhouse/database_api.py b/splinkclickhouse/clickhouse/database_api.py
@@ -61,6 +61,9 @@ def _setup_for_execute_sql(self, sql: str, physical_name: str) -> str:
         # workaround for https://github.com/ClickHouse/ClickHouse/issues/61004
         sql = sql.replace("count(*)", "count()")
         sql = sql.replace("COUNT(*)", "COUNT()")
+        # TODO: very sorry for this
+        # avoids 'double selection' issue in creating __splink__block_counts
+        sql = sql.replace(", count_l, count_r,", ",")
 
         sql = f"CREATE TABLE {physical_name} ORDER BY tuple() AS {sql}"
         return sql