fix: TransactionIter seek duplicate value

KipData · Sep 7, 2023 · 89f0e8e · 89f0e8e
1 parent 2a1d86c
commit 89f0e8e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "kip_db"
-version = "0.1.2-alpha.11"
+version = "0.1.2-alpha.12"
 edition = "2021"
 authors = ["Kould <[email protected]>"]
 description = "轻量级、异步 基于LSM Leveled Compaction K-V数据库"

diff --git a/src/kernel/lsm/mvcc.rs b/src/kernel/lsm/mvcc.rs
@@ -133,10 +133,17 @@ impl Transaction {
 
  match min {
  Bound::Included(key) => {
- seek_buf = version_iter.seek(Seek::Backward(key))?;
+ let ver_seek_option = version_iter.seek(Seek::Backward(key))?;
  unsafe {
- if !ptr.0.as_ref().is_empty() && key == ptr.0.as_ref()[0].0.as_ref() {
- seek_buf = None;
+ let op = |option_a: Option<&KeyValue>, option_b: Option<&KeyValue>| {
+ match (option_a, option_b) {
+ (Some(a), Some(b)) => a.0 == b.0,
+ _ => false,
+ }
+ };
+
+ if !op(ver_seek_option.as_ref(), ptr.0.as_ref().first()) {
+ seek_buf = ver_seek_option;
  }
  }
  }