Make sure db index is only set once.

See: #2984
spring-projects · Sep 13, 2024 · f2a1af6 · f2a1af6
1 parent feda7dc
commit f2a1af6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
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
@@ -961,14 +961,7 @@ protected RedisClusterAsyncCommands<byte[], byte[]> getAsyncDedicatedConnection(
 
 	@SuppressWarnings("unchecked")
 	protected StatefulConnection<byte[], byte[]> doGetAsyncDedicatedConnection() {
-
-		StatefulConnection<byte[], byte[]> connection = getConnectionProvider().getConnection(StatefulConnection.class);
-
-		if (customizedDatabaseIndex()) {
-			potentiallySelectDatabase(connection, this.dbIndex);
-		}
-
-		return connection;
+		return getConnectionProvider().getConnection(StatefulConnection.class);
 	}
 
 	@Override

diff --git a/...st/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionUnitTests.java b/...st/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionUnitTests.java
@@ -25,6 +25,7 @@
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.verifyNoInteractions;
 import static org.mockito.Mockito.when;
 
 import io.lettuce.core.KeyScanCursor;
@@ -188,7 +189,7 @@ void dbIndexShouldBeSetWhenObtainingConnection() {
 			connection.getNativeConnection();
 
 			verify(asyncCommandsMock).dispatch(eq(CommandType.SELECT), any(), any());
-			verify(commandsMock).select(1);
+			verifyNoInteractions(commandsMock);
 		}
 
 		@Test // DATAREDIS-603