| 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 | |