From 9eb824f07b67de4aa35c1d964c7a86a42a067472 Mon Sep 17 00:00:00 2001 From: Haris Osmanagic Date: Thu, 31 Aug 2023 13:26:58 +0200 Subject: [PATCH] linter --- columntypes/columntypes.go | 1 + source/iterator/iterator.go | 1 + 2 files changed, 2 insertions(+) diff --git a/columntypes/columntypes.go b/columntypes/columntypes.go index ca28129..2303062 100644 --- a/columntypes/columntypes.go +++ b/columntypes/columntypes.go @@ -57,6 +57,7 @@ func GetColumnTypes(ctx context.Context, db *sqlx.DB, table, schema string) (map if err != nil { return nil, fmt.Errorf("select column types %q, %v: %w", query, args, err) } + defer rows.Close() columnTypes := make(map[string]string) for rows.Next() { diff --git a/source/iterator/iterator.go b/source/iterator/iterator.go index fa4ad7c..e72ea59 100644 --- a/source/iterator/iterator.go +++ b/source/iterator/iterator.go @@ -315,6 +315,7 @@ func (iter *Iterator) latestSnapshotValue(ctx context.Context) (any, error) { if err != nil { return nil, fmt.Errorf("execute select latest snapshot value query %q: %w", query, err) } + defer rows.Close() for rows.Next() { if err = rows.Scan(&latestSnapshotValue); err != nil {