diff --git a/src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionUnitTestSuite.java b/src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionUnitTestSuite.java index ad0c20d3c..57e041767 100644 --- a/src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionUnitTestSuite.java +++ b/src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionUnitTestSuite.java @@ -258,6 +258,25 @@ public class JedisConnectionUnitTestSuite { verify(jedisSpy, times(1)).quit(); } + @Test // DATAREDIS-714, DATAREDIS-790 + public void doesNotSelectDbWhenCurrentDbMatchesDesiredOne() { + + Jedis jedisSpy = spy(new MockedClientJedis("http://localhost:1234", getNativeRedisConnectionMock())); + new JedisConnection(jedisSpy); + + verify(jedisSpy, never()).select(anyInt()); + } + + @Test // DATAREDIS-714, DATAREDIS-790 + public void doesNotSelectDbWhenCurrentDbDoesNotMatchDesiredOne() { + + Jedis jedisSpy = spy(new MockedClientJedis("http://localhost:1234", getNativeRedisConnectionMock())); + when(jedisSpy.getDB()).thenReturn(3L); + + new JedisConnection(jedisSpy); + + verify(jedisSpy).select(eq(0)); + } } public static class JedisConnectionPipelineUnitTests extends JedisConnectionUnitTests {