easypg: add missing error handling

sapcc · Mar 23, 2023 · 30f2578 · 30f2578
1 parent 64c4fa3
commit 30f2578
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/easypg/snapshot.go b/easypg/snapshot.go
@@ -86,7 +86,7 @@ func newDBSnapshot(t *testing.T, db *sql.DB) dbSnapshot {
 
 	//list column default values for all tables
 	columnDefaults := make(map[string]map[string]string)
-	rows, err = db.Query(listColumnDefaultsQuery) //nolint:sqlclosecheck
+	rows, err = db.Query(listColumnDefaultsQuery)
 	failOnErr(t, err)
 	for rows.Next() {
 		var (
@@ -114,6 +114,8 @@ func newDBSnapshot(t *testing.T, db *sql.DB) dbSnapshot {
 			columnDefaults[tableName][columnName] = computeValueOfSQLExpression(t, db, *defaultExpr).Serialized
 		}
 	}
+	failOnErr(t, rows.Err())
+	failOnErr(t, rows.Close()) //nolint:sqlclosecheck
 
 	//snapshot all tables
 	result := make(dbSnapshot, len(tableNames))