diff --git a/pkg/compute/models/natgateways.go b/pkg/compute/models/natgateways.go
index 1e1d0cf2ca..0051e3ebb6 100644
--- a/pkg/compute/models/natgateways.go
+++ b/pkg/compute/models/natgateways.go
@@ -249,6 +249,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() {
@@ -297,6 +298,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)
diff --git a/pkg/compute/models/vpcs_mapped_address.go b/pkg/compute/models/vpcs_mapped_address.go
index 5ba1121a97..73ed46676d 100644
--- a/pkg/compute/models/vpcs_mapped_address.go
+++ b/pkg/compute/models/vpcs_mapped_address.go
@@ -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")
diff --git a/pkg/compute/models/zones.go b/pkg/compute/models/zones.go
index 68e8ab077a..7b9cec5a1c 100644
--- a/pkg/compute/models/zones.go
+++ b/pkg/compute/models/zones.go
@@ -476,6 +476,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
@@ -541,6 +542,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