Method readQueries

programs/benchmark/Benchmark.cpp:467–521

    }

    void readQueries()
    {
        if (query_to_execute.empty())
        {
            ReadBufferFromFileDescriptor in(STDIN_FILENO);

            switch (queries_format)
            {
                case QueriesFormat::Script:
                {
                    String all_queries_text;
                    readStringUntilEOF(all_queries_text, in);

                    auto parse_res = splitMultipartQuery(
                        all_queries_text,
                        queries,
                        settings[Setting::max_query_size],
                        settings[Setting::max_parser_depth],
                        settings[Setting::max_parser_backtracks],
                        settings[Setting::allow_settings_after_format_in_insert],
                        settings[Setting::implicit_select]);

                    if (!parse_res.second)
                        throw Exception(ErrorCodes::BAD_ARGUMENTS,
                            "Cannot parse query near: {}", String(parse_res.first, std::min<size_t>(100, all_queries_text.data() + all_queries_text.size() - parse_res.first)));
                    break;
                }
                case QueriesFormat::TSV:
                {
                    /// Default: one query per line, tab-escaped
                    while (!in.eof())
                    {
                        String query;
                        readText(query, in);
                        assertChar('\n', in);

                        if (!query.empty())
                            queries.emplace_back(std::move(query));
                    }
                    break;
                }
            }

            if (queries.empty())
                throw Exception(ErrorCodes::EMPTY_DATA_PASSED, "Empty list of queries.");
        }
        else
        {
            queries.emplace_back(query_to_execute);
        }


        std::lock_guard lock(mutex);
        log << "Loaded " << queries.size() << " queries.\n" << flush;
    }

    /// Try push new query and check cancellation conditions
    bool tryPushQueryInteractively(const String & query, InterruptListener & interrupt_listener)