Fix SELECT command in Pipeline (#3301)

redis · Feb 27, 2023 · 84d0aaa · 84d0aaa
1 parent eb0fa1d
commit 84d0aaa
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java
@@ -4272,7 +4272,7 @@ public Response<List<String>> time() {
 
   @Override
   public Response<String> select(final int index) {
-    return appendCommand(new CommandObject<>(commandObjects.commandArguments(Protocol.Command.SELECT), BuilderFactory.STRING));
+    return appendCommand(new CommandObject<>(commandObjects.commandArguments(Protocol.Command.SELECT).add(index), BuilderFactory.STRING));
   }
 
   @Override

diff --git a/src/test/java/redis/clients/jedis/PipeliningTest.java b/src/test/java/redis/clients/jedis/PipeliningTest.java
@@ -157,9 +157,13 @@ private void verifyHasBothValues(byte[] firstKey, byte[] secondKey, byte[] value
 
   @Test
   public void pipelineSelect() {
+    jedis.set("foo", "bar");
+    jedis.swapDB(0, 1);
     Pipeline p = jedis.pipelined();
+    p.get("foo");
     p.select(1);
-    p.sync();
+    p.get("foo");
+    assertEquals(Arrays.<Object>asList(null, "OK", "bar"), p.syncAndReturnAll());
   }
 
   @Test