diff --git a/clickhouse_ddl_export.py b/clickhouse_ddl_export.py index 76453a1..bd7ed00 100755 --- a/clickhouse_ddl_export.py +++ b/clickhouse_ddl_export.py @@ -55,12 +55,13 @@ def dump(dumpfile=DUMPFILE): try: with open(dumpfile, "r") as f: a = json.load(f) - for database,values in a.items(): + for database, values in a.items(): print(f"--- database {database} ---") - print("{};\n".format(values["ddl"])) - for table,c in values["tables"].items(): + create_database = values["ddl"] + print(f"{create_database};\n") + for table, create_table in values["tables"].items(): print(f"-- table {database}.{table} --") - print(f"{c};\n") + print(f"{create_table};\n") except FileNotFoundError as e: print(e) print("-- to re-create replicas, run 'clickhouse-client --multiquery < generated_file.sql' on new replica server")