diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java index 830e9a014..dcde81da7 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java @@ -975,10 +975,13 @@ public class LettuceConnection extends AbstractRedisConnection { if (asyncDedicatedConn == null) { asyncDedicatedConn = doGetAsyncDedicatedConnection(); - - if (asyncDedicatedConn instanceof StatefulRedisConnection) { + + if (asyncDedicatedConn instanceof StatefulRedisConnection && dbIndex > 0) { ((StatefulRedisConnection) asyncDedicatedConn).sync().select(dbIndex); } + else if (asyncDedicatedConn instanceof StatefulRedisConnection) { + ((StatefulRedisConnection) asyncDedicatedConn).sync(); + } } if (asyncDedicatedConn instanceof StatefulRedisConnection) {