add select to transaction
This commit is contained in:
@@ -563,4 +563,9 @@ public class BinaryTransaction extends Queable {
|
|||||||
client.brpoplpush(source, destination, timeout);
|
client.brpoplpush(source, destination, timeout);
|
||||||
return getResponse(BuilderFactory.BYTE_ARRAY);
|
return getResponse(BuilderFactory.BYTE_ARRAY);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Response<String> select(final int index) {
|
||||||
|
client.select(index);
|
||||||
|
return getResponse(BuilderFactory.STRING);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -576,5 +576,4 @@ public class Transaction extends BinaryTransaction {
|
|||||||
client.publish(channel, message);
|
client.publish(channel, message);
|
||||||
return getResponse(BuilderFactory.LONG);
|
return getResponse(BuilderFactory.LONG);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -277,4 +277,22 @@ public class TransactionCommandsTest extends JedisCommandTestBase {
|
|||||||
}
|
}
|
||||||
assertEquals("bar", lr.get(2).get());
|
assertEquals("bar", lr.get(2).get());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void select() {
|
||||||
|
jedis.select(1);
|
||||||
|
jedis.set("foo", "bar");
|
||||||
|
jedis.watch("foo");
|
||||||
|
Transaction t = jedis.multi();
|
||||||
|
t.select(0);
|
||||||
|
t.set("bar", "foo");
|
||||||
|
|
||||||
|
Jedis jedis2 = createJedis();
|
||||||
|
jedis2.select(1);
|
||||||
|
jedis2.set("foo", "bar2");
|
||||||
|
|
||||||
|
List<Object> results = t.exec();
|
||||||
|
|
||||||
|
assertNull(results);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user