Function executeQuery

src/Interpreters/executeQuery.cpp:2187–2274

std::pair<ASTPtr, BlockIO> executeQuery(
    std::string_view query,
    ContextMutablePtr context,
    QueryFlags flags,
    QueryProcessingStage::Enum stage)
{
    if (isCrashed())
        throw Exception(ErrorCodes::ABORTED, "The server is shutting down due to a fatal error");

    ProfileEvents::checkCPUOverload(context->getServerSettings()[ServerSetting::os_cpu_busy_time_threshold],
            static_cast<double>(context->getSettingsRef()[Setting::min_os_cpu_wait_time_ratio_to_throw]),
            static_cast<double>(context->getSettingsRef()[Setting::max_os_cpu_wait_time_ratio_to_throw]),
            /*should_throw*/ true);

    ASTPtr ast;
    BlockIO res;
    auto implicit_tcl_executor = std::make_shared<ImplicitTransactionControlExecutor>();
    ReadBufferUniquePtr no_input_buffer;
    QueryResultDetails result_details;
    res = executeQueryImpl(query.data(), query.data() + query.size(), context, flags, stage, no_input_buffer, ast, implicit_tcl_executor, {}, result_details);
    if (const auto * ast_query_with_output = dynamic_cast<const ASTQueryWithOutput *>(ast.get()))
    {
        String format_name = ast_query_with_output->format_ast
                ? getIdentifierName(ast_query_with_output->format_ast)
                : context->getDefaultFormat();

        const bool ignore_null_for_explain = context->getSettingsRef()[Setting::ignore_format_null_for_explain];
        if (boost::iequals(format_name, "Null") && !(ast->as<ASTExplainQuery>() && ignore_null_for_explain))
            res.null_format = true;
    }

    /// The 'SYSTEM ENABLE FAILPOINT terminate_with_exception' query itself should succeed.
    if (ast && !ast->as<ASTSystemQuery>())
    {
        fiu_do_on(FailPoints::terminate_with_exception,
        {
            try
            {
                throw Exception(ErrorCodes::FAULT_INJECTED, "Failpoint terminate_with_exception");
            }
            catch (...)
            {
                std::terminate();
            }
        });

        fiu_do_on(FailPoints::terminate_with_std_exception,
        {
            try
            {
                throw std::runtime_error("Failpoint terminate_with_std_exception");
            }
            catch (...)
            {
                std::terminate();
            }
        });