DATAREDIS-1015 - Upgrade to Jedis 3.1.0.

Add pipelining/transactional implementation for zcount.

Author: mp911de

pom.xml

@@ -22,7 +22,7 @@
 <xstream>1.4.8</xstream>
 <pool>2.6.0</pool>
 <lettuce>5.1.6.RELEASE</lettuce>
-<jedis>3.0.1</jedis>
+<jedis>3.1.0</jedis>
 <multithreadedtc>1.01</multithreadedtc>
 <netty>4.1.22.Final</netty>
 <java-module-name>spring.data.redis</java-module-name>

src/main/java/org/springframework/data/redis/connection/jedis/JedisZSetCommands.java

@@ -466,16 +466,24 @@ public Long zCount(byte[] key, double min, double max) {
 public Long zCount(byte[] key, Range range) {
 
 Assert.notNull(key, "Key must not be null!");
+Assert.notNull(range, "Range must not be null!");
 
-if (isPipelined() || isQueueing()) {
-throw new UnsupportedOperationException(
-"ZCOUNT not implemented in jedis for binary protocol on transaction and pipeline");
-}
-
-// TODO: Implement zcount for pipeline/tx.
 byte[] min = JedisConverters.boundaryToBytesForZRange(range.getMin(), JedisConverters.NEGATIVE_INFINITY_BYTES);
 byte[] max = JedisConverters.boundaryToBytesForZRange(range.getMax(), JedisConverters.POSITIVE_INFINITY_BYTES);
-return connection.getJedis().zcount(key, min, max);
+
+try {
+if (isPipelined()) {
+pipeline(connection.newJedisResult(connection.getRequiredPipeline().zcount(key, min, max)));
+return null;
+}
+if (isQueueing()) {
+transaction(connection.newJedisResult(connection.getRequiredTransaction().zcount(key, min, max)));
+return null;
+}
+return connection.getJedis().zcount(key, min, max);
+} catch (Exception ex) {
+throw convertJedisAccessException(ex);
+}
 }
 
 /*