Make sure db index is only set once.

See: #2984
This commit is contained in:
Christoph Strobl
2024-09-13 09:38:22 +02:00
parent ab701142fe
commit 31dbba0112
2 changed files with 3 additions and 9 deletions

View File

@@ -961,14 +961,7 @@ public class LettuceConnection extends AbstractRedisConnection {
@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

View File

@@ -25,6 +25,7 @@ import static org.mockito.Mockito.eq;
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 @@ class LettuceConnectionUnitTests {
connection.getNativeConnection();
verify(asyncCommandsMock).dispatch(eq(CommandType.SELECT), any(), any());
verify(commandsMock).select(1);
verifyNoInteractions(commandsMock);
}
@Test // DATAREDIS-603