pg_affected_rows - PHP code example

PHP Function Pg_Affected_Rows

php function pg_affected_rows is one of the most important routines for using PostgreSQL from your php application. The function can help you know the number of rows that has been affected by INSERT, UPDATE or DELETE queries in your database.

Its a simple and powerful function for getting the number of rows affected by a SQL query. It is very helpful for developers and webmasters who use PostgreSQL in their applications. The php function can be used with either the mysql or postgres database.

The function accepts a parameter called query_str. The query_str is a string that contains the SQL statement to execute. It can also contain the BEGIN and COMMIT statements, but it is not recommended to use multiple transactions within a single call to a query function. The function also accepts an argument called assoc_array. The assoc_array is an array of values that will be inserted into the table specified by the table_name. The assoc_array must have as many elements as the number of columns in the table.

The pg_affected_rows() function returns the number of tuples (instances/records/rows) affected by INSERT, UPDATE, and DELETE queries. It can return 0 if the query was a SELECT query. Unlike @@ROWCOUNT, which only works on DDL statements like INSERT, UPDATE and DELETE, pg_affected_rows() returns the row count for all tuples in the result of a query, including those that were returned as NULL. This differs from MySQL and MariaDB, which only return the ROWCOUNT value for SELECT queries.

pg_affected_rows example

if (isset(self::RESULT_STATUS[$a['status']])) {
            $a['status'] = new ConstStub(self::RESULT_STATUS[$a['status']], $a['status']);
        }
        $a['command-completion tag'] = pg_result_status($result, \PGSQL_STATUS_STRING);

        if (-1 === $a['num rows']) {
            foreach (self::DIAG_CODES as $k => $v) {
                $a['error'][$k] = pg_result_error_field($result, $v);
            }
        }

        $a['affected rows'] = pg_affected_rows($result);
        $a['last OID'] = pg_last_oid($result);

        $fields = pg_num_fields($result);

        for ($i = 0; $i < $fields; ++$i) {
            $field = [
                'name' => pg_field_name($result, $i),
                'table' => sprintf('%s (OID: %s)', pg_field_table($result, $i), pg_field_table($result, $i, true)),
                'type' => sprintf('%s (OID: %s)', pg_field_type($result, $i), pg_field_type_oid($result, $i)),
                'nullable' => (bool) pg_field_is_null($result, $i),
                'storage' => pg_field_size($result, $i).' bytes',

    protected function getDriverFunctionPrefix(): string
    {
        return 'pg_';
    }

    /** * Returns the total number of rows affected by this query. */
    public function affectedRows(): int
    {
        return pg_affected_rows($this->resultID);
    }

    /** * "Smart" Escape String * * Escapes data based on type * * @param array|bool|float|int|object|string|null $str * * @return array|float|int|string * @phpstan-return ($str is array ? array : float|int|string) */