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>,