chore: generate libraries at Wed Mar 19 11:09:39 UTC 2025

cloud-java-bot · cloud-java-bot · commit e2da861abb87 · 2025-03-19T11:11:56.000Z
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ClientSideStatementValueConverters.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ClientSideStatementValueConverters.java
@@ -382,8 +382,11 @@ public DirectedReadOptions convert(String value) {
       return null;
     }
   }
-  
-  /** Converter for converting strings to {@link com.google.spanner.v1.TransactionOptions.IsolationLevel} values. */
+
+  /**
+   * Converter for converting strings to {@link
+   * com.google.spanner.v1.TransactionOptions.IsolationLevel} values.
+   */
   static class IsolationLevelConverter
       implements ClientSideStatementValueConverter<TransactionOptions.IsolationLevel> {
     static final IsolationLevelConverter INSTANCE = new IsolationLevelConverter();
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/Connection.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/Connection.java
@@ -219,7 +219,7 @@ public interface Connection extends AutoCloseable {
 
   /** @return <code>true</code> if this connection is in read-only mode */
   boolean isReadOnly();
-  
+
   /** Sets the default isolation level for read/write transactions for this connection. */
   void setDefaultIsolationLevel(IsolationLevel isolationLevel);
 
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionImpl.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionImpl.java
@@ -641,9 +641,11 @@ public boolean isReadOnly() {
   @Override
   public void setDefaultIsolationLevel(IsolationLevel isolationLevel) {
     ConnectionPreconditions.checkState(!isClosed(), CLOSED_ERROR_MSG);
-    ConnectionPreconditions.checkState(!isBatchActive(), "Cannot default isolation level while in a batch");
     ConnectionPreconditions.checkState(
-        !isTransactionStarted(), "Cannot set default isolation level while a transaction is active");
+        !isBatchActive(), "Cannot default isolation level while in a batch");
+    ConnectionPreconditions.checkState(
+        !isTransactionStarted(),
+        "Cannot set default isolation level while a transaction is active");
     setConnectionPropertyValue(DEFAULT_ISOLATION_LEVEL, isolationLevel);
     clearLastTransactionAndSetDefaultTransactionOptions();
   }
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionProperties.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionProperties.java
@@ -407,11 +407,15 @@ public class ConnectionProperties {
   static final ConnectionProperty<IsolationLevel> DEFAULT_ISOLATION_LEVEL =
       create(
           "default_isolation_level",
-          "The transaction isolation level that is used by default for read/write transactions. " 
-              + "The default is isolation_level_unspecified, which means that the connection will use the " 
+          "The transaction isolation level that is used by default for read/write transactions. "
+              + "The default is isolation_level_unspecified, which means that the connection will use the "
               + "default isolation level of the database that it is connected to.",
           IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED,
-          new IsolationLevel[]{IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED, IsolationLevel.SERIALIZABLE, IsolationLevel.REPEATABLE_READ},
+          new IsolationLevel[] {
+            IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED,
+            IsolationLevel.SERIALIZABLE,
+            IsolationLevel.REPEATABLE_READ
+          },
           IsolationLevelConverter.INSTANCE,
           Context.USER);
   static final ConnectionProperty<AutocommitDmlMode> AUTOCOMMIT_DML_MODE =
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionState.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ConnectionState.java
@@ -251,16 +251,17 @@ private <T> void internalSetValue(
     newValue.setValue(value, context);
     currentProperties.put(property.getKey(), newValue);
   }
-  
+
   static <T> void checkValidValue(ConnectionProperty<T> property, T value) {
     if (property.getValidValues() == null || property.getValidValues().length == 0) {
       return;
     }
-    if (Arrays.stream(property.getValidValues()).noneMatch(validValue -> Objects.equals(validValue, value))) {
+    if (Arrays.stream(property.getValidValues())
+        .noneMatch(validValue -> Objects.equals(validValue, value))) {
       throw invalidParamValueError(property, value);
     }
   }
-  
+
   /** Creates an exception for an invalid value for a connection property. */
   static <T> SpannerException invalidParamValueError(ConnectionProperty<T> property, T value) {
     return SpannerExceptionFactory.newSpannerException(
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ReadWriteTransaction.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/ReadWriteTransaction.java
@@ -253,7 +253,7 @@ Builder setSavepointSupport(SavepointSupport savepointSupport) {
       this.savepointSupport = savepointSupport;
       return this;
     }
-    
+
     Builder setIsolationLevel(IsolationLevel isolationLevel) {
       this.isolationLevel = Preconditions.checkNotNull(isolationLevel);
       return this;
diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/SingleUseTransaction.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/SingleUseTransaction.java
@@ -510,7 +510,8 @@ private TransactionRunner createWriteTransaction() {
     if (connectionState.getValue(MAX_COMMIT_DELAY).getValue() != null) {
       numOptions++;
     }
-    if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue() != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {
+    if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue()
+        != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {
       numOptions++;
     }
     if (numOptions == 0) {
@@ -531,8 +532,10 @@ private TransactionRunner createWriteTransaction() {
       options[index++] =
           Options.maxCommitDelay(connectionState.getValue(MAX_COMMIT_DELAY).getValue());
     }
-    if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue() != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {
-      options[index++] = Options.isolationLevel(connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue());
+    if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue()
+        != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {
+      options[index++] =
+          Options.isolationLevel(connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue());
     }
     return dbClient.readWriteTransaction(options);
   }
diff --git a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/AutoCommitMockServerTest.java b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/AutoCommitMockServerTest.java
@@ -31,16 +31,14 @@
 import java.util.Collections;
 import org.junit.Test;
 import org.junit.runner.RunWith;
-import org.junit.runners.JUnit4;
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameter;
 import org.junit.runners.Parameterized.Parameters;
 
 @RunWith(Parameterized.class)
 public class AutoCommitMockServerTest extends AbstractMockServerTest {
 
-  @Parameter
-  public IsolationLevel isolationLevel;
+  @Parameter public IsolationLevel isolationLevel;
 
   @Parameters(name = "isolationLevel = {0}")
   public static Object[] data() {
@@ -49,7 +47,10 @@ public static Object[] data() {
 
   @Override
   protected ITConnection createConnection() {
-    return createConnection(Collections.emptyList(), Collections.emptyList(), String.format(";default_isolation_level=%s", isolationLevel));
+    return createConnection(
+        Collections.emptyList(),
+        Collections.emptyList(),
+        String.format(";default_isolation_level=%s", isolationLevel));
   }
 
   @Test
@@ -63,7 +64,9 @@ public void testQuery() {
     ExecuteSqlRequest request = mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0);
     assertTrue(request.getTransaction().hasSingleUse());
     assertTrue(request.getTransaction().getSingleUse().hasReadOnly());
-    assertEquals(IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED, request.getTransaction().getSingleUse().getIsolationLevel());
+    assertEquals(
+        IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED,
+        request.getTransaction().getSingleUse().getIsolationLevel());
     assertFalse(request.getLastStatement());
   }
 
@@ -128,7 +131,8 @@ public void testPartitionedDml() {
     BeginTransactionRequest beginRequest =
         mockSpanner.getRequestsOfType(BeginTransactionRequest.class).get(0);
     assertTrue(beginRequest.getOptions().hasPartitionedDml());
-    assertEquals(IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED, beginRequest.getOptions().getIsolationLevel());
+    assertEquals(
+        IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED, beginRequest.getOptions().getIsolationLevel());
     assertEquals(1, mockSpanner.countRequestsOfType(ExecuteSqlRequest.class));
     ExecuteSqlRequest request = mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0);
     assertTrue(request.getTransaction().hasId());
diff --git a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/RunTransactionMockServerTest.java b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/RunTransactionMockServerTest.java
@@ -54,9 +54,10 @@ public void testRunTransaction() {
       }
       assertEquals(2, mockSpanner.countRequestsOfType(ExecuteSqlRequest.class));
       assertEquals(1, mockSpanner.countRequestsOfType(CommitRequest.class));
-      TransactionOptions transactionOptions = mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();
+      TransactionOptions transactionOptions =
+          mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();
       assertEquals(isolationLevel, transactionOptions.getIsolationLevel());
-      
+
       mockSpanner.clearRequests();
     }
   }
@@ -77,7 +78,8 @@ public void testRunTransactionInAutoCommit() {
       }
       assertEquals(2, mockSpanner.countRequestsOfType(ExecuteSqlRequest.class));
       assertEquals(1, mockSpanner.countRequestsOfType(CommitRequest.class));
-      TransactionOptions transactionOptions = mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();
+      TransactionOptions transactionOptions =
+          mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();
       assertEquals(isolationLevel, transactionOptions.getIsolationLevel());
 
       mockSpanner.clearRequests();
diff --git a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/TransactionMockServerTest.java b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/connection/TransactionMockServerTest.java
@@ -21,37 +21,35 @@
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 
-import com.google.cloud.spanner.Dialect;
 import com.google.cloud.spanner.ResultSet;
 import com.google.cloud.spanner.connection.ITAbstractSpannerTest.ITConnection;
-import com.google.spanner.v1.BeginTransactionRequest;
 import com.google.spanner.v1.CommitRequest;
 import com.google.spanner.v1.ExecuteBatchDmlRequest;
 import com.google.spanner.v1.ExecuteSqlRequest;
 import com.google.spanner.v1.TransactionOptions.IsolationLevel;
 import java.util.Collections;
 import org.junit.Test;
 import org.junit.runner.RunWith;
-import org.junit.runners.JUnit4;
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameter;
 import org.junit.runners.Parameterized.Parameters;
-import org.openjdk.jmh.annotations.Param;
 
 @RunWith(Parameterized.class)
 public class TransactionMockServerTest extends AbstractMockServerTest {
 
-  @Parameter
-  public IsolationLevel isolationLevel;
+  @Parameter public IsolationLevel isolationLevel;
 
   @Parameters(name = "isolationLevel = {0}")
   public static Object[] data() {
     return DEFAULT_ISOLATION_LEVEL.getValidValues();
   }
-  
+
   @Override
   protected ITConnection createConnection() {
-    return createConnection(Collections.emptyList(), Collections.emptyList(), String.format(";default_isolation_level=%s", isolationLevel));
+    return createConnection(
+        Collections.emptyList(),
+        Collections.emptyList(),
+        String.format(";default_isolation_level=%s", isolationLevel));
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -382,8 +382,11 @@ public DirectedReadOptions convert(String value) {`
`382`	`382`	`return null;`
`383`	`383`	`}`
`384`	`384`	`}`
`385`		`-`
`386`		`- /** Converter for converting strings to {@link com.google.spanner.v1.TransactionOptions.IsolationLevel} values. */`
	`385`	`+`
	`386`	`+ /**`
	`387`	`+ * Converter for converting strings to {@link`
	`388`	`+ * com.google.spanner.v1.TransactionOptions.IsolationLevel} values.`
	`389`	`+ */`
`387`	`390`	`static class IsolationLevelConverter`
`388`	`391`	`implements ClientSideStatementValueConverter<TransactionOptions.IsolationLevel> {`
`389`	`392`	`static final IsolationLevelConverter INSTANCE = new IsolationLevelConverter();`
Original file line number	Diff line number	Diff line change
`@@ -251,16 +251,17 @@ private <T> void internalSetValue(`
`251`	`251`	`newValue.setValue(value, context);`
`252`	`252`	`currentProperties.put(property.getKey(), newValue);`
`253`	`253`	`}`
`254`		`-`
	`254`	`+`
`255`	`255`	`static <T> void checkValidValue(ConnectionProperty<T> property, T value) {`
`256`	`256`	`if (property.getValidValues() == null \|\| property.getValidValues().length == 0) {`
`257`	`257`	`return;`
`258`	`258`	`}`
`259`		`- if (Arrays.stream(property.getValidValues()).noneMatch(validValue -> Objects.equals(validValue, value))) {`
	`259`	`+ if (Arrays.stream(property.getValidValues())`
	`260`	`+ .noneMatch(validValue -> Objects.equals(validValue, value))) {`
`260`	`261`	`throw invalidParamValueError(property, value);`
`261`	`262`	`}`
`262`	`263`	`}`
`263`		`-`
	`264`	`+`
`264`	`265`	`/** Creates an exception for an invalid value for a connection property. */`
`265`	`266`	`static <T> SpannerException invalidParamValueError(ConnectionProperty<T> property, T value) {`
`266`	`267`	`return SpannerExceptionFactory.newSpannerException(`
Original file line number	Diff line number	Diff line change
`@@ -253,7 +253,7 @@ Builder setSavepointSupport(SavepointSupport savepointSupport) {`
`253`	`253`	`this.savepointSupport = savepointSupport;`
`254`	`254`	`return this;`
`255`	`255`	`}`
`256`		`-`
	`256`	`+`
`257`	`257`	`Builder setIsolationLevel(IsolationLevel isolationLevel) {`
`258`	`258`	`this.isolationLevel = Preconditions.checkNotNull(isolationLevel);`
`259`	`259`	`return this;`
Original file line number	Diff line number	Diff line change
`@@ -510,7 +510,8 @@ private TransactionRunner createWriteTransaction() {`
`510`	`510`	`if (connectionState.getValue(MAX_COMMIT_DELAY).getValue() != null) {`
`511`	`511`	`numOptions++;`
`512`	`512`	`}`
`513`		`- if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue() != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {`
	`513`	`+ if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue()`
	`514`	`+ != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {`
`514`	`515`	`numOptions++;`
`515`	`516`	`}`
`516`	`517`	`if (numOptions == 0) {`
`@@ -531,8 +532,10 @@ private TransactionRunner createWriteTransaction() {`
`531`	`532`	`options[index++] =`
`532`	`533`	`Options.maxCommitDelay(connectionState.getValue(MAX_COMMIT_DELAY).getValue());`
`533`	`534`	`}`
`534`		`- if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue() != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {`
`535`		`- options[index++] = Options.isolationLevel(connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue());`
	`535`	`+ if (connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue()`
	`536`	`+ != IsolationLevel.ISOLATION_LEVEL_UNSPECIFIED) {`
	`537`	`+ options[index++] =`
	`538`	`+ Options.isolationLevel(connectionState.getValue(DEFAULT_ISOLATION_LEVEL).getValue());`
`536`	`539`	`}`
`537`	`540`	`return dbClient.readWriteTransaction(options);`
`538`	`541`	`}`
Original file line number	Diff line number	Diff line change
`@@ -54,9 +54,10 @@ public void testRunTransaction() {`
`54`	`54`	`}`
`55`	`55`	`assertEquals(2, mockSpanner.countRequestsOfType(ExecuteSqlRequest.class));`
`56`	`56`	`assertEquals(1, mockSpanner.countRequestsOfType(CommitRequest.class));`
`57`		`- TransactionOptions transactionOptions = mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();`
	`57`	`+ TransactionOptions transactionOptions =`
	`58`	`+ mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();`
`58`	`59`	`assertEquals(isolationLevel, transactionOptions.getIsolationLevel());`
`59`		`-`
	`60`	`+`
`60`	`61`	`mockSpanner.clearRequests();`
`61`	`62`	`}`
`62`	`63`	`}`
`@@ -77,7 +78,8 @@ public void testRunTransactionInAutoCommit() {`
`77`	`78`	`}`
`78`	`79`	`assertEquals(2, mockSpanner.countRequestsOfType(ExecuteSqlRequest.class));`
`79`	`80`	`assertEquals(1, mockSpanner.countRequestsOfType(CommitRequest.class));`
`80`		`- TransactionOptions transactionOptions = mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();`
	`81`	`+ TransactionOptions transactionOptions =`
	`82`	`+ mockSpanner.getRequestsOfType(ExecuteSqlRequest.class).get(0).getTransaction().getBegin();`
`81`	`83`	`assertEquals(isolationLevel, transactionOptions.getIsolationLevel());`
`82`	`84`
`83`	`85`	`mockSpanner.clearRequests();`