bugfix: fix XA rollback on commit failure (#6492)

Author: tanyaofei

changes/en-us/2.x.md

@@ -36,6 +36,7 @@ Add changes here for all PR submitted to the 2.x branch.
 - [[#6385](https://github.com/apache/incubator-seata/pull/6385)] fix the bug where Role.participant does not execute hooks but clears them.
 - [[#6465](https://github.com/apache/incubator-seata/pull/6465)] fix(6257): fix saga mode replay context lost start in 2.x
 - [[#6469](https://github.com/apache/incubator-seata/pull/6469)] fix Error in insert sql of [lock_table] data table to sqlserver database
+- [[#6492](https://github.com/apache/incubator-seata/pull/6492)] fix XA did not rollback but close when executing a long-running SQL(or deadlock SQL)
 
 ### optimize:
 - [[#6031](https://github.com/apache/incubator-seata/pull/6031)] add a check for the existence of the undolog table

changes/zh-cn/2.x.md

@@ -36,6 +36,7 @@
 - [[#6385](https://github.com/apache/incubator-seata/pull/6385)] 修复Role.Participant不执行hook但会清理的问题
 - [[#6465](https://github.com/apache/incubator-seata/pull/6465)] 修复2.0下saga模式的context replay丢失start问题
 - [[#6469](https://github.com/apache/incubator-seata/pull/6469)] 修复在sqlserver数据库下[lock_table]数据表的插入操作sql中存在的错误
+- [[#6492](https://github.com/apache/incubator-seata/pull/6492)] 修复XA执行长时间SQL(或死锁SQL)没有完成回滚就释放连接
 
 
 ### optimize:

rm-datasource/src/main/java/org/apache/seata/rm/datasource/xa/ConnectionProxyXA.java

@@ -206,7 +206,13 @@ public synchronized void commit() throws SQLException {
         }
         try {
             // XA End: Success
-            end(XAResource.TMSUCCESS);
+            try {
+                end(XAResource.TMSUCCESS);
+            } catch (SQLException sqle) {
+                // Rollback immediately before the XA Branch Context is deleted.
+                rollback(false);
+                throw new SQLException(sqle.getMessage(), SQLSTATE_XA_NOT_END, sqle);
+            }
             long now = System.currentTimeMillis();
             checkTimeout(now);
             setPrepareTime(now);
@@ -224,6 +230,10 @@ public synchronized void commit() throws SQLException {
 
     @Override
     public void rollback() throws SQLException {
+        rollback(true);
+    }
+
+    public void rollback(boolean end) throws SQLException {
         if (currentAutoCommitStatus) {
             // Ignore the committing on an autocommit session.
             return;
@@ -233,8 +243,10 @@ public void rollback() throws SQLException {
         }
         try {
             if (!rollBacked) {
-                // XA End: Fail
-                xaResource.end(this.xaBranchXid, XAResource.TMFAIL);
+                if (end) {
+                    // XA End: Fail
+                    xaResource.end(this.xaBranchXid, XAResource.TMFAIL);
+                }
                 xaRollback(xaBranchXid);
             }
             // Branch Report to TC