Browse Source

add xa close log

pull/330/head
yedf2 4 years ago
parent
commit
28cda03d7f
  1. 2
      client/dtmcli/dtmimp/trans_xa_base.go
  2. 8
      client/dtmcli/dtmimp/utils.go

2
client/dtmcli/dtmimp/trans_xa_base.go

@ -37,7 +37,7 @@ func XaHandleLocalTrans(xa *TransBase, dbConf DBConf, cb func(*sql.DB) error) (r
if rerr != nil {
return
}
defer func() { _ = db.Close() }()
defer XaClose(db)
defer DeferDo(&rerr, func() error {
_, err := DBExec(dbConf.Driver, db, GetDBSpecial(dbConf.Driver).GetXaSQL("prepare", xaBranch))
return err

8
client/dtmcli/dtmimp/utils.go

@ -181,10 +181,16 @@ func XaDB(conf DBConf) (*sql.DB, error) {
if conf.Driver == DBTypeMysql {
dsn += "&autocommit=0"
}
logger.Infof("opening standalone %s: %s", conf.Driver, strings.Replace(dsn, conf.Password, "****", 1))
logger.Infof("opening xa standalone %s: %s", conf.Driver, strings.Replace(dsn, conf.Password, "****", 1))
return sql.Open(conf.Driver, dsn)
}
// XaClose
func XaClose(db *sql.DB) {
logger.Infof("closing xa db")
_ = db.Close()
}
// DBExec use raw db to exec
func DBExec(dbType string, db DB, sql string, values ...interface{}) (affected int64, rerr error) {
if sql == "" {

Loading…
Cancel
Save