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

test: logstor: add basic delete test

Browse Source 
extend the test with basic DELETE queries and verify the results are as
expected.
This commit is contained in:
Michael Litvak
2026-05-13 13:38:02 +02:00
parent 6e9d6f02df
commit c3ab341234
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
test/cluster/test_logstor.py
View File

@@ -86,6 +86,13 @@ async def test_basic_write_and_read(manager: ManagerClient):
assert rows[0].pk == 2
assert rows[0].v == 150
await cql.run_async(f"DELETE FROM {ks}.test_int WHERE pk = 1")
rows = await cql.run_async(f"SELECT pk, v FROM {ks}.test_int WHERE pk = 1")
assert len(rows) == 0
rows = await cql.run_async(f"SELECT pk, v FROM {ks}.test_int WHERE pk = 2")
assert rows[0].pk == 2
assert rows[0].v == 150
# test conflict resolution by timestamp
await cql.run_async(f"INSERT INTO {ks}.test_int (pk, v) VALUES (3, 300) USING TIMESTAMP 1000")
await cql.run_async(f"INSERT INTO {ks}.test_int (pk, v) VALUES (3, 200) USING TIMESTAMP 900")
@@ -107,6 +114,10 @@ async def test_basic_write_and_read(manager: ManagerClient):
assert rows[0].pk == 1
assert rows[0].v == {'a': 'apple', 'b': 'banana', 'c': 'cherry'}
await cql.run_async(f"DELETE FROM {ks}.test_map WHERE pk = 1")
rows = await cql.run_async(f"SELECT pk, v FROM {ks}.test_map WHERE pk = 1")
assert len(rows) == 0
@pytest.mark.asyncio
async def test_range_read(manager: ManagerClient):
cmdline = ['--logger-log-level', 'logstor=debug']