fix sql

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{
+	sql := fmt.Sprintf(`UPDATE trans_global SET update_time='%s',next_cron_time='%s' WHERE gid = '%s'`,
-		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`,
 		now,
 		now,
-		where)
+		global.Gid)
 	_, err := dtmimp.DBExec(conf.Store.Driver, dbGet().ToSQLDB(), sql)
 	return err
 }

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)