Method generateExportQuery

src/Client/BuzzHouse/Generator/QueryOracle.cpp:982–1061

}

void QueryOracle::generateExportQuery(
    RandomGenerator & rg, StatementGenerator & gen, const bool test_content, const SQLTable & t, SQLQuery & sq2)
{
    SettingValues * svs = nullptr;
    Insert * ins = sq2.mutable_single_query()->mutable_explain()->mutable_inner_query()->mutable_insert();
    FileFunc * ff = ins->mutable_tof()->mutable_tfunc()->mutable_file();
    Expr * expr = ff->mutable_structure();
    SelectParen * sparen = ins->mutable_select();
    SelectStatementCore * sel = sparen->mutable_select()->mutable_select_core();
    const std::filesystem::path & cnfile = fc.client_file_path / "table.data";
    const std::filesystem::path & snfile = fc.server_file_path / "table.data";

    can_test_oracle_result &= test_content;
    /// Remove the file if exists
    const auto err = std::filesystem::remove(cnfile);
    UNUSED(err);
    ff->set_path(snfile.generic_string());
    ff->set_fname(FileFunc_FName::FileFunc_FName_file);

    gen.flatTableColumnPath(skip_nested_node | flat_nested, t.cols, [](const SQLColumn & c) { return c.canBeInserted(); });
    if (!can_test_oracle_result && rg.nextSmallNumber() < 3)
    {
        /// Sometimes generate a not matching structure
        gen.addRandomRelation(rg, std::nullopt, static_cast<uint32_t>(gen.entries.size()), expr);
    }
    else
    {
        String buf;
        bool first = true;

        for (const auto & entry : gen.entries)
        {
            buf += fmt::format(
                "{}{} {}{}{}{}",
                first ? "" : ", ",
                entry.columnPathRef(),
                entry.path.size() > 1 ? "Array(" : "",
                entry.getBottomType()->typeName(false, false),
                entry.path.size() > 1 ? ")" : "",
                (entry.path.size() == 1 && entry.nullable.has_value()) ? (entry.nullable.value() ? " NULL" : " NOT NULL") : "");
            first = false;
        }
        expr->mutable_lit_val()->set_string_lit(std::move(buf));
    }
    for (const auto & entry : gen.entries)
    {
        gen.columnPathRef(entry, sel->add_result_columns()->mutable_etc()->mutable_col()->mutable_path());
    }
    gen.entries.clear();
    ff->set_outformat(rg.pickRandomly(rg.pickRandomly(can_test_oracle_result ? QueryOracle::oracleFormats : outFormats)));
    if (rg.nextSmallNumber() < 4)
    {
        ff->set_fcomp(rg.pickRandomly(compressionMethods));
    }
    if (rg.nextSmallNumber() < 10)
    {
        const auto & settings = can_test_oracle_result ? serverSettings : formatSettings;