From 312855bf536f213e9d0a5004d7117785ea7cb319 Mon Sep 17 00:00:00 2001 From: Jeronimo Irazabal Date: Sat, 26 Nov 2022 19:57:06 -0300 Subject: [PATCH] test: simplified zscan Signed-off-by: Jeronimo Irazabal --- .../java/io/codenotary/immudb4j/ScanTest.java | 47 ++++++++++++++++++- .../io/codenotary/immudb4j/ZScanTest.java | 42 +---------------- 2 files changed, 47 insertions(+), 42 deletions(-) diff --git a/src/test/java/io/codenotary/immudb4j/ScanTest.java b/src/test/java/io/codenotary/immudb4j/ScanTest.java index c919c64..8eded36 100644 --- a/src/test/java/io/codenotary/immudb4j/ScanTest.java +++ b/src/test/java/io/codenotary/immudb4j/ScanTest.java @@ -29,8 +29,8 @@ public class ScanTest extends ImmuClientIntegrationTest { public void t1() { immuClient.openSession("defaultdb", "immudb", "immudb"); - byte[] value1 = {0, 1, 2, 3}; - byte[] value2 = {4, 5, 6, 7}; + byte[] value1 = { 0, 1, 2, 3 }; + byte[] value2 = { 4, 5, 6, 7 }; try { immuClient.set("scan1", value1); @@ -39,6 +39,23 @@ public void t1() { Assert.fail("Failed at set.", e); } + try { + immuClient.set("zadd1", value1); + immuClient.set("zadd2", value2); + } catch (CorruptedDataException e) { + Assert.fail("Failed at set.", e); + } + + try { + immuClient.zAdd("set1", "zadd1", 1); + immuClient.zAdd("set1", "zadd2", 2); + + immuClient.zAdd("set2", "zadd1", 2); + immuClient.zAdd("set2", "zadd2", 1); + } catch (CorruptedDataException e) { + Assert.fail("Failed to zAdd", e); + } + List scanResult = immuClient.scanAll("scan"); System.out.println(scanResult.size()); @@ -63,6 +80,32 @@ public void t1() { Assert.assertEquals(i, 2); + Assert.assertFalse(immuClient.scan("nonexistent-prefix").hasNext()); + + List zScan1 = immuClient.zScanAll("set1", false, 5); + Assert.assertEquals(zScan1.size(), 2); + + Assert.assertEquals(zScan1.get(0).getSet(), "set1".getBytes(StandardCharsets.UTF_8)); + Assert.assertEquals(zScan1.get(0).getKey(), "zadd1".getBytes(StandardCharsets.UTF_8)); + Assert.assertEquals(zScan1.get(0).getScore(), 1.0); + Assert.assertEquals(zScan1.get(0).getAtTx(), 0); + Assert.assertEquals(zScan1.get(0).getEntry().getValue(), value1); + + List zScan2 = immuClient.zScanAll("set2"); + Assert.assertEquals(zScan2.size(), 2); + + Iterator zScan3 = immuClient.zScan("set2"); + i = 0; + + while (zScan3.hasNext()) { + Assert.assertEquals(zScan3.next().getKey(), zScan2.get(i).getKey()); + i++; + } + + Assert.assertEquals(i, 2); + + Assert.assertFalse(immuClient.zScan("nonexistent-set").hasNext()); + immuClient.closeSession(); } diff --git a/src/test/java/io/codenotary/immudb4j/ZScanTest.java b/src/test/java/io/codenotary/immudb4j/ZScanTest.java index 87e4219..fb2d897 100644 --- a/src/test/java/io/codenotary/immudb4j/ZScanTest.java +++ b/src/test/java/io/codenotary/immudb4j/ZScanTest.java @@ -29,47 +29,9 @@ public class ZScanTest extends ImmuClientIntegrationTest { public void t1() { immuClient.openSession("defaultdb", "immudb", "immudb"); - byte[] value1 = {0, 1, 2, 3}; - byte[] value2 = {4, 5, 6, 7}; + - try { - immuClient.set("zadd1", value1); - immuClient.set("zadd2", value2); - } catch (CorruptedDataException e) { - Assert.fail("Failed at set.", e); - } - - try { - immuClient.zAdd("set1", "zadd1", 1); - immuClient.zAdd("set1", "zadd2", 2); - - immuClient.zAdd("set2", "zadd1", 2); - immuClient.zAdd("set2", "zadd2", 1); - } catch (CorruptedDataException e) { - Assert.fail("Failed to zAdd", e); - } - - List zScan1 = immuClient.zScanAll("set1", false, 5); - Assert.assertEquals(zScan1.size(), 2); - - Assert.assertEquals(zScan1.get(0).getSet(), "set1".getBytes(StandardCharsets.UTF_8)); - Assert.assertEquals(zScan1.get(0).getKey(), "zadd1".getBytes(StandardCharsets.UTF_8)); - Assert.assertEquals(zScan1.get(0).getScore(), 1.0); - Assert.assertEquals(zScan1.get(0).getAtTx(), 0); - Assert.assertEquals(zScan1.get(0).getEntry().getValue(), value1); - - List zScan2 = immuClient.zScanAll("set2"); - Assert.assertEquals(zScan2.size(), 2); - - Iterator zScan3 = immuClient.zScan("set2"); - int i = 0; - - while (zScan3.hasNext()) { - Assert.assertEquals(zScan3.next().getKey(), zScan2.get(i).getKey()); - i++; - } - - Assert.assertEquals(i, 2); + immuClient.closeSession(); }