Method addCreateQuery

src/CloudServices/CnchServerResource.cpp:199–229

}

void CnchServerResource::addCreateQuery(
    const ContextPtr & context,
    const StoragePtr & storage,
    const String & create_query,
    const String & worker_table_name,
    bool create_local_table)
{
    /// table should exists in SelectStreamFactory::createForShard
    /// so we create table in worker in advance
    if (context->getServerType() == ServerType::cnch_worker && create_local_table)
    {
        auto temp_context = Context::createCopy(context);
        auto worker_resource = context->getCnchWorkerResource();
        worker_resource->executeCreateQuery(temp_context, create_query, /* skip_if_exists */ true);
    }

    auto lock = getLock();

    auto it = assigned_table_resource.find(storage->getStorageUUID());
    if(storage->getStorageUUID() == UUIDHelpers::Nil)
    {
        // throw DB::Exception(ErrorCodes::LOGICAL_ERROR, "UUID for resources should not be nil");
        LOG_DEBUG(log, "UUID for resources should not be nil, query: {}, table: {}", create_query, worker_table_name);
    }
    if (it == assigned_table_resource.end())
        it = assigned_table_resource.emplace(storage->getStorageUUID(), AssignedResource{storage}).first;

    it->second.table_definition.definition = create_query;
    it->second.table_definition.local_table_name = worker_table_name;
    it->second.table_definition.cacheable = false;
}

void CnchServerResource::addCacheableCreateQuery(
    const StoragePtr & storage,