aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-18 09:04:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

slightly adjust one test

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-07-28 17:13:15 +04:00
parent 3614b022ab
commit 4d25cda1e2
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
tests/integration/functions/test_wal_api.rs
View File

@@ -41,10 +41,12 @@ fn test_wal_frame_transfer_no_schema_changes() {
assert_eq!(conn1.wal_frame_count().unwrap(), 15); assert_eq!(conn1.wal_frame_count().unwrap(), 15);
let mut frame = [0u8; 24 + 4096]; let mut frame = [0u8; 24 + 4096];
conn2.wal_insert_begin().unwrap(); conn2.wal_insert_begin().unwrap();
for frame_id in 1..=conn1.wal_frame_count().unwrap() as u32 { let frames_count = conn1.wal_frame_count().unwrap() as u32;
for frame_id in 1..=frames_count {
conn1.wal_get_frame(frame_id, &mut frame).unwrap(); conn1.wal_get_frame(frame_id, &mut frame).unwrap();
conn2.wal_insert_frame(frame_id, &frame).unwrap(); conn2.wal_insert_frame(frame_id, &frame).unwrap();
} }
conn2.wal_insert_end().unwrap(); conn2.wal_insert_end().unwrap();
assert_eq!(conn2.wal_frame_count().unwrap(), 15); assert_eq!(conn2.wal_frame_count().unwrap(), 15);
assert_eq!( assert_eq!(
@@ -134,12 +136,17 @@ fn test_wal_frame_transfer_schema_changes() {
.unwrap(); .unwrap();
assert_eq!(conn1.wal_frame_count().unwrap(), 15); assert_eq!(conn1.wal_frame_count().unwrap(), 15);
let mut frame = [0u8; 24 + 4096]; let mut frame = [0u8; 24 + 4096];
let mut commits = 0;
conn2.wal_insert_begin().unwrap(); conn2.wal_insert_begin().unwrap();
for frame_id in 1..=conn1.wal_frame_count().unwrap() as u32 { for frame_id in 1..=conn1.wal_frame_count().unwrap() as u32 {
conn1.wal_get_frame(frame_id, &mut frame).unwrap(); conn1.wal_get_frame(frame_id, &mut frame).unwrap();
conn2.wal_insert_frame(frame_id, &frame).unwrap(); let info = conn2.wal_insert_frame(frame_id, &frame).unwrap();
if info.is_commit {
commits += 1;
}
} }
conn2.wal_insert_end().unwrap(); conn2.wal_insert_end().unwrap();
assert_eq!(commits, 3);
assert_eq!(conn2.wal_frame_count().unwrap(), 15); assert_eq!(conn2.wal_frame_count().unwrap(), 15);
assert_eq!( assert_eq!(
limbo_exec_rows(&db2, &conn2, "SELECT x, length(y) FROM t"), limbo_exec_rows(&db2, &conn2, "SELECT x, length(y) FROM t"),