From 73a8c14d5ae480509697bffe08617a55a749023d Mon Sep 17 00:00:00 2001 From: Rulin Tang Date: Sun, 3 Mar 2024 16:25:48 +0800 Subject: [PATCH] active xa connection rollback fix --- pkg/datasource/sql/conn_xa.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/datasource/sql/conn_xa.go b/pkg/datasource/sql/conn_xa.go index f557c1e24..c4767bcbe 100644 --- 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 }