Implement Result::getQueryResult()

php-db/phpdb#172 added getQueryResult() to Driver\ResultInterface, so
Pgsql\Result no longer satisfied the contract and loading the class was a
fatal before any test could run. Follows Pdo\Result upstream: guard on
isQueryResult(), clone the given prototype or a default ResultSet, and
initialize it from this result.

php-db/phpdb 0.6.x-dev requires php ^8.3, so the php constraint,
config.platform.php and the PhpStan check in .laminas-ci.json move to 8.3 —
the lock cannot pick up the interface change otherwise.

Covered by unit tests over a ResultStub that answers the two methods
reading the pgsql resource, and by integration tests running a real select
and a fields-less statement through the native driver.

Author: simon-mundy

.laminas-ci.json

@@ -3,7 +3,7 @@
         {
             "name": "PhpStan",
             "job": {
-                "php": "8.2",
+                "php": "8.3",
                 "dependencies": "latest",
                 "command": "composer require --dev phpstan/phpstan && vendor/bin/phpstan analyse"
             }

composer.json

@@ -18,7 +18,7 @@
     "config": {
         "sort-packages": true,
         "platform": {
-            "php": "8.2.99"
+            "php": "8.3.99"
         },
         "allow-plugins": {
             "dealerdirect/phpcodesniffer-composer-installer": true
@@ -30,7 +30,7 @@
         }
     },
     "require": {
-        "php": "~8.2.0 || ~8.3.0 || ~8.4.0 || ~8.5.0",
+        "php": "~8.3.0 || ~8.4.0 || ~8.5.0",
         "php-db/phpdb": "^0.6.0"
     },
     "require-dev": {

composer.lock

@@ -7,6 +7,9 @@
 use Override;
 use PgSql\Result as PgSqlResult;
 use PhpDb\Adapter\Driver\ResultInterface;
+use PhpDb\Adapter\Exception;
+use PhpDb\ResultSet\ResultSet;
+use PhpDb\ResultSet\ResultSetInterface;
 
 use function pg_affected_rows;
 use function pg_fetch_assoc;
@@ -94,6 +97,26 @@ public function getGeneratedValue(): int|string|false|null
         return $this->generatedValue;
     }
 
+    /**
+     * @throws Exception\RuntimeException When this result is not a query result.
+     */
+    #[Override]
+    public function getQueryResult(?ResultSetInterface $resultPrototype = null): ResultSetInterface
+    {
+        if (! $this->isQueryResult()) {
+            throw new Exception\RuntimeException(
+                'Cannot produce a query result set from a result that is not a query result;'
+                    . ' check isQueryResult() first'
+            );
+        }
+
+        $resultPrototype ??= new ResultSet();
+        $resultSet         = clone $resultPrototype;
+        $resultSet->initialize($this);
+
+        return $resultSet;
+    }
+
     /**
      * Get resource
      */

src/Result.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpDbTestAsset\Pgsql;
+
+use Override;
+use PhpDb\Pgsql\Result;
+
+/**
+ * Result::getQueryResult() only needs isQueryResult() and getFieldCount() to be
+ * answerable, both of which read the pgsql resource. Overriding them keeps the
+ * method unit-testable without a live connection.
+ */
+final class ResultStub extends Result
+{
+    public function __construct(private bool $isQueryResult, private int $fieldCount = 0)
+    {
+    }
+
+    #[Override]
+    public function isQueryResult(): bool
+    {
+        return $this->isQueryResult;
+    }
+
+    #[Override]
+    public function getFieldCount(): int
+    {
+        return $this->fieldCount;
+    }
+}

test/asset/ResultStub.php

@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpDbIntegrationTest\Pgsql;
+
+use PhpDb\Adapter\Exception;
+use PhpDb\Pgsql\Result;
+use PhpDbTestAsset\Pgsql\SetupTrait;
+use PHPUnit\Framework\Attributes\CoversMethod;
+use PHPUnit\Framework\TestCase;
+
+#[CoversMethod(Result::class, 'getQueryResult')]
+#[CoversMethod(Result::class, 'isQueryResult')]
+class ResultTest extends TestCase
+{
+    use SetupTrait;
+
+    public function testGetQueryResultSeedsTheResultSetFromASelect(): void
+    {
+        $result = $this->getAdapter()->executeQuery('SELECT id, name, value FROM test');
+
+        self::assertSame($result->getFieldCount(), $result->getQueryResult()->getFieldCount());
+    }
+
+    public function testGetQueryResultIteratesTheSelectedRows(): void
+    {
+        $result = $this->getAdapter()->executeQuery('SELECT name FROM test ORDER BY id');
+
+        $names = [];
+        foreach ($result->getQueryResult() as $row) {
+            $names[] = $row['name'];
+        }
+
+        self::assertSame(['foo', 'bar'], $names);
+    }
+
+    public function testAStatementReturningNoFieldsIsNotAQueryResult(): void
+    {
+        $result = $this->getAdapter()->executeQuery('SET search_path TO public');
+
+        self::assertFalse($result->isQueryResult());
+    }
+
+    public function testGetQueryResultRejectsAStatementThatReturnsNoFields(): void
+    {
+        $result = $this->getAdapter()->executeQuery('SET search_path TO public');
+
+        $this->expectException(Exception\RuntimeException::class);
+        $this->expectExceptionMessage(
+            'Cannot produce a query result set from a result that is not a query result;'
+                . ' check isQueryResult() first'
+        );
+
+        $result->getQueryResult();
+    }
+}

test/integration/ResultTest.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpDbTest\Pgsql;
+
+use PhpDb\Adapter\Exception;
+use PhpDb\Pgsql\Result;
+use PhpDb\ResultSet\ResultSet;
+use PhpDbTestAsset\Pgsql\ResultStub;
+use PHPUnit\Framework\Attributes\CoversMethod;
+use PHPUnit\Framework\TestCase;
+
+#[CoversMethod(Result::class, 'getQueryResult')]
+class ResultTest extends TestCase
+{
+    public function testGetQueryResultSeedsTheResultSetFromTheResult(): void
+    {
+        $resultSet = (new ResultStub(true, 3))->getQueryResult();
+
+        self::assertSame(3, $resultSet->getFieldCount());
+    }
+
+    public function testGetQueryResultClonesTheGivenPrototype(): void
+    {
+        $prototype = new ResultSet();
+
+        $resultSet = (new ResultStub(true, 1))->getQueryResult($prototype);
+
+        self::assertNotSame($prototype, $resultSet);
+    }
+
+    public function testGetQueryResultRejectsAResultThatIsNotAQueryResult(): void
+    {
+        $this->expectException(Exception\RuntimeException::class);
+        $this->expectExceptionMessage(
+            'Cannot produce a query result set from a result that is not a query result;'
+                . ' check isQueryResult() first'
+        );
+
+        (new ResultStub(false))->getQueryResult();
+    }
+}