From c7514277e598496eeefc91cf8a07e301cd2f0f20 Mon Sep 17 00:00:00 2001 From: yedf2 <120050102@qq.com> Date: Thu, 14 Jul 2022 21:50:25 +0800 Subject: [PATCH] rename ResetXaData() --- test/busi/data.go | 2 +- test/busi/utils.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/test/busi/data.go b/test/busi/data.go index 4927532..e5f8726 100644 --- a/test/busi/data.go +++ b/test/busi/data.go @@ -19,7 +19,7 @@ import ( // PopulateDB populate example mysql data func PopulateDB(skipDrop bool) { - resetXaData() + ResetXaData() file := fmt.Sprintf("%s/busi.%s.sql", dtmutil.GetSQLDir(), BusiConf.Driver) dtmutil.RunSQLScript(BusiConf, file, skipDrop) file = fmt.Sprintf("%s/dtmcli.barrier.%s.sql", dtmutil.GetSQLDir(), BusiConf.Driver) diff --git a/test/busi/utils.go b/test/busi/utils.go index e30b463..c7afe3c 100644 --- a/test/busi/utils.go +++ b/test/busi/utils.go @@ -42,7 +42,8 @@ func txGet() *sql.Tx { return tx } -func resetXaData() { +// ResetXaData will rollback all pending xa transaction +func ResetXaData() { if BusiConf.Driver != "mysql" { return }