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

fmt

Browse Source
This commit is contained in:
Jussi Saurio
2025-09-15 11:33:15 +03:00
parent f2dbf1eeb0
commit 88856de48e
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
tests/integration/query_processing/test_transactions.rs
View File

@@ -363,13 +363,16 @@ fn test_mvcc_update_same_row_twice() {
);
let conn1 = tmp_db.connect_limbo();
conn1.execute("CREATE TABLE test (id INTEGER PRIMARY KEY, value TEXT)")
conn1
.execute("CREATE TABLE test (id INTEGER PRIMARY KEY, value TEXT)")
.unwrap();
conn1.execute("INSERT INTO test (id, value) VALUES (1, 'first')")
conn1
.execute("INSERT INTO test (id, value) VALUES (1, 'first')")
.unwrap();
conn1.execute("UPDATE test SET value = 'second' WHERE id = 1")
conn1
.execute("UPDATE test SET value = 'second' WHERE id = 1")
.unwrap();
let stmt = conn1
@@ -382,7 +385,8 @@ fn test_mvcc_update_same_row_twice() {
};
assert_eq!(value.as_str(), "second");
conn1.execute("UPDATE test SET value = 'third' WHERE id = 1")
conn1
.execute("UPDATE test SET value = 'third' WHERE id = 1")
.unwrap();
let stmt = conn1
@@ -409,14 +413,20 @@ fn test_mvcc_concurrent_conflicting_update() {
.execute("CREATE TABLE test (id INTEGER, value TEXT)")
.unwrap();
conn1.execute("INSERT INTO test (id, value) VALUES (1, 'first')")
conn1
.execute("INSERT INTO test (id, value) VALUES (1, 'first')")
.unwrap();
conn1.execute("BEGIN CONCURRENT").unwrap();
conn2.execute("BEGIN CONCURRENT").unwrap();
conn1.execute("UPDATE test SET value = 'second' WHERE id = 1").unwrap();
let err = conn2.execute("UPDATE test SET value = 'third' WHERE id = 1").err().expect("expected error");
conn1
.execute("UPDATE test SET value = 'second' WHERE id = 1")
.unwrap();
let err = conn2
.execute("UPDATE test SET value = 'third' WHERE id = 1")
.err()
.expect("expected error");
assert!(matches!(err, LimboError::WriteWriteConflict));
}