'commit'

ClickHouse/main.py

@@ -32,15 +32,15 @@ def main():
             'com_charge_discount_type', 'special_channel_order_source'
         ]
     )
-
+    tableName = 't_equipment_charge_order'
     # 创建同步服务
     service = SyncService(
         mysql_conn=mysql_conn,
         ch_conn=ch_conn,
         mapper=mapper,
-        schema_path="schemas/t_equipment_charge_order.sql"
+        schema_path="schemas/"+tableName+".sql"
     )
-    tableName = 't_equipment_charge_order'
+
     try:
         # 创建ClickHouse表
         service.create_ch_table()