Method execute

src/Interpreters/InterpreterShowProcesslistQuery.cpp:21–40

}

BlockIO InterpreterShowProcesslistQuery::execute()
{
    auto context = getContext();

    String query;
    if (context->getSettingsRef()[Setting::show_processlist_include_internal])
    {
        query = "SELECT * FROM system.processes ORDER BY elapsed DESC";
    }
    else
    {
        query = "SELECT * FROM system.processes WHERE is_internal = 0 ORDER BY elapsed DESC";
    }

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

    return executeQuery(query, query_context, QueryFlags{ .internal = true }).second;
}

void registerInterpreterShowProcesslistQuery(InterpreterFactory & factory);
void registerInterpreterShowProcesslistQuery(InterpreterFactory & factory)