[incubator-devlake] branch release-v0.15 updated: fix: close pg conn (#4272)

[abeizn]

This is an automated email from the ASF dual-hosted git repository.

abeizn pushed a commit to branch release-v0.15
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git


The following commit(s) were added to refs/heads/release-v0.15 by this push:
     new b5bb53bc2 fix: close pg conn (#4272)
b5bb53bc2 is described below

commit b5bb53bc27ce361b9ea041b98c620a4871452847
Author: long2ice <jinlong.p...@merico.dev>
AuthorDate: Mon Jan 30 16:19:03 2023 +0800

    fix: close pg conn (#4272)
---
 plugins/starrocks/tasks/tasks.go | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/plugins/starrocks/tasks/tasks.go b/plugins/starrocks/tasks/tasks.go
index 0d00e464e..4995e7ddf 100644
--- a/plugins/starrocks/tasks/tasks.go
+++ b/plugins/starrocks/tasks/tasks.go
@@ -186,16 +186,20 @@ func createTmpTable(starrocks *sql.DB, db dal.Dal, 
starrocksTable string, starro
        firstcm := ""
        firstcmName := ""
        var rowsInStarRocks *sql.Rows
+       var rowsInPostgres dal.Rows
        defer func() {
                if rowsInStarRocks != nil {
                        rowsInStarRocks.Close()
                }
+               if rowsInPostgres != nil {
+                       rowsInPostgres.Close()
+               }
        }()
        for _, cm := range columnMetas {
                name := cm.Name()
                if name == updateColumn {
                        // check update column to detect skip or not
-                       rows, err := db.Cursor(
+                       rowsInPostgres, err = db.Cursor(
                                dal.From(table),
                                dal.Select(updateColumn),
                                dal.Limit(1),
@@ -205,8 +209,8 @@ func createTmpTable(starrocks *sql.DB, db dal.Dal, 
starrocksTable string, starro
                                return nil, "", false, err
                        }
                        var updatedFrom time.Time
-                       if rows.Next() {
-                               err = errors.Convert(rows.Scan(&updatedFrom))
+                       if rowsInPostgres.Next() {
+                               err = 
errors.Convert(rowsInPostgres.Scan(&updatedFrom))
                                if err != nil {
                                        return nil, "", false, err
                                }