active xa connection rollback fix (#672)

apache · Mar 16, 2024 · b254466 · b254466
1 parent 0ca80a0
commit b254466
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/datasource/sql/conn_xa.go b/pkg/datasource/sql/conn_xa.go
@@ -257,11 +257,11 @@ func (c *XAConn) start(ctx context.Context) error {
 }
 
 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
 	}