Method fillTableIfNeeded

src/Interpreters/InterpreterCreateQuery.cpp:2420–2484

}

BlockIO InterpreterCreateQuery::fillTableIfNeeded(const ASTCreateQuery & create)
{
    /// If the query is a CREATE SELECT, insert the data into the table.
    if (create.isCreateQueryWithImmediateInsertSelect())
    {
        auto insert = make_intrusive<ASTInsertQuery>();
        insert->table_id = {create.getDatabase(), create.getTable(), create.uuid};
        if (create.is_window_view)
        {
            auto table = DatabaseCatalog::instance().getTable(insert->table_id, getContext());
            insert->select = typeid_cast<StorageWindowView *>(table.get())->getSourceTableSelectQuery();
        }
        else
            insert->select = create.select->clone();

        return InterpreterInsertQuery(
                   insert,
                   getContext(),
                   getContext()->getSettingsRef()[Setting::insert_allow_materialized_columns],
                   /* no_squash */ false,
                   /* no_destination */ false,
                   /* async_isnert */ false)
            .execute();
    }

    /// If the query is a CREATE TABLE .. CLONE AS ..., attach all partitions of the source table to the newly created table.
    if (create.is_clone_as && !as_table_saved.empty() && !create.is_create_empty && !create.is_ordinary_view
        && (!(create.is_materialized_view || create.is_window_view) || create.is_populate))
    {
        String as_database_name = getContext()->resolveDatabase(as_database_saved);

        auto partition = make_intrusive<ASTPartition>();
        partition->all = true;

        auto command = make_intrusive<ASTAlterCommand>();
        command->replace = false;
        command->type = ASTAlterCommand::REPLACE_PARTITION;
        command->partition = command->children.emplace_back(std::move(partition)).get();
        command->from_database = as_database_name;
        command->from_table = as_table_saved;
        command->to_database = create.getDatabase();
        command->to_table = create.getTable();

        auto command_list = make_intrusive<ASTExpressionList>();
        command_list->children.push_back(command);

        auto query = make_intrusive<ASTAlterQuery>();
        query->setDatabase(create.getDatabase());
        query->setTable(create.getTable());
        query->uuid = create.uuid;
        auto * alter = query->as<ASTAlterQuery>();

        alter->alter_object = ASTAlterQuery::AlterObjectType::TABLE;
        alter->set(alter->command_list, command_list);

        /// The result of this internal ALTER is not visible to the user,
        /// so disable verbose output to avoid creating a pulling pipeline
        /// that executeTrivialBlockIO cannot handle.