Fix "CREATE TABLE IF NOT EXISTS"

Author: nielsreijers

mysql_ch_replicator/clickhouse_api.py

@@ -14,7 +14,7 @@
 
 
 CREATE_TABLE_QUERY = '''
-CREATE TABLE {db_name}.{table_name}
+CREATE TABLE {if_not_exists} {db_name}.{table_name}
 (
 {fields},
     `_version` UInt64,
@@ -165,6 +165,7 @@ def create_table(self, structure: TableStructure, additional_indexes: list | Non
             primary_key = f'({primary_key})'
 
         query = CREATE_TABLE_QUERY.format(**{
+            'if_not_exists': 'IF NOT EXISTS' if structure.if_not_exists else '',
             'db_name': self.database,
             'table_name': structure.table_name,
             'fields': fields,

mysql_ch_replicator/converter.py

@@ -262,6 +262,7 @@ def convert_field_type(self, mysql_type, mysql_parameters):
     def convert_table_structure(self, mysql_structure: TableStructure) -> TableStructure:
         clickhouse_structure = TableStructure()
         clickhouse_structure.table_name = mysql_structure.table_name
+        clickhouse_structure.if_not_exists = mysql_structure.if_not_exists
         for field in mysql_structure.fields:
             clickhouse_field_type = self.convert_field_type(field.field_type, field.parameters)
             clickhouse_structure.fields.append(TableField(