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

Fix delete() on non-existent ID

Browse Source
This commit is contained in:
Pekka Enberg
2023-04-08 18:03:41 +03:00
parent 7a2085c02f
commit 957949a49d
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
core/mvcc/database/src/lib.rs
View File

@@ -238,17 +238,19 @@ impl<Clock: LogicalClock> Database<Clock> {
let inner = self.inner.lock().unwrap();
let mut rows = inner.rows.borrow_mut();
let mut txs = inner.txs.borrow_mut();
let row_versions = rows.get_mut(&id).unwrap();
match row_versions.last_mut() {
Some(v) => {
let tx = txs.get(&tx).unwrap();
if is_version_visible(&txs, tx, v) {
v.end = Some(TxTimestampOrID::TxID(tx.tx_id));
} else {
return false;
match rows.get_mut(&id) {
Some(row_versions) => match row_versions.last_mut() {
Some(v) => {
let tx = txs.get(&tx).unwrap();
if is_version_visible(&txs, tx, v) {
v.end = Some(TxTimestampOrID::TxID(tx.tx_id));
} else {
return false;
}
}
}
None => unreachable!("no versions for row {}", id),
None => unreachable!("no versions for row {}", id),
},
None => return false,
}
let tx = txs.get_mut(&tx).unwrap();
tx.insert_to_write_set(id);