diff --git a/sql.go b/sql.go index 69e9c62..9df352f 100644 --- a/sql.go +++ b/sql.go @@ -1021,7 +1021,12 @@ func cleanupJobData() { if err != nil { return } - log.Printf("cleanupJobData : delObj : %d\n", delObj.RowsAffected()) + del, err := delObj.RowsAffected() + logOnError(err, "cleanupJobData : rows delObj") + if err != nil { + return + } + log.Printf("cleanupJobData : delObj : %d\n", del) } else { logOnError(err, "cleanupJobData : scan doneStmt") return