mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-13 03:12:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: db: Add test for row merging involving many versions

Browse Source 
The test verifies that a row which participated in earlier merge, and
its cells lost on the timestamp check, behaves exactly like an empty
row and can accept any mutation.

This wasn't the case in versions prior to f006acc.

Closes #11787
This commit is contained in:
Tomasz Grabiec
2022-10-13 01:11:37 +02:00
committed by Avi Kivity
parent 5d7e40af99
commit c8a372ae7f
2 changed files with 29 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
test/boost/mutation_test.cc
View File

@@ -1877,6 +1877,26 @@ SEASTAR_TEST_CASE(test_commutativity_and_associativity) {
return make_ready_future<>();
}
SEASTAR_THREAD_TEST_CASE(test_row_merging) {
simple_schema table;
auto&& s = *table.schema();
row r1;
table.set_cell(r1, "v1");
row r2;
table.set_cell(r2, "v2");
row r3;
table.set_cell(r3, "v3");
r2.apply_monotonically(s, column_kind::regular_column, std::move(r1));
auto r3_backup = row(s, column_kind::regular_column, r3);
r1.apply_monotonically(s, column_kind::regular_column, std::move(r3));
BOOST_REQUIRE(r1.equal(column_kind::regular_column, s, r3_backup, s));
}
SEASTAR_TEST_CASE(test_continuity_merging) {
return seastar::async([] {
simple_schema table;

9
test/lib/simple_schema.hh
View File

@@ -138,6 +138,15 @@ public:
return t;
}
api::timestamp_type set_cell(row& r, const sstring& v, api::timestamp_type t = api::missing_timestamp) {
if (t == api::missing_timestamp) {
t = new_timestamp();
}
const column_definition& v_def = get_v_def(*_s);
r.apply_monotonically(v_def, atomic_cell::make_live(*v_def.type, t, serialized(v)));
return t;
}
std::pair<sstring, api::timestamp_type> get_value(const schema& s, const clustering_row& row) {
const column_definition& v_def = get_v_def(s);
auto cell = row.cells().find_cell(v_def.id);