pg_last_error - PHP code example

PHP Function pg_Last_Error

Article Summary

php function pg_last_error provides a way to get the last error message for a given connection. This is very useful if you want to track errors in a script and fix them. The pg_last_error function also comes in handy when you need to send the same query to multiple servers.

The pg_last_error function is used to display the latest error message for a given PostgreSQL database connection. This function is similar to pg_result_error_field but it allows you to get more detail from an error report.

Use pg_last_error instead of pg_result_error_field for better error handling. It is recommended to use the newer pg_send_query_params function to avoid problems with undefined variables and other issues.

pg_send_query_params() -- Sends a parameterized query asynchronously to the database. This is like pg_query but it can send multiple queries at once and return the results one by one. Unlike pg_query, it does not block the script execution while queries are executing and can be cancelled with pg_cancel_query(). Data inside the query must be properly escaped. This function works only with a PostgreSQL server that supports 7.4 or higher and will not work on pre-7.4 connections.

pg_set_error_verbosity() -- Sets the verbosity of error messages that are returned by pg_last_error and pg_result_error_field. This function used to be called pg_error_message().

pg_last_error example

        $a['status'] = pg_connection_status($link);
        $a['status'] = new ConstStub(\PGSQL_CONNECTION_OK === $a['status'] ? 'PGSQL_CONNECTION_OK' : 'PGSQL_CONNECTION_BAD', $a['status']);
        $a['busy'] = pg_connection_busy($link);

        $a['transaction'] = pg_transaction_status($link);
        if (isset(self::TRANSACTION_STATUS[$a['transaction']])) {
            $a['transaction'] = new ConstStub(self::TRANSACTION_STATUS[$a['transaction']], $a['transaction']);
        }

        $a['pid'] = pg_get_pid($link);
        $a['last error'] = pg_last_error($link);
        $a['last notice'] = pg_last_notice($link);
        $a['host'] = pg_host($link);
        $a['port'] = pg_port($link);
        $a['dbname'] = pg_dbname($link);
        $a['options'] = pg_options($link);
        $a['version'] = pg_version($link);

        foreach (self::PARAM_CODES as $v) {
            if (false !== $s = pg_parameter_status($link, $v)) {
                $a['param'][$v] = $s;
            }
        }

/** * Returns the last error code and message. * Must return this format: ['code' => string|int, 'message' => string] * intval(code) === 0 means "no error". * * @return array<string, int|string> */
    public function error(): array
    {
        return [
            'code'    => '',
            'message' => pg_last_error($this->connID) ?: '',
        ];
    }

    /** * @return int|string */
    public function insertID()
    {
        $v = pg_version($this->connID);
        // 'server' key is only available since PostgreSQL 7.4         $v = explode(' ', $v['server'])[0] ?? 0;

        $this->name = (string) random_int(1, 10_000_000_000_000_000);

        $sql = $this->parameterize($sql);

        // Update the query object since the parameters are slightly different         // than what was put in.         $this->query->setQuery($sql);

        if (! $this->statement = pg_prepare($this->db->connID, $this->name, $sql)) {
            $this->errorCode   = 0;
            $this->errorString = pg_last_error($this->db->connID);

            if ($this->db->DBDebug) {
                throw new DatabaseException($this->errorString . ' code: ' . $this->errorCode);
            }
        }

        return $this;
    }

    /** * Takes a new set of data and runs it against the currently * prepared query. Upon success, will return a Results object. */