Browse Source

translate trans_xa_base.go

pull/128/head
parkma99 4 years ago
parent
commit
8a898f697e
  1. 4
      dtmcli/dtmimp/trans_xa_base.go

4
dtmcli/dtmimp/trans_xa_base.go

@ -18,7 +18,7 @@ type XaClientBase struct {
NotifyURL string
}
// HandleCallback 处理commit/rollback的回调
// HandleCallback type of commit/rollback callback handler
func (xc *XaClientBase) HandleCallback(gid string, branchID string, action string) error {
db, err := StandaloneDB(xc.Conf)
if err != nil {
@ -28,7 +28,7 @@ func (xc *XaClientBase) HandleCallback(gid string, branchID string, action strin
xaID := gid + "-" + branchID
_, err = DBExec(db, GetDBSpecial().GetXaSQL(action, xaID))
if err != nil &&
(strings.Contains(err.Error(), "XAER_NOTA") || strings.Contains(err.Error(), "does not exist")) { // 重复commit/rollback同一个id,报这个错误,忽略
(strings.Contains(err.Error(), "XAER_NOTA") || strings.Contains(err.Error(), "does not exist")) { // Repeat commit/rollback with the same id, report this error, ignore
err = nil
}
return err

Loading…
Cancel
Save