commit b254466445545eded5db5b76313eb0b35c9aaaa1
author smiletrl <smiletrl@outlook.com> Sat Mar 16 18:33:21 2024 +0800
committer GitHub <noreply@github.com> Sat Mar 16 18:33:21 2024 +0800
tree c5588a0f21a1b9908948fadc7c4d0210ce80ef4b
parent 0ca80a07e80bc4eb345f3a543ea46c0b3266084d

active xa connection rollback fix (#672)

pkg/datasource/sql/conn_xa.go

diff --git a/pkg/datasource/sql/conn_xa.go b/pkg/datasource/sql/conn_xa.go
index f557c1e..c4767bc 100644
--- a/pkg/datasource/sql/conn_xa.go
+++ b/pkg/datasource/sql/conn_xa.go
@@ -257,11 +257,11 @@
 }
 
 func (c *XAConn) end(ctx context.Context, flags int) error {
-	err := c.termination(c.xaBranchXid.String())
+	err := c.xaResource.End(ctx, c.xaBranchXid.String(), flags)
 	if err != nil {
 		return err
 	}
-	err = c.xaResource.End(ctx, c.xaBranchXid.String(), flags)
+	err = c.termination(c.xaBranchXid.String())
 	if err != nil {
 		return err
 	}