Skip to content
This repository was archived by the owner on Apr 7, 2026. It is now read-only.

Commit 3e97a21

Browse files
Addressed comments
1 parent 66e7bd4 commit 3e97a21

8 files changed

Lines changed: 18 additions & 19 deletions

File tree

google-cloud-spanner/src/main/java/com/google/cloud/spanner/SpannerOptions.java

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1616,18 +1616,12 @@ public Builder disableLeaderAwareRouting() {
16161616
}
16171617

16181618
@BetaApi
1619-
public Builder enableDirectAccess() {
1620-
this.enableDirectAccess = true;
1619+
public Builder setEnableDirectAccess(boolean enableDirectAccess) {
1620+
this.enableDirectAccess = enableDirectAccess;
16211621
return this;
16221622
}
16231623

1624-
@BetaApi
1625-
public Builder disableDirectAccess() {
1626-
this.enableDirectAccess = false;
1627-
return this;
1628-
}
1629-
1630-
@ObsoleteApi("Use disableDirectAccess() instead")
1624+
@ObsoleteApi("Use setEnableDirectAccess(false) instead")
16311625
@Deprecated
16321626
public Builder disableDirectPath() {
16331627
this.enableDirectAccess = false;

google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1082,7 +1082,7 @@ boolean isExperimentalHost() {
10821082
return getInitialConnectionPropertyValue(IS_EXPERIMENTAL_HOST);
10831083
}
10841084

1085-
boolean isEnableDirectAccess() {
1085+
Boolean isEnableDirectAccess() {
10861086
return getInitialConnectionPropertyValue(ENABLE_DIRECT_ACCESS);
10871087
}
10881088

google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionProperties.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ public class ConnectionProperties {
193193
+ "Otherwise it will automatically fallback to the standard network path. "
194194
+ "NOTE: The default for this property is currently false, "
195195
+ "but this could be changed in the future.",
196-
false,
196+
null,
197197
BOOLEANS,
198198
BooleanConverter.INSTANCE,
199199
Context.STARTUP);

google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/SpannerPool.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ static class SpannerPoolKey {
164164
private final String clientCertificate;
165165
private final String clientCertificateKey;
166166
private final boolean isExperimentalHost;
167-
private final boolean enableDirectAccess;
167+
private final Boolean enableDirectAccess;
168168

169169
@VisibleForTesting
170170
static SpannerPoolKey of(ConnectionOptions options) {
@@ -416,8 +416,8 @@ Spanner createSpanner(SpannerPoolKey key, ConnectionOptions options) {
416416
if (key.isExperimentalHost) {
417417
builder.setExperimentalHost(key.host);
418418
}
419-
if (key.enableDirectAccess) {
420-
builder.enableDirectAccess();
419+
if (key.enableDirectAccess != null) {
420+
builder.setEnableDirectAccess(key.enableDirectAccess);
421421
}
422422
if (options.getConfigurator() != null) {
423423
options.getConfigurator().configure(builder);

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1317,7 +1317,12 @@ public void testEnableDirectAccess() {
13171317
ConnectionOptions.Builder builderWithoutDirectPathParam = ConnectionOptions.newBuilder();
13181318
builderWithoutDirectPathParam.setUri(
13191319
"spanner://localhost:15000/instances/default/databases/singers-db;usePlainText=true");
1320-
assertFalse(builderWithoutDirectPathParam.build().isEnableDirectAccess());
1320+
assertNull(builderWithoutDirectPathParam.build().isEnableDirectAccess());
1321+
1322+
ConnectionOptions.Builder builderWithDirectPathParamFalse = ConnectionOptions.newBuilder();
1323+
builderWithDirectPathParamFalse.setUri(
1324+
"spanner://localhost:15000/instances/default/databases/singers-db;usePlainText=true;enableDirectAccess=false");
1325+
assertFalse(builderWithDirectPathParamFalse.build().isEnableDirectAccess());
13211326

13221327
ConnectionOptions.Builder builderWithDirectPathParam = ConnectionOptions.newBuilder();
13231328
builderWithDirectPathParam.setUri(

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public void testCredentialsProvider() throws Throwable {
9393
.setConfigurator(
9494
spannerOptions -> {
9595
spannerOptions.setChannelConfigurator(ManagedChannelBuilder::usePlaintext);
96-
spannerOptions.disableDirectAccess();
96+
spannerOptions.setEnableDirectAccess(false);
9797
})
9898
.build();
9999

@@ -135,7 +135,7 @@ public void testCredentialsProvider() throws Throwable {
135135
.setConfigurator(
136136
spannerOptions -> {
137137
spannerOptions.setChannelConfigurator(ManagedChannelBuilder::usePlaintext);
138-
spannerOptions.disableDirectAccess();
138+
spannerOptions.setEnableDirectAccess(false);
139139
})
140140
.build();
141141
try (Connection connection = options.getConnection()) {

google-cloud-spanner/src/test/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpcTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -879,7 +879,7 @@ private SpannerOptions createSpannerOptions() {
879879
.setProjectId("[PROJECT]")
880880
// Set a custom channel configurator to allow http instead of https.
881881
.setChannelConfigurator(ManagedChannelBuilder::usePlaintext)
882-
.disableDirectAccess()
882+
.setEnableDirectAccess(false)
883883
.setHost("http://" + endpoint)
884884
// Set static credentials that will return the static OAuth test token.
885885
.setCredentials(STATIC_CREDENTIALS)

google-cloud-spanner/src/test/java/com/google/cloud/spanner/spi/v1/GfeLatencyTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,7 +290,7 @@ private static SpannerOptions createSpannerOptions(InetSocketAddress address, Se
290290
.setProjectId("[PROJECT]")
291291
// Set a custom channel configurator to allow http instead of https.
292292
.setChannelConfigurator(ManagedChannelBuilder::usePlaintext)
293-
.disableDirectAccess()
293+
.setEnableDirectAccess(false)
294294
.setHost("http://" + endpoint)
295295
// Set static credentials that will return the static OAuth test token.
296296
.setCredentials(STATIC_CREDENTIALS)

0 commit comments

Comments
 (0)