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

fix

Browse Source
This commit is contained in:
shoopea 2020-10-20 11:34:42 +02:00
parent 1f724c37da
commit f96b90e91c
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sql.go
View File

@ -962,9 +962,10 @@ func getSQLListID64(q string) []int64 {
func cleanupJobData() { func cleanupJobData() {
var ( var (
jobID int64 jobID int64
count int64 count int64
isDone int countDeleted 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) + `;`)
@ -1023,6 +1024,7 @@ func cleanupJobData() {
} }
del, err := delObj.RowsAffected() del, err := delObj.RowsAffected()
logOnError(err, "cleanupJobData : rows delObj") logOnError(err, "cleanupJobData : rows delObj")
countDeleted += del
if err != nil { if err != nil {
return return
} }
@ -1038,7 +1040,7 @@ func cleanupJobData() {
count += 1 count += 1
} }
log.Printf("cleanupJobData : %d jobs\n", count) log.Printf("cleanupJobData : %d jobs scanned, %d obj deleted\n", count, countDeleted)
/* /*
for _, id := range ids { for _, id := range ids {