Method executeCreateQuery

src/CloudServices/CnchWorkerResource.cpp:56–77

}

void CnchWorkerResource::executeCreateQuery(ContextMutablePtr context, const String & create_query, bool skip_if_exists, const ColumnsDescription & object_columns)
{
    LOG_DEBUG(&Poco::Logger::get("WorkerResource"), "start create cloud table {}", create_query);
    auto ast_query = parseCreateQuery(context, create_query);
    auto & ast_create_query = ast_query->as<ASTCreateQuery &>();

    /// set query settings
    /// TODO: can we remove this? i.e., don't rely on create query to pass query setting
    if (ast_create_query.settings_ast)
        InterpreterSetQuery(ast_create_query.settings_ast, context).executeForCurrentContext();

    auto res = createStorageFromQuery(ast_create_query, context);
    if (auto cloud_table = std::dynamic_pointer_cast<StorageCloudMergeTree>(res))
        cloud_table->resetObjectColumns(object_columns);
    res->startup();

    bool throw_if_exists = !ast_create_query.if_not_exists && !skip_if_exists;
    const auto & database_name = ast_create_query.database; // not empty.
    const auto & table_name = ast_create_query.table;
    String tenant_db = formatTenantDatabaseName(database_name);
    insertCloudTable({tenant_db, table_name}, res, context, throw_if_exists);
}

void CnchWorkerResource::executeCacheableCreateQuery(
    ContextMutablePtr context,