From cd721708a8a030de1dad9a0830c81e008f980dc5 Mon Sep 17 00:00:00 2001 From: shoopea Date: Sat, 25 May 2019 20:00:47 +0800 Subject: [PATCH] test --- sql.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sql.go b/sql.go index 020d75b..5caa0b5 100644 --- a/sql.go +++ b/sql.go @@ -1638,10 +1638,11 @@ func loadCurrentJobs() ([]Job, error) { } defer tx.Rollback() - stmt, err := tx.Prepare("SELECT o.id, o.obj_sub_type_id, j.status, j.payload FROM obj_job j, obj o WHERE j.obj_id = o.id AND j.is_done = 0 and j.in_work = 0 AND j.schedule <= ? ORDER BY j.priority ASC, j.obj_id ASC LIMIT ? FOR UPDATE;") + stmt, err := tx.Prepare("SELECT o.id, o.obj_sub_type_id, j.status, j.payload FROM obj_job j, obj o WHERE j.obj_id = o.id AND j.is_done = 0 and j.in_work = 0 AND j.schedule <= ? ORDER BY j.priority ASC, j.obj_id ASC LIMIT 1 FOR UPDATE;") logOnError(err, "loadCurrentJobs : prepare select statement") - rows, err := stmt.Query(time.Now(), SQLJobSliceSize) + //rows, err := stmt.Query(time.Now(), SQLJobSliceSize) + rows, err := stmt.Query(time.Now()) logOnError(err, "loadCurrentJobs : query select statement") for rows.Next() {