fix: 修复 RocksMap.startWith 一致迭代到尾部的 bug

helyho · Mar 25, 2020 · 971c18a · 971c18a
1 parent a085ca0
commit 971c18a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/Common/pom.xml b/Common/pom.xml
@@ -37,7 +37,7 @@
         <dependency>
             <groupId>org.rocksdb</groupId>
             <artifactId>rocksdbjni</artifactId>
-            <version>6.2.4</version>
+            <version>6.6.4</version>
             <optional>true</optional>
         </dependency>
         <dependency>

diff --git a/Common/src/main/java/org/voovan/tools/collection/RocksMap.java b/Common/src/main/java/org/voovan/tools/collection/RocksMap.java
@@ -1524,6 +1524,8 @@ public Map<K,V> startWith(K key, int skipSize, int size) {
                 iterator.directNext();
                 if (TByte.byteArrayStartWith(iterator.keyBytes(), keyBytes)) {
                     entryMap.put((K) iterator.key(), (V) iterator.value());
+                } else {
+                    break;
                 }
             }
 

diff --git a/Common/src/test/java/org/voovan/test/tools/collection/RocksMapTest.java b/Common/src/test/java/org/voovan/test/tools/collection/RocksMapTest.java
@@ -94,7 +94,7 @@ public void testWal() throws RocksDBException {
 //        columnFamilyOptions.setWriteBufferSize(1024*1024*512);
 
         RocksMap rocksMap =  new RocksMap("waltest", "cfname", columnFamilyOptions, dbOptions, readOptions, writeOptions, false);
-        for(int i=0;i<300000;i++){
+        for(int i=0;i<30;i++){
             rocksMap.put(i, i);
         }
         rocksMap.compact();