Method getSelectResult

src/Interpreters/InterpreterKillQueryQuery.cpp:429–459

}

Block InterpreterKillQueryQuery::getSelectResult(const String & columns, const String & table)
{
    String select_query = "SELECT " + columns + " FROM " + table;
    auto & where_expression = query_ptr->as<ASTKillQueryQuery>()->where_expression;
    if (where_expression)
        select_query += " WHERE " + where_expression->formatWithSecretsOneLine();

    auto query_context = Context::createCopy(getContext());
    query_context->makeQueryContext();
    query_context->setCurrentQueryId("");

    auto io = executeQuery(select_query, std::move(query_context), QueryFlags{ .internal = true }).second;

    Block res;
    Block tmp_block;
    io.executeWithCallbacks([&]()
    {
        PullingPipelineExecutor executor(io.pipeline);
        while (res.empty() && executor.pull(res));

        while (executor.pull(tmp_block));
    });

    if (!tmp_block.empty())
        throw Exception(ErrorCodes::LOGICAL_ERROR, "Expected one block from input stream");

    /// Materialize const columns, because callers use typeid_cast to concrete column types.
    materializeBlockInplace(res);

    return res;
}


AccessRightsElements InterpreterKillQueryQuery::getRequiredAccessForDDLOnCluster() const