1 | #include "catch.hpp" |
2 | #include "test_helpers.hpp" |
3 | |
4 | using namespace duckdb; |
5 | using namespace std; |
6 | |
7 | TEST_CASE("Test NULL versions" , "[transactions]" ) { |
8 | unique_ptr<QueryResult> result; |
9 | DuckDB db(nullptr); |
10 | Connection con(db), con2(db); |
11 | con.EnableQueryVerification(); |
12 | |
13 | REQUIRE_NO_FAIL(con.Query("CREATE TABLE integers(i INTEGER, j INTEGER)" )); |
14 | REQUIRE_NO_FAIL(con.Query("INSERT INTO integers VALUES (NULL, 3)" )); |
15 | |
16 | result = con.Query("SELECT * FROM integers" ); |
17 | REQUIRE(CHECK_COLUMN(result, 0, {Value()})); |
18 | |
19 | // begin a transaction in con2 |
20 | REQUIRE_NO_FAIL(con2.Query("BEGIN TRANSACTION" )); |
21 | // update the row in con1 |
22 | REQUIRE_NO_FAIL(con.Query("UPDATE integers SET i=1,j=1" )); |
23 | |
24 | // con1 should see the value "1" |
25 | result = con.Query("SELECT * FROM integers" ); |
26 | REQUIRE(CHECK_COLUMN(result, 0, {1})); |
27 | REQUIRE(CHECK_COLUMN(result, 1, {1})); |
28 | |
29 | // con2 should see the value "NULL" |
30 | result = con2.Query("SELECT * FROM integers" ); |
31 | REQUIRE(CHECK_COLUMN(result, 0, {Value()})); |
32 | REQUIRE(CHECK_COLUMN(result, 1, {3})); |
33 | |
34 | // after a rollback con2 should see the value "1" as well |
35 | REQUIRE_NO_FAIL(con2.Query("ROLLBACK" )); |
36 | |
37 | result = con.Query("SELECT * FROM integers" ); |
38 | REQUIRE(CHECK_COLUMN(result, 0, {1})); |
39 | REQUIRE(CHECK_COLUMN(result, 1, {1})); |
40 | } |
41 | |