1 | #include "catch.hpp" |
2 | #include "test_helpers.hpp" |
3 | #include "duckdb/storage/storage_info.hpp" |
4 | |
5 | using namespace duckdb; |
6 | using namespace std; |
7 | |
8 | TEST_CASE("Test big append" , "[append][.]" ) { |
9 | unique_ptr<QueryResult> result; |
10 | DuckDB db(nullptr); |
11 | Connection con(db); |
12 | con.EnableQueryVerification(); |
13 | |
14 | // append entries bigger than one block |
15 | REQUIRE_NO_FAIL(con.Query("CREATE TABLE integers(i INTEGER);" )); |
16 | REQUIRE_NO_FAIL(con.Query("INSERT INTO integers VALUES (1), (2), (3), (NULL)" )); |
17 | |
18 | idx_t desired_count = (Storage::BLOCK_SIZE * 2) / sizeof(int); |
19 | idx_t current_count = 4; |
20 | while (current_count < desired_count) { |
21 | REQUIRE_NO_FAIL(con.Query("INSERT INTO integers SELECT * FROM integers" )); |
22 | current_count *= 2; |
23 | } |
24 | |
25 | result = con.Query("SELECT COUNT(*), COUNT(i), SUM(i) FROM integers" ); |
26 | REQUIRE(CHECK_COLUMN(result, 0, {Value::BIGINT(current_count)})); |
27 | REQUIRE(CHECK_COLUMN(result, 1, {Value::BIGINT(current_count / 4 * 3)})); |
28 | REQUIRE(CHECK_COLUMN(result, 2, {Value::BIGINT(current_count / 4 * 6)})); |
29 | } |
30 | |