fix: update closedExplicitly flag

karenc-bq · sergiyvamz · commit b010dd640cae · 2025-10-15T14:19:55.000-07:00
diff --git a/wrapper/src/main/java/software/amazon/jdbc/plugin/failover2/FailoverConnectionPlugin.java b/wrapper/src/main/java/software/amazon/jdbc/plugin/failover2/FailoverConnectionPlugin.java
@@ -206,7 +206,8 @@ public <T, E extends Exception> T execute(
     }
 
     if (canDirectExecute(methodName)) {
-      if (JdbcMethod.CONNECTION_CLOSE.methodName.equals(methodName)) {
+      if (JdbcMethod.CONNECTION_CLOSE.methodName.equals(methodName)
+          || JdbcMethod.CONNECTION_ABORT.methodName.equals(methodName)) {
         this.closedExplicitly = true;
       }
       return jdbcMethodFunc.call();

Original file line number	Diff line number	Diff line change
`@@ -206,7 +206,8 @@ public <T, E extends Exception> T execute(`
`206`	`206`	`}`
`207`	`207`
`208`	`208`	`if (canDirectExecute(methodName)) {`
`209`		`- if (JdbcMethod.CONNECTION_CLOSE.methodName.equals(methodName)) {`
	`209`	`+ if (JdbcMethod.CONNECTION_CLOSE.methodName.equals(methodName)`
	`210`	`+ \|\| JdbcMethod.CONNECTION_ABORT.methodName.equals(methodName)) {`
`210`	`211`	`this.closedExplicitly = true;`
`211`	`212`	`}`
`212`	`213`	`return jdbcMethodFunc.call();`