Function prepareDatabaseAndTable

src/Interpreters/CnchSystemLog.cpp:184–243

template <typename LogElement>
bool prepareDatabaseAndTable(
    const ContextPtr & context,
    const String & database_name,
    const String & table_name,
    const Poco::Util::AbstractConfiguration & config,
    const String & config_prefix,
    Poco::Logger * log)
{
    if (!config.has(config_prefix) ||
        (context->getServerType() != ServerType::cnch_server))
       return true;

    if (!createDatabaseInCatalog(context, database_name, log))
        return false;

    auto create = std::make_shared<ASTCreateQuery>();
    create->database = database_name;
    create->table = table_name;

    auto ordinary_columns = LogElement::getNamesAndTypes();
    auto alias_columns = LogElement::getNamesAndAliases();
    auto new_columns_list = std::make_shared<ASTColumns>();
    new_columns_list->set(new_columns_list->columns, InterpreterCreateQuery::formatColumns(ordinary_columns, alias_columns, ParserSettings::CLICKHOUSE));
    create->set(create->columns_list, new_columns_list);

    String engine;
    if (config.has(config_prefix + ".engine"))
    {
        if (config.has(config_prefix + ".partition_by"))
            throw Exception("If 'engine' is specified for system table, "
                "PARTITION BY parameters should be specified directly inside 'engine' and 'partition_by' setting doesn't make sense",
                ErrorCodes::BAD_ARGUMENTS);
        if (config.has(config_prefix + ".ttl"))
            throw Exception("If 'engine' is specified for system table, "
                            "TTL parameters should be specified directly inside 'engine' and 'ttl' setting doesn't make sense",
                            ErrorCodes::BAD_ARGUMENTS);
        engine = config.getString(config_prefix + ".engine");
    }
    else
    {
        engine = prepareEngineClause<LogElement>(config, config_prefix);
    }

    ASTPtr create_query = constructCreateTableQuery<LogElement>(database_name, table_name, engine);

    if (!prepareCnchTable(context, database_name, table_name, create_query, log))
        return false;

    ColumnsWithTypeAndName log_element_columns;
    for (const auto & name_and_type : ordinary_columns)
        log_element_columns.emplace_back(name_and_type.type, name_and_type.name);

    Block expected_block(std::move(log_element_columns));

    if (!syncTableSchema(context, database_name, table_name, expected_block, log))
        return false;
    if (!createView(context, database_name, table_name, log))
        return false;