chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2020-10-20 11:21:14 +02:00
parent f792d2c1d2
commit 8ce9e3b0e3
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
sql.go
View File

@ -964,6 +964,7 @@ func cleanupJobData() {
var ( var (
jobID int64 jobID int64
count int64 count int64
isDone int
) )
jobStmt, err := db.Prepare(`SELECT o.id FROM obj o WHERE o.obj_type_id = ` + strconv.FormatInt(cacheObjType[`job`], 10) + `;`) jobStmt, err := db.Prepare(`SELECT o.id FROM obj o WHERE o.obj_type_id = ` + strconv.FormatInt(cacheObjType[`job`], 10) + `;`)
@ -974,12 +975,6 @@ func cleanupJobData() {
} }
defer jobStmt.Close() defer jobStmt.Close()
jobs, err := jobStmt.Query()
logOnError(err, "cleanupJobData : query jobStmt")
if err != nil {
return
}
doneStmt, err := db.Prepare(`SELECT oj.is_done FROM obj_job oj WHERE oj.obj_id = ?;`) doneStmt, err := db.Prepare(`SELECT oj.is_done FROM obj_job oj WHERE oj.obj_id = ?;`)
logOnError(err, "cleanupJobData : prepare doneStmt") logOnError(err, "cleanupJobData : prepare doneStmt")
if err != nil { if err != nil {
@ -1004,6 +999,12 @@ func cleanupJobData() {
} }
defer delObjStmt.Close() defer delObjStmt.Close()
jobs, err := jobStmt.Query()
logOnError(err, "cleanupJobData : query jobStmt")
if err != nil {
return
}
for jobs.Next() { for jobs.Next() {
err = jobs.Scan(&jobID) err = jobs.Scan(&jobID)
logOnError(err, "cleanupJobData : scan jobStmt") logOnError(err, "cleanupJobData : scan jobStmt")
@ -1011,6 +1012,12 @@ func cleanupJobData() {
return return
} }
log.Printf("cleanupJobData : JobID : %d\n", jobID) log.Printf("cleanupJobData : JobID : %d\n", jobID)
err = doneStmt.QueryRow(jobID).Scan(&isDone)
if err != nil {
return
}
logOnError(err, "cleanupJobData : scan doneStmt")
log.Printf("cleanupJobData : isDone : %d\n", isDone)
count += 1 count += 1
} }