fix: close it after using sql.Rows

This commit is contained in:
rainzm
2021-11-25 17:36:22 +08:00
parent fbe66f5ed5
commit 6b043e2392
2 changed files with 3 additions and 1 deletions

View File

@@ -336,6 +336,7 @@ func (manager *SMonitorResourceManager) GetPropertyAlert(ctx context.Context, us
if err != nil {
return nil, errors.Wrap(err, "getMonitorResourceAlert query err")
}
defer rows.Close()
total := int64(0)
resTypeDict := jsonutils.NewDict()
for rows.Next() {

View File

@@ -551,10 +551,11 @@ func dataCleaning(tableName string) error {
monthsDaysAgo,
)
q := sqlchemy.NewRawQuery(sqlStr)
_, err := q.Rows()
rows, err := q.Rows()
if err != nil {
return errors.Wrapf(err, "unable to delete expired data in %q", tableName)
}
defer rows.Close()
log.Infof("delete expired data in %q successfully", tableName)
return nil
}