diff --git a/sql.go b/sql.go index 8aef2a3..70e6c90 100644 --- a/sql.go +++ b/sql.go @@ -1325,8 +1325,15 @@ func insertMsgAuctionAnnounce(m *ChatWarsMessageAuctionAnnounce) error { } func createJob(job_type_id int32, priority int32, schedule time.Time, payload []byte) error { - res, err := db.Exec(`INSERT INTO obj (obj_type_id, obj_sub_type_id) - VALUES (` + strconv.Itoa(int(objTypeJob)) + `,` + strconv.Itoa(job_type_id) + `);`) + stmt, err := db.Prepare(`INSERT INTO obj (obj_type_id, obj_sub_type_id) + VALUES (? , ?);`) + logOnError(err, "createJob : prepare insert obj") + if err != nil { + return err + } + defer stmt.Close() + + res, err = stmt.Exec(objTypeJob, job_type_id) logOnError(err, "createJob : insert obj") if err != nil { return err