Skip to content

Commit 275c97a

Browse files
committed
chore(spanner): lint fix
1 parent 84045ef commit 275c97a

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/ITAbstractSpannerTest.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import com.google.cloud.spanner.GceTestEnvConfig;
2323
import com.google.cloud.spanner.IntegrationTestEnv;
2424
import com.google.cloud.spanner.ResultSet;
25+
import com.google.cloud.spanner.Spanner;
2526
import com.google.cloud.spanner.SpannerExceptionFactory;
2627
import com.google.cloud.spanner.SpannerOptions;
2728
import com.google.cloud.spanner.Statement;
@@ -34,6 +35,7 @@
3435
import com.google.common.base.Preconditions;
3536
import com.google.common.base.Stopwatch;
3637
import com.google.common.base.Strings;
38+
import com.google.common.collect.ImmutableList;
3739
import com.google.rpc.RetryInfo;
3840
import io.grpc.Metadata;
3941
import io.grpc.StatusRuntimeException;
@@ -368,4 +370,11 @@ protected boolean indexExists(Connection connection, String table, String index)
368370
}
369371
return false;
370372
}
373+
374+
protected boolean isMultiplexedSessionsEnabledForRW(Spanner spanner) {
375+
if (spanner.getOptions() == null || spanner.getOptions().getSessionPoolOptions() == null) {
376+
return false;
377+
}
378+
return spanner.getOptions().getSessionPoolOptions().getUseMultiplexedSessionForRW();
379+
}
371380
}

0 commit comments

Comments
 (0)