From ddb804adc2d72b2e666df2031e8dbf324206b930 Mon Sep 17 00:00:00 2001 From: Somtochi Onyekwere Date: Tue, 23 Dec 2025 18:13:33 +0100 Subject: [PATCH] clear db_version on commit/rollback Signed-off-by: Somtochi Onyekwere --- core/rs/core/src/commit.rs | 8 +++++++- core/rs/core/src/db_version.rs | 2 +- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/core/rs/core/src/commit.rs b/core/rs/core/src/commit.rs index 096482e9..623d31f4 100644 --- a/core/rs/core/src/commit.rs +++ b/core/rs/core/src/commit.rs @@ -42,8 +42,14 @@ pub unsafe fn commit_or_rollback_reset(ext_data: *mut crsql_ExtData) { let mut table_infos = unsafe { mem::ManuallyDrop::new(Box::from_raw((*ext_data).tableInfos as *mut Vec)) }; - ordinals.clear(); + let mut last_db_versions: mem::ManuallyDrop, i64>>> = + mem::ManuallyDrop::new(Box::from_raw( + (*ext_data).lastDbVersions as *mut BTreeMap, i64>, + )); + + last_db_versions.clear(); + ordinals.clear(); for tbl_info in table_infos.iter_mut() { tbl_info.clear_cl_cache(); } diff --git a/core/rs/core/src/db_version.rs b/core/rs/core/src/db_version.rs index 9aa60473..a888a676 100644 --- a/core/rs/core/src/db_version.rs +++ b/core/rs/core/src/db_version.rs @@ -217,7 +217,7 @@ pub fn insert_db_version( insert_db_vrsn: i64, ) -> Result<(), ResultCode> { unsafe { - // we can get a more recent db_versio + // we can get a more recent db_version let mut last_db_versions: mem::ManuallyDrop, i64>>> = mem::ManuallyDrop::new(Box::from_raw( (*ext_data).lastDbVersions as *mut BTreeMap, i64>,