Function executeSubQueryWithoutResult

src/Interpreters/executeSubQuery.cpp:63–87

}

void executeSubQueryWithoutResult(const String & query, ContextMutablePtr query_context, bool internal)
{
    modifyQueryContext(query_context, internal);

    std::exception_ptr exception;
    auto thread = ThreadFromGlobalPool([query_context = std::move(query_context), &query, internal, &exception]() {
        try
        {
            CurrentThread::QueryScope query_scope{query_context};
            {
                ReadBufferFromOwnString in(query);
                NullWriteBuffer out;
                executeQuery(in, out, /*allow_into_outfile=*/false, query_context, /*set_result_details=*/{}, std::nullopt, internal);
            }
        }
        catch (...)
        {
            exception = constructException(query_context);
        }
    });
    thread.join();

    if (exception)
        std::rethrow_exception(exception);
}

Block executeSubQueryWithOneRow(const String & query, ContextMutablePtr query_context, bool internal, bool tolerate_multi_rows)
{