Method createTable

src/Interpreters/InterpreterCreateQuery.cpp:1550–1867

}

BlockIO InterpreterCreateQuery::createTable(ASTCreateQuery & create)
{
    auto component_guard = Coordination::setCurrentComponent("InterpreterCreateQuery::createTable");
    /// Temporary tables are created out of databases.
    if (create.isTemporary() && create.attach)
        throw Exception(ErrorCodes::SYNTAX_ERROR, "ATTACH of TEMPORARY tables are not supported");

    if (create.isTemporary() && create.database)
        throw Exception(ErrorCodes::BAD_DATABASE_FOR_TEMPORARY_TABLE,
                        "Temporary objects (tables/views) cannot be inside a database. "
                        "You should not specify a database for a temporary objects.");

    if (create.isTemporary() && !create.cluster.empty())
        throw Exception(ErrorCodes::INCORRECT_QUERY,
            "Temporary objects (tables/views) cannot be created ON CLUSTER."
            "You should not specify a cluster for a temporary objects.");

    String current_database = getContext()->getCurrentDatabase();
    auto database_name = create.database ? create.getDatabase() : current_database;

    bool is_secondary_query = getContext()->getZooKeeperMetadataTransaction() && !getContext()->getZooKeeperMetadataTransaction()->isInitialQuery();
    auto mode = getLoadingStrictnessLevel(create.attach, /*force_attach*/ false, /*has_force_restore_data_flag*/ false, is_secondary_query || is_restore_from_backup);

    if (!create.sql_security && create.supportSQLSecurity() && (create.refresh_strategy || !getContext()->getServerSettings()[ServerSetting::ignore_empty_sql_security_in_create_view_query]))
        create.set(create.sql_security, make_intrusive<ASTSQLSecurity>());

    if (create.sql_security)
        processSQLSecurityOption(getContext(), create.sql_security->as<ASTSQLSecurity &>(), create.is_materialized_view, mode);

    DDLGuardPtr ddl_guard;

    // If this is a stub ATTACH query, read the query definition from the database
    if (create.attach && (!create.storage || !create.storage->engine) && !create.columns_list)
    {
        /// First, reject any user-supplied storage clauses or top-level fields that the
        /// short-ATTACH path below would silently drop by overwriting `create` with the
        /// stored table metadata. `InterpreterSetQuery::applySettingsFromQuery` (called from
        /// `executeQueryImpl` before this interpreter) has already hoisted session settings
        /// out of `create.storage->settings`, so anything still here is either engine-specific
        /// (`ORDER BY`, `PARTITION BY`, `PRIMARY KEY`, `SAMPLE BY`, `TTL`, `UNIQUE KEY`, MergeTree
        /// `SETTINGS`) or a top-level `ASTCreateQuery` field (`COMMENT`, `REFRESH`, `SQL SECURITY`,
        /// `TO target`, `EMPTY`, `CLONE`, `AS SELECT`, `UUID`, etc.).
        bool has_dropped_clauses = false;

        if (create.storage)
        {
            const auto & storage = *create.storage;
            has_dropped_clauses
                = storage.partition_by != nullptr
                || storage.primary_key != nullptr
                || storage.order_by != nullptr
                || storage.sample_by != nullptr
                || storage.ttl_table != nullptr
                || storage.unique_key != nullptr
                || storage.settings != nullptr;
        }

        has_dropped_clauses = has_dropped_clauses