Method doCreateOrReplaceTable

src/Interpreters/InterpreterCreateQuery.cpp:1625–1671

BlockIO InterpreterCreateQuery::doCreateOrReplaceTable(ASTCreateQuery & create,
                                                       const InterpreterCreateQuery::TableProperties & properties)
{
    auto ast_drop = std::make_shared<ASTDropQuery>();
    String table_to_replace_name = create.table;
    bool created = false;
    bool replaced = false;

    try
    {
        [[maybe_unused]] bool done = doCreateTable(create, properties);
        assert(done);
        ast_drop->table = create.table;
        ast_drop->is_dictionary = create.is_dictionary;
        ast_drop->database = create.database;
        ast_drop->kind = ASTDropQuery::Drop;
        created = true;
        if (!create.replace_table)
            return fillTableIfNeeded(create);

        auto ast_rename = std::make_shared<ASTRenameQuery>();
        ASTRenameQuery::Element elem
        {
            ASTRenameQuery::Table{create.database, create.table},
            ASTRenameQuery::Table{create.database, table_to_replace_name}
        };

        ast_rename->elements.push_back(std::move(elem));
        ast_rename->exchange = true;
        ast_rename->dictionary = create.is_dictionary;

        InterpreterRenameQuery(ast_rename, getContext()).execute();
        replaced = true;

        InterpreterDropQuery(ast_drop, getContext()).execute();

        create.table = table_to_replace_name;

        return fillTableIfNeeded(create);
    }
    catch (...)
    {
        if (created && create.replace_table && !replaced)
            InterpreterDropQuery(ast_drop, getContext()).execute();
        throw;
    }
}

BlockIO InterpreterCreateQuery::fillTableIfNeeded(const ASTCreateQuery & create)
{