Function executeQuery

src/Interpreters/executeQuery.cpp:1945–1968

}

BlockIO
executeQuery(const String & query, ContextMutablePtr context, bool internal, QueryProcessingStage::Enum stage, bool may_have_embedded_data)
{
    ASTPtr ast;
    BlockIO streams;


    std::tie(ast, streams)
        = executeQueryImpl(query.data(), query.data() + query.size(), nullptr, context, internal, stage, !may_have_embedded_data, nullptr);

    if (const auto * ast_query_with_output = dynamic_cast<const ASTQueryWithOutput *>(ast.get()))
    {

        // Try to redirect streams to the target file instead of the client when outfile_in_server_with_tcp is true
        tryOutfile(streams, ast, context);

        String format_name = ast_query_with_output->format ? getIdentifierName(ast_query_with_output->format) : context->getDefaultFormat();

        if (format_name == "Null")
            streams.null_format = true;
    }

    return streams;
}

BlockIO executeQuery(
    const String & query,