From 8092b726faa50f2e0b82ce7103583abafc310dcb Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Sat, 1 Jul 2023 18:08:08 +0800
Subject: [PATCH] fix sql

---
 dtmsvr/storage/sql/sql.go | 8 ++------
 test/api_test.go          | 2 +-
 2 files changed, 3 insertions(+), 7 deletions(-)

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)