From c9b413c323df9ea47c1c72af6f85d37c14e5db44 Mon Sep 17 00:00:00 2001 From: ivowiblo Date: Tue, 17 Apr 2012 16:40:54 -0400 Subject: [PATCH] Select support to pipeline. Thanks to @ib84 --- src/main/java/redis/clients/jedis/Pipeline.java | 5 +++++ .../java/redis/clients/jedis/tests/PipeliningTest.java | 7 +++++++ 2 files changed, 12 insertions(+) diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java index 95bc773..520e975 100644 --- a/src/main/java/redis/clients/jedis/Pipeline.java +++ b/src/main/java/redis/clients/jedis/Pipeline.java @@ -1226,4 +1226,9 @@ public class Pipeline extends Queable { client.randomKey(); return getResponse(BuilderFactory.STRING); } + + public Response select(int index){ + client.select(index); + return getResponse(BuilderFactory.STRING); + } } \ No newline at end of file diff --git a/src/test/java/redis/clients/jedis/tests/PipeliningTest.java b/src/test/java/redis/clients/jedis/tests/PipeliningTest.java index 1b18e52..0a2f7d4 100644 --- a/src/test/java/redis/clients/jedis/tests/PipeliningTest.java +++ b/src/test/java/redis/clients/jedis/tests/PipeliningTest.java @@ -101,6 +101,13 @@ public class PipeliningTest extends Assert { assertNotNull(score.get()); } + @Test + public void pipelineSelect() { + Pipeline p = jedis.pipelined(); + p.select(1); + p.sync(); + } + @Test public void pipelineResponseWithoutData() { jedis.zadd("zset", 1, "foo");