在rowsToArray中进行defer rows.Close()

pkg/scheduler/db/models/base.go

@@ -136,6 +136,8 @@ func virtualResourceRowsNotDeletedIn(r Resourcer, key string, set []string) (*sq
 }
 
 func rowsToArray(r Resourcer, rows *sql.Rows) ([]interface{}, error) {
+	defer rows.Close()
+
 	columns, _ := rows.Columns()
 
 	objs := make([]interface{}, 0, len(columns))

pkg/scheduler/db/models/metadata.go

@@ -40,6 +40,5 @@ func FetchMetadatas(resourceName string, ids, keys []string) ([]interface{}, err
 	if err != nil {
 		return nil, err
 	}
-	defer rows.Close()
 	return rowsToArray(Metadatas, rows)
 }