hotfix: prevent pool_db connections accumulating

IdrisHanafi · IdrisHanafi · commit 91a365d7dd65 · 2023-12-14T19:29:50.000-05:00
Same PR as #30
diff --git a/pool/pgpoolstorage/policy.go b/pool/pgpoolstorage/policy.go
@@ -34,6 +34,8 @@ func (p *PostgresPoolStorage) CheckPolicy(ctx context.Context, policy pool.Polic
 	} else if err != nil {
 		return false, err
 	}
+
+	defer rows.Close()
 	if !rows.Next() { // should always be a row if the policy exists
 		return false, nil
 	}

Original file line number	Diff line number	Diff line change
`@@ -34,6 +34,8 @@ func (p *PostgresPoolStorage) CheckPolicy(ctx context.Context, policy pool.Polic`
`34`	`34`	`} else if err != nil {`
`35`	`35`	`return false, err`
`36`	`36`	`}`
	`37`	`+`
	`38`	`+ defer rows.Close()`
`37`	`39`	`if !rows.Next() { // should always be a row if the policy exists`
`38`	`40`	`return false, nil`
`39`	`41`	`}`