diff --git a/job.go b/job.go index 24f7aa3..0acdca7 100644 --- a/job.go +++ b/job.go @@ -21,9 +21,9 @@ func jobRescan(j Job) { for i := 1; i <= (len(ids)/SQLMsgRescanJobSize)+1; i++ { var s string for _, id := range ids[((i - 1) * SQLMsgRescanJobSize):(i*SQLMsgRescanJobSize - 1)] { - s = s + fmp.Sprintf("SELECT %d id FROM DUAL UNION\n", id) + s = s + fmt.Sprintf("SELECT %d id FROM DUAL UNION\n", id) } - s = s + fmp.Sprintf("SELECT 0 id FROM DUAL WHERE 1 = 2;", id) + s = s + `SELECT 0 id FROM DUAL WHERE 1 = 2;` p := JobPayloadRescanMsg{ Query: s, MsgID64: 0,