From f9cca239ef449c19e6faa5c71c07429dce2fc487 Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Tue, 22 Mar 2022 09:09:55 +0800
Subject: [PATCH] xa callback use pooled db

---
 dtmcli/dtmimp/trans_xa_base.go | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/dtmcli/dtmimp/trans_xa_base.go b/dtmcli/dtmimp/trans_xa_base.go
index f934a15..6d633c7 100644
--- a/dtmcli/dtmimp/trans_xa_base.go
+++ b/dtmcli/dtmimp/trans_xa_base.go
@@ -20,13 +20,10 @@ type XaClientBase struct {
 
 // HandleCallback Handle the callback of commit/rollback
 func (xc *XaClientBase) HandleCallback(gid string, branchID string, action string) error {
-	db, err := StandaloneDB(xc.Conf)
+	db, err := PooledDB(xc.Conf)
 	if err != nil {
 		return err
 	}
-	defer func() {
-		_ = db.Close()
-	}()
 	xaID := gid + "-" + branchID
 	_, err = DBExec(db, GetDBSpecial().GetXaSQL(action, xaID))
 	if err != nil &&