aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-23 08:55:40 +01:00
Code Issues Packages Projects Releases Wiki Activity

core/mvcc: test with delete after checkpoint

Browse Source
This commit is contained in:
Pere Diaz Bou
2025-11-19 16:56:32 +01:00
parent b4c11705f3
commit bf1afb56cf
1 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
core/mvcc/database/tests.rs
View File

@@ -1658,3 +1658,34 @@ fn test_cursor_with_btree_and_mvcc_with_backward_cursor() {
assert_eq!(rows[1], vec![Value::Integer(2)]);
assert_eq!(rows[2], vec![Value::Integer(1)]);
}
#[test]
#[ignore = "we need to implement seek with btree cursor"]
fn test_cursor_with_btree_and_mvcc_with_backward_cursor_with_delete() {
let mut db = MvccTestDbNoConn::new_with_random_db();
// First write some rows and checkpoint so data is flushed to BTree file (.db)
{
let conn = db.connect();
conn.execute("CREATE TABLE t(x integer primary key)")
.unwrap();
conn.execute("INSERT INTO t VALUES (1)").unwrap();
conn.execute("INSERT INTO t VALUES (2)").unwrap();
conn.execute("INSERT INTO t VALUES (4)").unwrap();
conn.execute("INSERT INTO t VALUES (5)").unwrap();
conn.execute("PRAGMA wal_checkpoint(TRUNCATE)").unwrap();
}
// Now restart so new connection will have to read data from BTree instead of MVCC.
db.restart();
let conn = db.connect();
// Insert a new row so that we have a gap in the BTree.
conn.execute("INSERT INTO t VALUES (3)").unwrap();
conn.execute("DELETE FROM t WHERE x = 2").unwrap();
println!("getting rows");
let rows = get_rows(&conn, "SELECT * FROM t order by x desc");
dbg!(&rows);
assert_eq!(rows.len(), 4);
assert_eq!(rows[0], vec![Value::Integer(5)]);
assert_eq!(rows[1], vec![Value::Integer(4)]);
assert_eq!(rows[2], vec![Value::Integer(3)]);
assert_eq!(rows[2], vec![Value::Integer(1)]);
}