Method init

test/test_runner/multi_copy_split.cpp:61–96

}

void SplitMultiCopyRandom::init() {
    genSeedIfNecessary();

    const std::string tmpDir = TestHelper::getTempDir("multi_copy");
    auto totalFilePath = TestHelper::joinPath(tmpDir, tableName + ".csv");
    auto loadQuery = std::format("COPY (LOAD FROM {} RETURN *) TO '{}';", source, totalFilePath);
    spdlog::info("QUERY: {}", loadQuery);
    validateQuery(connection, loadQuery);

    auto lineEnds = getLineEnds(totalFilePath);

    auto lineIdx = 0u;
    std::vector<std::string> lengths;
    std::ifstream file(totalFilePath);
    for (auto& endLine : lineEnds) {
        lengths.push_back(std::to_string(endLine - lineIdx));
        auto currFilePath =
            TestHelper::joinPath(tmpDir, tableName + std::to_string(lengths.size()) + ".csv");
        std::ofstream outfile(currFilePath);
        if (!outfile.is_open()) {
            throw TestException(
                std::format("Error opening file: {}, errno: {}.", currFilePath, errno));
        }
        splitFilePaths.push_back(currFilePath);
        std::string line;
        for (; lineIdx < endLine; lineIdx++) {
            if (!getline(file, line)) {
                throw TestException(
                    std::format("Expected line number mismatch: {} to {}.", lineIdx, endLine));
            }
            outfile << line << "\n";
        }
    }
    spdlog::info("RANDOM MULTI COPY: split {} lines into {} chunks of {} lines",
        lineEnds[lineEnds.size() - 1], numSplit, StringUtils::join(lengths, ", "));
}

void SplitMultiCopyRandom::run() {
    for (auto file : splitFilePaths) {