From bda78edaba827acf974c87c335868a6f8caa38f2 Mon Sep 17 00:00:00 2001
From: Sri Harsha CH <57220027+harshachinta@users.noreply.github.com>
Date: Thu, 20 Feb 2025 15:57:03 +0530
Subject: [PATCH] feat(spanner): support multiplexed session for read-write
 transactions (#3608)

* chore(spanner): update project

* chore(spanner): test update error code and add statements to emptybody

* chore(spanner): test update error code

* chore(spanner): add select 1 for schema refresh time in tests

* chore(spanner): add sleep for cache refresh

* chore(spanner): update error code

* chore(spanner): run it on cloud-devel

* chore(spanner): mutation only aborted case

* chore(spanner): fix conection it tests

* chore(spanner): lint fix

* chore(spanner): enable env

* chore(spanner): skip failing unit tests

* chore(spanner): throw aborted

* chore(spanner): cache miss fix

* chore(spanner): remove temp fixes

* chore(spanner): remove temp fixes

* chore(spanner): comment out exception

* chore(spanner): revert begintxn aborted case to verify tests

* chore(spanner): add env for partitioned ops for integration tests

* chore(spanner): run .write only if there are any mutations to commit

* chore(spanner): skip pops unit tests

* chore(spanner): comment failing unit tests for pops

* chore(spanner): return in interceptor if txn is not created

* chore(spanner): don't throw error if precommit token is empty

* chore(spanner): INVALID_ARGUMENT error code to NOT_FOUND

* chore(spanner): remove mutations only code

* chore(spanner): test fix

* chore(spanner): test fix

* chore(spanner): fix tests

* chore(spanner): lint fix

* chore(spanner): lint fix

* chore(spanner): test fix

* chore(spanner): throw error for resetforretryasync

* chore(spanner): skip test temp

* chore(spanner): tracing test skip

* chore(spanner): tests fix

* chore(spanner): test fix for AsyncRunnerTest

* chore(spanner): remove test skip

* chore(spanner): fix resource cleanup

* chore(spanner): revert cloud-devel to prod

* chore(spanner): lint fix
---
 .../main/java/com/google/cloud/spanner/SessionPoolOptions.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SessionPoolOptions.java b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SessionPoolOptions.java
index 03551640b4..7ce6b7bc61 100644
--- a/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SessionPoolOptions.java
+++ b/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SessionPoolOptions.java
@@ -390,7 +390,7 @@ private static Boolean parseBooleanEnvVariable(String variableName) {
   private static Boolean getUseMultiplexedSessionForRWFromEnvVariable() {
     // Checks the value of env, GOOGLE_CLOUD_SPANNER_MULTIPLEXED_SESSIONS_FOR_RW
     // This returns null until RW is supported.
-    return null;
+    return parseBooleanEnvVariable("GOOGLE_CLOUD_SPANNER_MULTIPLEXED_SESSIONS_FOR_RW");
   }
 
   Duration getMultiplexedSessionMaintenanceDuration() {