Method executeToTables

src/Interpreters/InterpreterRenameQuery.cpp:99–137

}

BlockIO InterpreterRenameQuery::executeToTables(const ASTRenameQuery & rename, const RenameDescriptions & descriptions, TableGuards & ddl_guards)
{
    auto & database_catalog = DatabaseCatalog::instance();

    for (const auto & elem : descriptions)
    {
        if (!rename.exchange)
            database_catalog.assertTableDoesntExist(StorageID(elem.to_database_name, elem.to_table_name), getContext());

        DatabasePtr database = database_catalog.getDatabase(elem.from_database_name, getContext());
        if (typeid_cast<DatabaseReplicated *>(database.get())
            && !getContext()->getClientInfo().is_replicated_database_internal)
        {
            if (1 < descriptions.size())
                throw Exception(ErrorCodes::NOT_IMPLEMENTED, "Database {} is Replicated, "
                                "it does not support renaming of multiple tables in single query.", elem.from_database_name);

            UniqueTableName from(elem.from_database_name, elem.from_table_name);
            UniqueTableName to(elem.to_database_name, elem.to_table_name);
            ddl_guards[from]->releaseTableLock();
            ddl_guards[to]->releaseTableLock();
            return typeid_cast<DatabaseReplicated *>(database.get())->tryEnqueueReplicatedDDL(query_ptr, getContext());
        }
        else
        {
            database->renameTable(
                getContext(),
                elem.from_table_name,
                *database_catalog.getDatabase(elem.to_database_name, getContext()),
                elem.to_table_name,
                rename.exchange,
                rename.dictionary);
        }
    }
    if (auto txn = getContext()->getCurrentTransaction())
        txn->commitV1();

    return {};
}

BlockIO InterpreterRenameQuery::executeToDatabase(const ASTRenameQuery &, const RenameDescriptions & descriptions)
{