Function executeTrivialBlockIO

src/Interpreters/executeQuery.cpp:2637–2666

}

void executeTrivialBlockIO(BlockIO & streams, ContextPtr context, bool with_interactive_cancel)
{
    try
    {
        if (!streams.pipeline.initialized())
            return;

        if (!streams.pipeline.completed())
            throw Exception(ErrorCodes::LOGICAL_ERROR, "Query pipeline requires output, but no output buffer provided, it's a bug");

        streams.pipeline.setProgressCallback(context->getProgressCallback());

        CompletedPipelineExecutor executor(streams.pipeline);

        if (auto callback = context->getInteractiveCancelCallback(); callback && with_interactive_cancel)
        {
            auto interactive_delay = context->getSettingsRef()[Setting::interactive_delay];
            executor.setCancelCallback(std::move(callback), interactive_delay / 1000);
        }

        executor.execute();
    }
    catch (...)
    {
        streams.onException();
        throw;
    }

    streams.onFinish();
}

}