valitydev/clickhouse-sink-connector
14
0
Fork 0
mirror of https://github.com/valitydev/clickhouse-sink-connector.git synced 2024-11-06 02:25:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

is_deleted and _sign are exclusive

Browse Source
This commit is contained in:
Arnaud Adant 2023-10-16 22:13:36 -05:00
parent bada816bc0
commit 8b6bae9aac
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sink-connector/python/db_load/mysql_parser/CreateTableMySQLParserListener.py
View File

@ -127,10 +127,12 @@ class CreateTableMySQLParserListener(MySqlParserListener):
def exitColumnCreateTable(self, ctx):
tableName = self.extract_original_text(ctx.tableName())
self.buffer = f"CREATE TABLE {tableName} ("
self.columns.append("`_sign` Int8 DEFAULT 1")
self.columns.append("`_version` UInt64 DEFAULT 0")
# is_deleted and _sign are redundant, so exclusive in the schema
if self.rmt_delete_support:
self.columns.append("`is_deleted` UInt8 DEFAULT 0")
else:
self.columns.append("`_sign` Int8 DEFAULT 1")
for column in self.columns:
self.buffer += column