aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-03 00:14:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

mvcc: revert connection schema changes in mv rollback

Browse Source
This commit is contained in:
Jussi Saurio
2025-09-24 14:42:08 +03:00
parent 1626ef046b
commit ede2a882f1
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1357,6 +1357,13 @@ impl<Clock: LogicalClock> MvStore<Clock> {
}
}
if connection.schema.borrow().schema_version
> connection.db.schema.lock().unwrap().schema_version
{
// Connection made schema changes during tx and rolled back -> revert connection-local schema.
connection.schema.replace(connection.db.clone_schema()?);
}
let tx = tx_unlocked.value();
tx.state.store(TransactionState::Terminated);
tracing::trace!("terminate(tx_id={})", tx_id);