| 1 | #include "catch.hpp" |
|---|---|
| 2 | #include "duckdb/common/file_system.hpp" |
| 3 | #include "test_helpers.hpp" |
| 4 | |
| 5 | using namespace duckdb; |
| 6 | using namespace std; |
| 7 | |
| 8 | TEST_CASE("Test functioning of checksum", "[storage]") { |
| 9 | FileSystem fs; |
| 10 | unique_ptr<DuckDB> database; |
| 11 | auto storage_database = TestCreatePath("checksum_test"); |
| 12 | auto config = GetTestConfig(); |
| 13 | |
| 14 | // make sure the database does not exist |
| 15 | DeleteDatabase(storage_database); |
| 16 | { |
| 17 | // create a database and insert values |
| 18 | DuckDB db(storage_database, config.get()); |
| 19 | Connection con(db); |
| 20 | REQUIRE_NO_FAIL(con.Query("CREATE TABLE test(a INTEGER);")); |
| 21 | REQUIRE_NO_FAIL(con.Query("INSERT INTO test VALUES (3);")); |
| 22 | } |
| 23 | // we can open the database file now |
| 24 | REQUIRE_NOTHROW(database = make_unique<DuckDB>(storage_database, config.get())); |
| 25 | database.reset(); |
| 26 | |
| 27 | // now write random values into the file |
| 28 | auto handle = fs.OpenFile(storage_database, FileFlags::WRITE); |
| 29 | int8_t value = 0x22; |
| 30 | fs.Write(*handle, &value, sizeof(int8_t), 100); |
| 31 | handle->Sync(); |
| 32 | handle.reset(); |
| 33 | // reloading the database no longer works |
| 34 | REQUIRE_THROWS(database = make_unique<DuckDB>(storage_database, config.get())); |
| 35 | |
| 36 | DeleteDatabase(storage_database); |
| 37 | } |
| 38 |