fix(database): preserve Postgre prepared SQLSTATE

- Execute prepared statements through the send/get-result flow
- Classify Postgre prepared failures from structured SQLSTATE diagnostics

Signed-off-by: memleakd <121398829+memleakd@users.noreply.github.com>

Author: memleakd

system/Database/Postgre/PreparedQuery.php

@@ -92,31 +92,51 @@ public function _execute(array $data): bool
             }
         }
 
-        $this->result = pg_execute($this->db->connID, $this->name, $data);
+        $sent = pg_send_execute($this->db->connID, $this->name, $data);
 
-        if ($this->result instanceof PgSqlResult && pg_result_status($this->result) === PGSQL_FATAL_ERROR) {
-            $sqlstate                = (string) pg_result_error_field($this->result, PGSQL_DIAG_SQLSTATE);
-            $this->errorCode         = 0;
-            $this->errorString       = (string) pg_result_error($this->result);
-            $this->databaseException = $this->db->createDatabaseException($this->errorString, $sqlstate);
-
-            if ($this->db->DBDebug) {
-                throw $this->databaseException;
-            }
+        if ($sent === false || $sent === 0) {
+            $this->errorCode   = 0;
+            $this->errorString = pg_last_error($this->db->connID);
 
             return false;
         }
 
+        $this->result = pg_get_result($this->db->connID);
+
         if ($this->result === false) {
             $this->errorCode   = 0;
             $this->errorString = pg_last_error($this->db->connID);
 
+            return false;
+        }
+
+        $lastResult   = $this->result;
+        $failedResult = pg_result_status($this->result) === PGSQL_FATAL_ERROR ? $this->result : null;
+
+        while (($next = pg_get_result($this->db->connID)) !== false) {
+            $lastResult = $next;
+
+            if (! $failedResult instanceof PgSqlResult && pg_result_status($next) === PGSQL_FATAL_ERROR) {
+                $failedResult = $next;
+            }
+        }
+
+        $this->result = $lastResult;
+
+        if ($failedResult instanceof PgSqlResult) {
+            $sqlstate                = (string) pg_result_error_field($failedResult, PGSQL_DIAG_SQLSTATE);
+            $this->errorCode         = 0;
+            $this->errorString       = (string) pg_result_error($failedResult);
+            $this->databaseException = $this->db->createDatabaseException($this->errorString, $sqlstate);
+
             if ($this->db->DBDebug) {
-                throw $this->db->createDatabaseException($this->errorString, $this->errorCode);
+                throw $this->databaseException;
             }
+
+            return false;
         }
 
-        return (bool) $this->result;
+        return true;
     }
 
     /**