Function createTable

src/Databases/MySQL/MaterializedMySQLSyncThreadManager.cpp:187–200

}

static void createTable(const String & database_name, const String & query_str, const ContextPtr context)
{
    auto query_context = MaterializedMySQL::createQueryContext(context);
    auto txn = createTransactionForMySQL(context);
    SCOPE_EXIT({
        if (txn)
            context->getCnchTransactionCoordinator().finishTransaction(txn);
    });

    query_context->setCurrentTransaction(txn);

    String comment = "Materialize MySQL step 1: execute MySQL DDL for dump data";
    tryToExecuteQuery(query_str, query_context, database_name, comment); /// create table.
}

static inline void dumpDataForTables(
    mysqlxx::Pool::Entry & connection, const std::unordered_map<String, String> & need_dumping_tables,