Method commitCreateTable

src/Databases/DatabaseReplicated.cpp:2314–2349

}

void DatabaseReplicated::commitCreateTable(const ASTCreateQuery & query, const StoragePtr & table,
                       const String & table_metadata_tmp_path, const String & table_metadata_path,
                       ContextPtr query_context)
{
    auto txn = query_context->getZooKeeperMetadataTransaction();
    chassert(!ddl_worker->isCurrentlyActive() || txn);

    String statement = getObjectDefinitionFromCreateQuery(query.clone());

    /// For CREATE OR REPLACE, the metadata node for the temporary table is intentionally omitted
    /// from the transaction because renameTable will create it under the final name atomically.
    /// However, inner tables (`.inner_id.*`) are NOT renamed during the exchange — they keep
    /// their UUID-based name — so their metadata nodes must still be created here, as part of
    /// the rename transaction that commits everything. Without this, an explicit DROP TABLE
    /// after CREATE OR REPLACE would fail with a ZooKeeper "No node" error when trying to
    /// remove the inner table's metadata node.
    const bool is_inner_table = query.getTable().starts_with(".inner_id.");
    if (txn && txn->isInitialQuery() && (!txn->isCreateOrReplaceQuery() || is_inner_table))
    {
        String metadata_zk_path = zookeeper_path + "/metadata/" + escapeForFileName(query.getTable());
        /// zk::multi(...) will throw if `metadata_zk_path` exists
        txn->addOp(zkutil::makeCreateRequest(metadata_zk_path, statement, zkutil::CreateMode::Persistent));
    }

    std::lock_guard lock{metadata_mutex};
    UInt64 new_digest = tables_metadata_digest;
    new_digest += DB::getMetadataHash(query.getTable(), statement);
    if (txn && !txn->isCreateOrReplaceQuery() && !is_recovering)
        txn->addOp(zkutil::makeSetRequest(replica_path + "/digest", toString(new_digest), -1));

    DatabaseAtomic::commitCreateTable(query, table, table_metadata_tmp_path, table_metadata_path, query_context);
    tables_metadata_digest = new_digest;

    /// commitCreateTable() commits the txn, so no need to try to attach it to txn
    assertDigest(query_context);
}

void DatabaseReplicated::commitAlterTable(const StorageID & table_id,
                                          const String & table_metadata_tmp_path, const String & table_metadata_path,