From 6c4ee1e905d279d7dd1ac875d36d021a346aa32c Mon Sep 17 00:00:00 2001 From: ben594 Date: Sun, 19 Jan 2025 20:04:25 -0500 Subject: [PATCH] Update changes on delete Remove unwrap --- core/vdbe/mod.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/core/vdbe/mod.rs b/core/vdbe/mod.rs index cc64c68a1..1d9676249 100644 --- a/core/vdbe/mod.rs +++ b/core/vdbe/mod.rs @@ -896,10 +896,9 @@ impl Program { Ok(crate::storage::wal::CheckpointStatus::IO) => Ok(StepResult::IO), Ok(crate::storage::wal::CheckpointStatus::Done) => { if self.change_cnt_on { - self.connection - .upgrade() - .unwrap() - .set_changes(self.n_change.get()); + if let Some(conn) = self.connection.upgrade() { + conn.set_changes(self.n_change.get()); + } } Ok(StepResult::Done) } @@ -2106,6 +2105,8 @@ impl Program { Insn::DeleteAwait { cursor_id } => { let cursor = btree_table_cursors.get_mut(cursor_id).unwrap(); cursor.wait_for_completion()?; + let prev_changes = self.n_change.get(); + self.n_change.set(prev_changes + 1); state.pc += 1; } Insn::NewRowid {