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

only rollback on write transaction

Browse Source
This commit is contained in:
pedrocarlo
2025-07-07 12:08:31 -03:00
parent 367002fb72
commit 6b60dd06c6
2 changed files with 10 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
core/lib.rs
View File

@@ -102,17 +102,6 @@ enum TransactionState {
None,
}
impl TransactionState {
fn schema_did_change(&self) -> bool {
matches!(
self,
TransactionState::Write {
schema_did_change: true
}
)
}
}
pub(crate) type MvStore = mvcc::MvStore<mvcc::LocalClock>;
pub(crate) type MvCursor = mvcc::cursor::ScanCursor<mvcc::LocalClock>;
@@ -633,7 +622,9 @@ impl Connection {
let res = self._db.io.run_once();
if res.is_err() {
let state = self.transaction_state.get();
self.pager.rollback(state.schema_did_change(), self)?;
if let TransactionState::Write { schema_did_change } = state {
self.pager.rollback(schema_did_change, self)?
}
}
res
}
@@ -906,8 +897,10 @@ impl Statement {
let res = self.pager.io.run_once();
if res.is_err() {
let state = self.program.connection.transaction_state.get();
self.pager
.rollback(state.schema_did_change(), &self.program.connection)?;
if let TransactionState::Write { schema_did_change } = state {
self.pager
.rollback(schema_did_change, &self.program.connection)?
}
}
res
}

4
core/vdbe/mod.rs
View File

@@ -386,7 +386,9 @@ impl Program {
let res = insn_function(self, state, insn, &pager, mv_store.as_ref());
if res.is_err() {
let state = self.connection.transaction_state.get();
pager.rollback(state.schema_did_change(), &self.connection)?
if let TransactionState::Write { schema_did_change } = state {
pager.rollback(schema_did_change, &self.connection)?
}
}
match res? {
InsnFunctionStepResult::Step => {}