From 0e42e81e577eca539e4a2d6abca595f618fc4d39 Mon Sep 17 00:00:00 2001 From: zymap Date: Thu, 23 May 2024 14:11:40 +0800 Subject: [PATCH] Add test for the partitionKey with other operation --- .../oxia/client/it/OxiaClientIT.java | 24 +++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientIT.java b/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientIT.java index 6b475b0e..3a208158 100644 --- a/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientIT.java +++ b/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientIT.java @@ -17,6 +17,7 @@ import static io.streamnative.oxia.client.api.PutOption.IfRecordDoesNotExist; import static io.streamnative.oxia.client.api.PutOption.IfVersionIdEquals; +import static io.streamnative.oxia.client.api.PutOption.PartitionKey; import static java.nio.charset.StandardCharsets.UTF_8; import static java.util.concurrent.CompletableFuture.allOf; import static java.util.function.Function.identity; @@ -229,6 +230,29 @@ void test() throws Exception { .isEqualTo(24); } + @Test + public void testGetFloorCeilingWithPartitionKey() throws Exception { + @Cleanup + SyncOxiaClient client = OxiaClientBuilder.create(oxia.getServiceAddress()).syncClient(); + + + GetResult gr = client.get("a", Set.of(GetOption.PartitionKey("a"), GetOption.ComparisonCeiling)); + if (gr != null) { + System.out.println(gr.getKey()); + } else { + System.out.println("ComparisionCeiling null"); + } + + + gr = client.get("a", Set.of(GetOption.PartitionKey("a"), GetOption.ComparisonHigher)); + if (gr != null) { + System.out.println(gr.getKey()); + } else { + System.out.println("ComparisionHigher null"); + } + + } + @Test void testGetFloorCeiling() throws Exception { @Cleanup