Method execute

src/Interpreters/InterpreterCreateQuery.cpp:1753–1790

}

BlockIO InterpreterCreateQuery::execute()
{
    FunctionNameNormalizer().visit(query_ptr.get());
    auto & create = query_ptr->as<ASTCreateQuery &>();
    if (!create.cluster.empty())
    {
        prepareOnClusterQuery(create, getContext(), create.cluster);
        return executeDDLQueryOnCluster(query_ptr, getContext(), getRequiredAccess());
    }

    auto context = getContext();
    context->checkAccess(getRequiredAccess());
    if (create.is_dictionary && context->is_tenant_user())
    {
        if (create.dictionary)
        {
            auto& refresh_query = create.dictionary->clickhouse_query;
            auto& invalidate_query = create.dictionary->clickhouse_invalidate_query;
            if (!refresh_query.empty())
                executeQuery("explain " + refresh_query, context, true);
            if (!invalidate_query.empty())
                executeQuery(invalidate_query, context, true);
        }

    }

    ASTQueryWithOutput::resetOutputASTIfExist(create);

    if (!create.catalog.empty() && create.database.empty() && create.table.empty())
        return createExternalCatalog(create);
    else if (!create.catalog.empty() && (!create.database.empty() || !create.table.empty()))
        throw Exception("create database or table in externcal catalog is not supported", ErrorCodes::INCORRECT_QUERY );
    /// CREATE|ATTACH DATABASE
    else if (!create.database.empty() && create.table.empty())
        return createDatabase(create);
    else
        return createTable(create);
}


AccessRightsElements InterpreterCreateQuery::getRequiredAccess() const