Method doCreateTable

src/Interpreters/InterpreterCreateQuery.cpp:1444–1622

}

bool InterpreterCreateQuery::doCreateTable(ASTCreateQuery & create,
                                           const InterpreterCreateQuery::TableProperties & properties)
{
    std::unique_ptr<DDLGuard> guard;

    String data_path;
    DatabasePtr database;
    IntentLockPtr db_lock;
    IntentLockPtr tb_lock;


    bool need_add_to_database = !create.temporary;
    if (need_add_to_database)
    {
        /** If the request specifies IF NOT EXISTS, we allow concurrent CREATE queries (which do nothing).
          * If table doesn't exist, one thread is creating table, while others wait in DDLGuard.
          */
        guard = DatabaseCatalog::instance().getDDLGuard(create.database, create.table);

        database = DatabaseCatalog::instance().getDatabase(create.database, getContext());
        if (database->getEngineName().starts_with("Cnch"))
        {
            auto txn = getContext()->getCurrentTransaction();
            if (!txn)
                throw Exception("Transaction not initialized", ErrorCodes::CNCH_TRANSACTION_NOT_INITIALIZED);
                        /// May need to acquire kv lock before creating entry
            if (getContext()->getSettingsRef().bypass_ddl_db_lock)
            {
                tb_lock = txn->createIntentLock(IntentLock::TB_LOCK_PREFIX, database->getDatabaseName(), create.table);
                tb_lock->lock();
            }
            else
            {
                db_lock = txn->createIntentLock(IntentLock::DB_LOCK_PREFIX, database->getDatabaseName());
                tb_lock = txn->createIntentLock(IntentLock::TB_LOCK_PREFIX, database->getDatabaseName(), create.table);
                std::lock(*db_lock, *tb_lock);
            }
        }
        assertOrSetUUID(create, database);

        String storage_name = create.is_dictionary ? "Dictionary" : "Table";
        auto storage_already_exists_error_code = create.is_dictionary ? ErrorCodes::DICTIONARY_ALREADY_EXISTS : ErrorCodes::TABLE_ALREADY_EXISTS;

        /// Table can be created before or it can be created concurrently in another thread, while we were waiting in DDLGuard.
        if (database->isTableExist(create.table, getContext()))
        {
            /// TODO Check structure of table
            if (create.if_not_exists)
                return false;
            else if (create.replace_view)
            {
                /// when executing CREATE OR REPLACE VIEW, drop current existing view
                auto drop_ast = std::make_shared<ASTDropQuery>();
                drop_ast->database = create.database;
                drop_ast->table = create.table;
                drop_ast->no_ddl_lock = true;

                auto drop_context = Context::createCopy(context);