diff --git a/redis/src/test/java/com/baeldung/JedisTest.java b/redis/src/test/java/com/baeldung/JedisTest.java index 55fee95328..b8e29327a1 100644 --- a/redis/src/test/java/com/baeldung/JedisTest.java +++ b/redis/src/test/java/com/baeldung/JedisTest.java @@ -25,201 +25,201 @@ import redis.embedded.RedisServer; */ public class JedisTest { - private Jedis jedis; - private static RedisServer redisServer; + private Jedis jedis; + private static RedisServer redisServer; - public JedisTest() { - jedis = new Jedis(); - } + public JedisTest() { + jedis = new Jedis(); + } - @BeforeClass - public static void setUp() throws IOException { - redisServer = new RedisServer(6379); - redisServer.start(); - } + @BeforeClass + public static void setUp() throws IOException { + redisServer = new RedisServer(6379); + redisServer.start(); + } - @AfterClass - public static void destroy() { - redisServer.stop(); - } + @AfterClass + public static void destroy() { + redisServer.stop(); + } - @After - public void flush() { - jedis.flushAll(); - } + @After + public void flush() { + jedis.flushAll(); + } - @Test - public void givenAStringThenSaveItAsRedisStrings() { - String key = "key"; - String value = "value"; + @Test + public void givenAStringThenSaveItAsRedisStrings() { + String key = "key"; + String value = "value"; - jedis.set(key, value); - String value2 = jedis.get(key); + jedis.set(key, value); + String value2 = jedis.get(key); - Assert.assertEquals(value, value2); - } + Assert.assertEquals(value, value2); + } - @Test - public void givenListElementsThenSaveThemInRedisList() { - String queue = "queue#tasks"; + @Test + public void givenListElementsThenSaveThemInRedisList() { + String queue = "queue#tasks"; - String taskOne = "firstTask"; - String taskTwo = "secondTask"; - String taskThree = "thirdTask"; + String taskOne = "firstTask"; + String taskTwo = "secondTask"; + String taskThree = "thirdTask"; - jedis.lpush(queue, taskOne, taskTwo); + jedis.lpush(queue, taskOne, taskTwo); - String taskReturnedOne = jedis.rpop(queue); + String taskReturnedOne = jedis.rpop(queue); - jedis.lpush(queue, taskThree); - Assert.assertEquals(taskOne, taskReturnedOne); + jedis.lpush(queue, taskThree); + Assert.assertEquals(taskOne, taskReturnedOne); - String taskReturnedTwo = jedis.rpop(queue); - String taskReturnedThree = jedis.rpop(queue); + String taskReturnedTwo = jedis.rpop(queue); + String taskReturnedThree = jedis.rpop(queue); - Assert.assertEquals(taskTwo, taskReturnedTwo); - Assert.assertEquals(taskThree, taskReturnedThree); + Assert.assertEquals(taskTwo, taskReturnedTwo); + Assert.assertEquals(taskThree, taskReturnedThree); - String taskReturnedFour = jedis.rpop(queue); - Assert.assertNull(taskReturnedFour); - } + String taskReturnedFour = jedis.rpop(queue); + Assert.assertNull(taskReturnedFour); + } - @Test - public void givenSetElementsThenSaveThemInRedisSet() { - String countries = "countries"; + @Test + public void givenSetElementsThenSaveThemInRedisSet() { + String countries = "countries"; - String countryOne = "Spain"; - String countryTwo = "Ireland"; - String countryThree = "Ireland"; + String countryOne = "Spain"; + String countryTwo = "Ireland"; + String countryThree = "Ireland"; - jedis.sadd(countries, countryOne); + jedis.sadd(countries, countryOne); - Set countriesSet = jedis.smembers(countries); - Assert.assertEquals(1, countriesSet.size()); + Set countriesSet = jedis.smembers(countries); + Assert.assertEquals(1, countriesSet.size()); - jedis.sadd(countries, countryTwo); - countriesSet = jedis.smembers(countries); - Assert.assertEquals(2, countriesSet.size()); + jedis.sadd(countries, countryTwo); + countriesSet = jedis.smembers(countries); + Assert.assertEquals(2, countriesSet.size()); - jedis.sadd(countries, countryThree); - countriesSet = jedis.smembers(countries); - Assert.assertEquals(2, countriesSet.size()); + jedis.sadd(countries, countryThree); + countriesSet = jedis.smembers(countries); + Assert.assertEquals(2, countriesSet.size()); - boolean exists = jedis.sismember(countries, countryThree); - Assert.assertTrue(exists); - } + boolean exists = jedis.sismember(countries, countryThree); + Assert.assertTrue(exists); + } - @Test - public void givenObjectFieldsThenSaveThemInRedisHash() { - String key = "user#1"; + @Test + public void givenObjectFieldsThenSaveThemInRedisHash() { + String key = "user#1"; - String field = "name"; - String value = "William"; + String field = "name"; + String value = "William"; - String field2 = "job"; - String value2 = "politician"; + String field2 = "job"; + String value2 = "politician"; - jedis.hset(key, field, value); - jedis.hset(key, field2, value2); + jedis.hset(key, field, value); + jedis.hset(key, field2, value2); - String value3 = jedis.hget(key, field); - Assert.assertEquals(value, value3); + String value3 = jedis.hget(key, field); + Assert.assertEquals(value, value3); - Map fields = jedis.hgetAll(key); - String value4 = fields.get(field2); - Assert.assertEquals(value2, value4); - } + Map fields = jedis.hgetAll(key); + String value4 = fields.get(field2); + Assert.assertEquals(value2, value4); + } - @Test - public void givenARankingThenSaveItInRedisSortedSet() { - String key = "ranking"; + @Test + public void givenARankingThenSaveItInRedisSortedSet() { + String key = "ranking"; - Map scores = new HashMap<>(); + Map scores = new HashMap<>(); - scores.put("PlayerOne", 3000.0); - scores.put("PlayerTwo", 1500.0); - scores.put("PlayerThree", 8200.0); + scores.put("PlayerOne", 3000.0); + scores.put("PlayerTwo", 1500.0); + scores.put("PlayerThree", 8200.0); - for (String player : scores.keySet()) { - jedis.zadd(key, scores.get(player), player); - } + for (String player : scores.keySet()) { + jedis.zadd(key, scores.get(player), player); + } - Set players = jedis.zrevrange(key, 0, 1); - Assert.assertEquals("PlayerThree", players.iterator().next()); + Set players = jedis.zrevrange(key, 0, 1); + Assert.assertEquals("PlayerThree", players.iterator().next()); - long rank = jedis.zrevrank(key, "PlayerOne"); - Assert.assertEquals(1, rank); - } + long rank = jedis.zrevrank(key, "PlayerOne"); + Assert.assertEquals(1, rank); + } - @Test - public void givenMultipleOperationsThatNeedToBeExecutedAtomicallyThenWrapThemInATransaction() { - String friendsPrefix = "friends#"; + @Test + public void givenMultipleOperationsThatNeedToBeExecutedAtomicallyThenWrapThemInATransaction() { + String friendsPrefix = "friends#"; - String userOneId = "4352523"; - String userTwoId = "5552321"; + String userOneId = "4352523"; + String userTwoId = "5552321"; - Transaction t = jedis.multi(); - t.sadd(friendsPrefix + userOneId, userTwoId); - t.sadd(friendsPrefix + userTwoId, userOneId); - t.exec(); + Transaction t = jedis.multi(); + t.sadd(friendsPrefix + userOneId, userTwoId); + t.sadd(friendsPrefix + userTwoId, userOneId); + t.exec(); - boolean exists = jedis.sismember(friendsPrefix + userOneId, userTwoId); - Assert.assertTrue(exists); + boolean exists = jedis.sismember(friendsPrefix + userOneId, userTwoId); + Assert.assertTrue(exists); - exists = jedis.sismember(friendsPrefix + userTwoId, userOneId); - Assert.assertTrue(exists); - } + exists = jedis.sismember(friendsPrefix + userTwoId, userOneId); + Assert.assertTrue(exists); + } - @Test - public void givenMultipleIndependentOperationsWhenNetworkOptimizationIsImportantThenWrapThemInAPipeline() { - String userOneId = "4352523"; - String userTwoId = "4849888"; + @Test + public void givenMultipleIndependentOperationsWhenNetworkOptimizationIsImportantThenWrapThemInAPipeline() { + String userOneId = "4352523"; + String userTwoId = "4849888"; - Pipeline p = jedis.pipelined(); - p.sadd("searched#" + userOneId, "paris"); - p.zadd("ranking", 126, userOneId); - p.zadd("ranking", 325, userTwoId); - Response pipeExists = p.sismember("searched#" + userOneId, "paris"); - Response> pipeRanking = p.zrange("ranking", 0, -1); - p.sync(); + Pipeline p = jedis.pipelined(); + p.sadd("searched#" + userOneId, "paris"); + p.zadd("ranking", 126, userOneId); + p.zadd("ranking", 325, userTwoId); + Response pipeExists = p.sismember("searched#" + userOneId, "paris"); + Response> pipeRanking = p.zrange("ranking", 0, -1); + p.sync(); - Assert.assertTrue(pipeExists.get()); - Assert.assertEquals(2, pipeRanking.get().size()); - } + Assert.assertTrue(pipeExists.get()); + Assert.assertEquals(2, pipeRanking.get().size()); + } - @Test - public void givenAPoolConfigurationThenCreateAJedisPool() { - final JedisPoolConfig poolConfig = buildPoolConfig(); + @Test + public void givenAPoolConfigurationThenCreateAJedisPool() { + final JedisPoolConfig poolConfig = buildPoolConfig(); - try (JedisPool jedisPool = new JedisPool(poolConfig, "localhost"); Jedis jedis = jedisPool.getResource()) { + try (JedisPool jedisPool = new JedisPool(poolConfig, "localhost"); Jedis jedis = jedisPool.getResource()) { - // do simple operation to verify that the Jedis resource is working - // properly - String key = "key"; - String value = "value"; + // do simple operation to verify that the Jedis resource is working + // properly + String key = "key"; + String value = "value"; - jedis.set(key, value); - String value2 = jedis.get(key); + jedis.set(key, value); + String value2 = jedis.get(key); - Assert.assertEquals(value, value2); + Assert.assertEquals(value, value2); - // flush Redis - jedis.flushAll(); - } - } + // flush Redis + jedis.flushAll(); + } + } - private JedisPoolConfig buildPoolConfig() { - final JedisPoolConfig poolConfig = new JedisPoolConfig(); - poolConfig.setMaxTotal(128); - poolConfig.setMaxIdle(128); - poolConfig.setMinIdle(16); - poolConfig.setTestOnBorrow(true); - poolConfig.setTestOnReturn(true); - poolConfig.setTestWhileIdle(true); - poolConfig.setMinEvictableIdleTimeMillis(Duration.ofSeconds(60).toMillis()); - poolConfig.setTimeBetweenEvictionRunsMillis(Duration.ofSeconds(30).toMillis()); - poolConfig.setNumTestsPerEvictionRun(3); - poolConfig.setBlockWhenExhausted(true); - return poolConfig; - } + private JedisPoolConfig buildPoolConfig() { + final JedisPoolConfig poolConfig = new JedisPoolConfig(); + poolConfig.setMaxTotal(128); + poolConfig.setMaxIdle(128); + poolConfig.setMinIdle(16); + poolConfig.setTestOnBorrow(true); + poolConfig.setTestOnReturn(true); + poolConfig.setTestWhileIdle(true); + poolConfig.setMinEvictableIdleTimeMillis(Duration.ofSeconds(60).toMillis()); + poolConfig.setTimeBetweenEvictionRunsMillis(Duration.ofSeconds(30).toMillis()); + poolConfig.setNumTestsPerEvictionRun(3); + poolConfig.setBlockWhenExhausted(true); + return poolConfig; + } }