Close pgsql connection in destructor

Author: derrabus

phpstan.neon.dist

@@ -148,6 +148,9 @@ parameters:
         - '~^Parameter #1 \$row of method Doctrine\\DBAL\\Driver\\PgSQL\\Result\:\:mapAssociativeRow\(\) expects array<string, string\|null>, array<int\|string, string\|null> given\.$~'
         - '~^Parameter #1 \$row of method Doctrine\\DBAL\\Driver\\PgSQL\\Result\:\:mapNumericRow\(\) expects array<int, string\|null>, array<int\|string, string\|null> given\.$~'
 
+        # Ignore isset() checks in destructors.
+        - '~^Property Doctrine\\DBAL\\Driver\\PgSQL\\Connection\:\:\$connection \(PgSql\\Connection\|resource\) in isset\(\) is not nullable\.$~'
+
         # On PHP 7.4, pg_fetch_all() might return false for empty result sets.
         -
             message: '~^Strict comparison using === between array<int, array> and false will always evaluate to false\.$~'

psalm.xml.dist

@@ -645,6 +645,7 @@
             <errorLevel type="suppress">
                 <!-- PgSql objects are represented as resources in PHP 7.4 -->
                 <referencedFunction name="pg_affected_rows"/>
+                <referencedFunction name="pg_close"/>
                 <referencedFunction name="pg_escape_bytea"/>
                 <referencedFunction name="pg_escape_literal"/>
                 <referencedFunction name="pg_fetch_all"/>
@@ -748,6 +749,9 @@
             <errorLevel type="suppress">
                 <!-- Running isset() checks on properties that should be initialized by setUp() is fine. -->
                 <directory name="tests"/>
+
+                <!-- Ignore isset() checks in destructors. -->
+                <file name="src/Driver/PgSQL/Connection.php"/>
             </errorLevel>
         </RedundantPropertyInitializationCheck>
         <ReferenceConstraintViolation>

src/Driver/PgSQL/Connection.php

@@ -14,6 +14,7 @@
 use function gettype;
 use function is_object;
 use function is_resource;
+use function pg_close;
 use function pg_escape_bytea;
 use function pg_escape_literal;
 use function pg_get_result;
@@ -47,6 +48,15 @@ public function __construct($connection)
         $this->parser     = new Parser(false);
     }
 
+    public function __destruct()
+    {
+        if (isset($this->connection)) {
+            @pg_close($this->connection);
+        }
+
+        unset($this->connection);
+    }
+
     public function prepare(string $sql): Statement
     {
         $visitor = new ConvertParameters();