Method convertCSVFiles

test/test_runner/csv_converter.cpp:152–180

}

void CSVConverter::convertCSVFiles() {
    // Load CSV Files to temp database
    TestHelper::executeScript(
        LocalFileSystem::joinPath(csvDatasetPath, std::string(TestHelper::SCHEMA_FILE_NAME)),
        *tempConn);
    TestHelper::executeScript(
        LocalFileSystem::joinPath(csvDatasetPath, std::string(TestHelper::COPY_FILE_NAME)),
        *tempConn);

    spdlog::set_level(spdlog::level::info);
    if (fileExtension == ".json") {
        auto result = tempConn->query(
            "load extension \"" +
            TestHelper::appendLbugRootPath("extension/json/build/libjson.lbug_extension\""));
        if (!result->isSuccess()) {
            spdlog::error(result->getErrorMessage());
        }
    }
    for (auto table : tables) {
        spdlog::info("Converting: {} to {}", table->csvFilePath, table->outputFilePath);
        auto cmd = table->getConverterQuery(tempConn->getClientContext());
        auto result = tempConn->query(cmd);
        if (!result->isSuccess()) {
            spdlog::error(result->getErrorMessage());
        } else {
            spdlog::info("Executed query: {}", cmd);
        }
    }
}

void CSVConverter::convertCSVDataset() {
    LocalFileSystem localFileSystem("");