fix(region): add rows.Close func

This commit is contained in:
yangbaoqiang
2021-11-25 15:18:32 +08:00
parent 8d829db0a6
commit 704de226ed
3 changed files with 6 additions and 0 deletions
+2
View File
@@ -250,6 +250,7 @@ func (self *SNatGateway) PerformSnatResources(ctx context.Context, userCred mccl
if err != nil {
return nil, errors.Wrapf(err, "fetch resource with natgateway_id %s error", self.Id)
}
defer rows.Close()
ipset, ip := make(map[string]struct{}), ""
networks, network := make([]string, 0), ""
for rows.Next() {
@@ -298,6 +299,7 @@ func (self *SNatGateway) extractEipAddr(q *sqlchemy.SQuery) ([]string, error) {
if err != nil {
return nil, errors.Wrapf(err, "fetch resource with natgateway_id %s error", self.Id)
}
defer rows.Close()
ipset, ip := make(map[string]struct{}), ""
for rows.Next() {
err := rows.Scan(&ip)
@@ -53,6 +53,7 @@ func (man *SGuestnetworkManager) allocMappedIpAddr(ctx context.Context) (string,
if err != nil {
return "", err
}
defer rows.Close()
for rows.Next() {
if err := rows.Scan(&ip); err != nil {
return "", errors.Wrap(err, "scan guest mapped ip")
@@ -90,6 +91,7 @@ func (man *SHostManager) allocOvnMappedIpAddr(ctx context.Context) (string, erro
if err != nil {
return "", err
}
defer rows.Close()
for rows.Next() {
if err := rows.Scan(&ip); err != nil {
return "", errors.Wrap(err, "scan host mapped ip")
+2
View File
@@ -477,6 +477,7 @@ func zoneUsableVpc(usableVpc bool, query *api.ZoneListInput) (map[string]map[str
results[id] = map[string]string{"id": id, "cloudregion_id": cloudregion_id}
}
rows.Close()
}
return results, nil
@@ -542,6 +543,7 @@ func filterResult(q *sqlchemy.SQuery) ([]string, error) {
if err != nil && err != sql.ErrNoRows {
return nil, errors.Wrap(err, "filterResult.rows")
}
defer rows.Close()
results := make([]string, 0)
for rows.Next() {
var id string