138 lines
4.3 KiB
Java
138 lines
4.3 KiB
Java
package redis.clients.jedis.tests;
|
|
|
|
import org.junit.Assert;
|
|
import org.junit.Before;
|
|
import org.junit.Test;
|
|
import redis.clients.jedis.*;
|
|
import redis.clients.jedis.exceptions.JedisDataException;
|
|
import redis.clients.jedis.tests.HostAndPortUtil.HostAndPort;
|
|
|
|
import java.io.UnsupportedEncodingException;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
import java.util.UUID;
|
|
|
|
public class PipeliningTest extends Assert {
|
|
private static HostAndPort hnp = HostAndPortUtil.getRedisServers().get(0);
|
|
|
|
private Jedis jedis;
|
|
|
|
@Before
|
|
public void setUp() throws Exception {
|
|
jedis = new Jedis(hnp.host, hnp.port, 500);
|
|
jedis.connect();
|
|
jedis.auth("foobared");
|
|
jedis.flushAll();
|
|
}
|
|
|
|
@Test
|
|
public void pipeline() throws UnsupportedEncodingException {
|
|
List<Object> results = jedis.pipelined(new PipelineBlock() {
|
|
public void execute() {
|
|
set("foo", "bar");
|
|
get("foo");
|
|
}
|
|
});
|
|
|
|
assertEquals(2, results.size());
|
|
assertEquals("OK", results.get(0));
|
|
assertEquals("bar", results.get(1));
|
|
|
|
Pipeline p = jedis.pipelined();
|
|
p.set("foo", "bar");
|
|
p.get("foo");
|
|
results = p.syncAndReturnAll();
|
|
|
|
assertEquals(2, results.size());
|
|
assertEquals("OK", results.get(0));
|
|
assertEquals("bar", results.get(1));
|
|
|
|
}
|
|
|
|
@Test
|
|
public void pipelineResponse() {
|
|
jedis.set("string", "foo");
|
|
jedis.lpush("list", "foo");
|
|
jedis.hset("hash", "foo", "bar");
|
|
jedis.zadd("zset", 1, "foo");
|
|
jedis.sadd("set", "foo");
|
|
|
|
Pipeline p = jedis.pipelined();
|
|
Response<String> string = p.get("string");
|
|
Response<String> list = p.lpop("list");
|
|
Response<String> hash = p.hget("hash", "foo");
|
|
Response<Set<String>> zset = p.zrange("zset", 0, -1);
|
|
Response<String> set = p.spop("set");
|
|
Response<Boolean> blist = p.exists("list");
|
|
Response<Double> zincrby = p.zincrby("zset", 1, "foo");
|
|
Response<Long> zcard = p.zcard("zset");
|
|
p.lpush("list", "bar");
|
|
Response<List<String>> lrange = p.lrange("list", 0, -1);
|
|
Response<Map<String, String>> hgetAll = p.hgetAll("hash");
|
|
p.sadd("set", "foo");
|
|
Response<Set<String>> smembers = p.smembers("set");
|
|
Response<Set<Tuple>> zrangeWithScores = p.zrangeWithScores("zset", 0,
|
|
-1);
|
|
p.sync();
|
|
|
|
assertEquals("foo", string.get());
|
|
assertEquals("foo", list.get());
|
|
assertEquals("bar", hash.get());
|
|
assertEquals("foo", zset.get().iterator().next());
|
|
assertEquals("foo", set.get());
|
|
assertEquals(false, blist.get());
|
|
assertEquals(Double.valueOf(2), zincrby.get());
|
|
assertEquals(Long.valueOf(1), zcard.get());
|
|
assertEquals(1, lrange.get().size());
|
|
assertNotNull(hgetAll.get().get("foo"));
|
|
assertEquals(1, smembers.get().size());
|
|
assertEquals(1, zrangeWithScores.get().size());
|
|
}
|
|
|
|
@Test(expected = JedisDataException.class)
|
|
public void pipelineResponseWithinPipeline() {
|
|
jedis.set("string", "foo");
|
|
|
|
Pipeline p = jedis.pipelined();
|
|
Response<String> string = p.get("string");
|
|
string.get();
|
|
p.sync();
|
|
}
|
|
|
|
@Test
|
|
public void pipelineWithPubSub() {
|
|
Pipeline pipelined = jedis.pipelined();
|
|
Response<Long> p1 = pipelined.publish("foo", "bar");
|
|
Response<Long> p2 = pipelined.publish("foo".getBytes(), "bar"
|
|
.getBytes());
|
|
pipelined.sync();
|
|
assertEquals(0, p1.get().longValue());
|
|
assertEquals(0, p2.get().longValue());
|
|
}
|
|
|
|
@Test
|
|
public void canRetrieveUnsetKey() {
|
|
Pipeline p = jedis.pipelined();
|
|
Response<String> shouldNotExist = p.get(UUID.randomUUID().toString());
|
|
p.sync();
|
|
assertNull(shouldNotExist.get());
|
|
}
|
|
|
|
@Test
|
|
public void piplineWithError(){
|
|
Pipeline p = jedis.pipelined();
|
|
p.set("foo", "bar");
|
|
Response<Set<String>> error = p.smembers("foo");
|
|
Response<String> r = p.get("foo");
|
|
p.sync();
|
|
try{
|
|
error.get();
|
|
fail();
|
|
}catch(JedisDataException e){
|
|
//that is fine we should be here
|
|
}
|
|
assertEquals(r.get(), "bar");
|
|
}
|
|
}
|