fix(kv): fix checkAndDelete (#354)

netease-im · Nov 21, 2024 · 830a380 · 830a380
1 parent 8b822d2
commit 830a380
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...-proxy-kv-obkv/src/main/java/com/netease/nim/camellia/redis/proxy/kv/obkv/OBKVClient.java b/...-proxy-kv-obkv/src/main/java/com/netease/nim/camellia/redis/proxy/kv/obkv/OBKVClient.java
@@ -222,12 +222,12 @@ public boolean supportCheckAndDelete() {
     @Override
     public void checkAndDelete(int slot, byte[] key, byte[] value) {
         try {
-            TableQuery tableQuery = obTableClient.query(tableName).select("slot", "k", "v");
-            ObTableValueFilter filter1 = new ObTableValueFilter(ObCompareOp.EQ, "slot", slot);
-            ObTableValueFilter filter2 = new ObTableValueFilter(ObCompareOp.EQ, "k", key);
-            ObTableValueFilter filter3 = new ObTableValueFilter(ObCompareOp.EQ, "v", value);
-            ObTableFilterList filterList = new ObTableFilterList(ObTableFilterList.operator.AND, filter1, filter2, filter3);
-            tableQuery.setFilter(filterList);
+            TableQuery tableQuery = obTableClient.query(tableName)
+                    .select("slot", "k", "v")
+                    .addScanRange(new Object[]{slot, key}, true, new Object[]{slot, key}, true)
+                    .limit(1);
+            ObTableValueFilter filter = new ObTableValueFilter(ObCompareOp.EQ, "v", value);
+            tableQuery.setFilter(filter);
             ObTableQueryAndMutateRequest request = obTableClient.obTableQueryAndDelete(tableQuery);
             obTableClient.execute(request);
         } catch (Exception e) {