diff --git a/dtmsvr/storage/sql/sql.go b/dtmsvr/storage/sql/sql.go index 3f94896..cf8583c 100644 --- a/dtmsvr/storage/sql/sql.go +++ b/dtmsvr/storage/sql/sql.go @@ -208,14 +208,10 @@ func (s *Store) ResetCronTime(after time.Duration, limit int64) (succeedCount in // ResetTransGlobalCronTime reset nextCronTime of one global trans. func (s *Store) ResetTransGlobalCronTime(global *storage.TransGlobalStore) error { now := getTimeStr(0) - where := map[string]string{ - dtmimp.DBTypeMysql: fmt.Sprintf(`gid = '%s'`, global.Gid), - }[conf.Store.Driver] - - sql := fmt.Sprintf(`UPDATE trans_global SET update_time='%s',next_cron_time='%s' WHERE %s`, + sql := fmt.Sprintf(`UPDATE trans_global SET update_time='%s',next_cron_time='%s' WHERE gid = '%s'`, now, now, - where) + global.Gid) _, err := dtmimp.DBExec(conf.Store.Driver, dbGet().ToSQLDB(), sql) return err } diff --git a/test/api_test.go b/test/api_test.go index 7753236..e5bb3db 100644 --- a/test/api_test.go +++ b/test/api_test.go @@ -266,7 +266,7 @@ func TestAPIResetNextCronTime(t *testing.T) { "gid": saga.Gid, }).Post(dtmutil.DefaultHTTPServer + "/resetNextCronTime") assert.Nil(t, err) - assert.Equal(t, resp.StatusCode(), http.StatusOK) + assert.Equal(t, http.StatusOK, resp.StatusCode()) // after reset assert g2 := s.FindTransGlobalStore(gid)