Method executeCacheableCreateQuery

src/CloudServices/CnchWorkerResource.cpp:79–179

}

void CnchWorkerResource::executeCacheableCreateQuery(
    ContextMutablePtr context,
    const StorageID & cnch_storage_id,
    const String & definition,
    const String & local_table_name,
    WorkerEngineType engine_type,
    const String & underlying_dictionary_tables,
    const ColumnsDescription & object_columns)
{
    static auto * log = &Poco::Logger::get("WorkerResource");

    std::shared_ptr<StorageCloudMergeTree> cached;
    if (auto cache = context->tryGetCloudTableDefinitionCache(); cache)
    {
        auto load = [&]() -> std::shared_ptr<StorageCloudMergeTree>
        {
            auto ast_query = parseCreateQuery(context, definition);
            auto & create_query = ast_query->as<ASTCreateQuery &>();

            replaceCnchWithCloud(
                create_query.storage,
                cnch_storage_id.getDatabaseName(),
                cnch_storage_id.getTableName(),
                engine_type);

            auto table = createStorageFromQuery(create_query, context);
            if (auto cloud_table = std::dynamic_pointer_cast<StorageCloudMergeTree>(table))
                return cloud_table;
            return {};
        };

        cached = cache->getOrSet(CloudTableDefinitionCache::hash(definition), std::move(load)).first;
    }

    StoragePtr res;
    if (cached)
    {
        LOG_DEBUG(log, "Creating cloud table {} from cached template of definition {}", local_table_name, definition);
        StorageID actual_table_id = cached->getStorageID();
        actual_table_id.table_name = local_table_name;

        std::unique_ptr<MergeTreeSettings> new_settings = std::make_unique<MergeTreeSettings>(*cached->getSettings());
        if (!underlying_dictionary_tables.empty())
            new_settings->underlying_dictionary_tables = underlying_dictionary_tables;

        switch (engine_type)
        {
            case WorkerEngineType::CLOUD:
                res = StorageCloudMergeTree::create(
                    actual_table_id,
                    cnch_storage_id.database_name,
                    cnch_storage_id.table_name,
                    *cached->getInMemoryMetadataPtr(),
                    context,
                    /*date_column_name*/ "",
                    cached->getMergingParams(),
                    std::move(new_settings));
                break;