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

fix sort order of write set

Browse Source
This commit is contained in:
Jussi Saurio
2025-09-30 22:54:36 +03:00
parent 509bde109e
commit fb2878973f
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/mvcc/database/mod.rs
View File

@@ -527,8 +527,10 @@ impl<Clock: LogicalClock> StateTransition for CommitStateMachine<Clock> {
tracing::trace!("commit_tx(tx_id={})", self.tx_id);
self.write_set
.extend(tx.write_set.iter().map(|v| *v.value()));
self.write_set
.sort_by(|a, b| a.table_id.cmp(&b.table_id).then(a.row_id.cmp(&b.row_id)));
self.write_set.sort_by(|a, b| {
// table ids are negative, and sqlite_schema has id -1 so we want to sort in descending order of table id
b.table_id.cmp(&a.table_id).then(a.row_id.cmp(&b.row_id))
});
if self.write_set.is_empty() {
tx.state.store(TransactionState::Committed(end_ts));
if mvcc_store.is_exclusive_tx(&self.tx_id) {