| 69 | } |
| 70 | |
| 71 | static void writeStorageVersionToHeader(const std::string& databasePath, uint64_t storageVersion) { |
| 72 | auto localFileSystem = common::LocalFileSystem(""); |
| 73 | auto fileInfo = localFileSystem.openFile(databasePath, |
| 74 | common::FileOpenFlags(common::FileFlags::READ_ONLY | common::FileFlags::WRITE)); |
| 75 | auto databaseHeader = DatabaseHeader::readDatabaseHeader(*fileInfo); |
| 76 | if (!databaseHeader.has_value()) { |
| 77 | throw TestException("Invalid database header: " + databasePath); |
| 78 | } |
| 79 | databaseHeader->storageVersion = storageVersion; |
| 80 | auto writer = std::make_shared<common::BufferedFileWriter>(*fileInfo); |
| 81 | common::Serializer serializer{writer}; |
| 82 | databaseHeader->serialize(serializer); |
| 83 | writer->flush(); |
| 84 | writer->sync(); |
| 85 | } |
| 86 | |
| 87 | void DBTest::runTest(std::vector<TestStatement>& statements, uint64_t checkpointWaitTimeout, |
| 88 | std::set<std::string> connNames) { |
no test coverage detected