Method runTest

test/graph_test/private_graph_test.cpp:87–233

}

void DBTest::runTest(std::vector<TestStatement>& statements, uint64_t checkpointWaitTimeout,
    std::set<std::string> connNames) {
    for (const auto& connName : connNames) {
        concurrentTests.try_emplace(connName, connectionsPaused, *connMap[connName], databasePath);
    }

    bool skipFsmLeakCheck = false;

    for (auto& statement : statements) {
        // special for testing import and export test cases
        if (statement.removeFileFlag) {
            auto filePath = statement.removeFilePath;
            filePath.erase(std::ranges::remove(filePath, '\"').begin(), filePath.end());
            removeFile(filePath);
            continue;
        }
        if (statement.importDBFlag) {
            auto filePath = statement.importFilePath;
            filePath.erase(std::ranges::remove(filePath, '\"').begin(), filePath.end());
            createNewDB();
            setIEDatabasePath(filePath);
            continue;
        }
        if (statement.reloadDBFlag) {
            // For in-mem mode, we skip reload.
            if (!inMemMode) {
                spdlog::info("QUERY: RELOAD DB");
                for (auto& name : connNames) {
                    if (connMap.contains(name)) {
                        connMap.erase(name);
                    }
                }
                createDB(checkpointWaitTimeout);
                createConns(connNames);
            }
            continue;
        }
        if (statement.expectedStorageVersion.has_value()) {
            if (!inMemMode) {
                conn.reset();
                connMap.clear();
                database.reset();
                const auto storageVersion = readStorageVersionFromHeader(databasePath);
                createDB(checkpointWaitTimeout);
                createConns(connNames);
                ASSERT_EQ(storageVersion, statement.expectedStorageVersion.value());
            }
            continue;
        }
        if (statement.storageVersionToSet.has_value()) {
            if (!inMemMode) {
                conn.reset();
                connMap.clear();
                database.reset();
                writeStorageVersionToHeader(databasePath, statement.storageVersionToSet.value());
                createDB(checkpointWaitTimeout);
                createConns(connNames);
            }