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 }