如何修改PHP类使其支持接收PgSql\Result作为属性

PHP 8.1及以上版本将PostgreSQL查询结果的资源类型迁移为PgSql\Result实例。在旧版PHP中，我可以这样给类属性赋值：

var $results;
....
$this->results = pg_query($conn, "SELECT author, email FROM authors");

但现在执行这段代码会触发致命错误：

PHP Fatal error: Uncaught Exception: Serialization of 'PgSql\Result' is not allowed in [no active file]

我尝试将属性声明为PgSQL\Result类型但未成功，可能是声明方式有误，我对面向对象编程不太熟悉。

我希望以下代码能正常运行：

class foo
{
    var $results; // 或替换为适配PgSql\Result对象的声明方式

    function __construct()
    {
        $this->results = pg_query($conn, "SELECT author, email FROM authors"); 
    }
}
---------------------
$x = new foo();
$row = pg_fetch_row($x->results);

解决方案 #

1. 正确声明属性类型 #

首先修正属性的类型声明，PHP 8.1+支持直接声明PgSql\Result类型，但要注意类实例不能被序列化——这是报错的核心原因，PgSql\Result是与数据库绑定的资源对象，本身不支持序列化。

修改类代码：

class foo
{
    // 明确声明属性类型为PgSql\Result
    private PgSql\Result $results;

    // 构造函数传入数据库连接，避免全局变量依赖
    function __construct(\PgSql\Connection $conn)
    {
        $result = pg_query($conn, "SELECT author, email FROM authors");
        // 增加查询失败的错误处理
        if (!$result) {
            throw new \RuntimeException('查询失败: ' . pg_last_error($conn));
        }
        $this->results = $result;
    }

    // 提供getter方法获取结果，符合面向对象封装规范
    public function getResults(): PgSql\Result
    {
        return $this->results;
    }
}

2. 避免序列化类实例 #

如果你的代码中存在序列化操作（比如将类实例存入Session、调用serialize()函数等），必须做以下处理：

• 不要将包含PgSql\Result属性的类实例存入Session
• 若必须序列化，重写__sleep()和__wakeup()方法，排除无法序列化的属性，并在唤醒时重新执行查询：

class foo
{
    private PgSql\Result $results;
    private string $query = "SELECT author, email FROM authors";
    private string $connStr = "host=localhost dbname=test user=postgres password=123456";

    function __construct()
    {
        $conn = pg_connect($this->connStr);
        if (!$conn) {
            throw new \RuntimeException('数据库连接失败');
        }
        $this->executeQuery($conn);
    }

    private function executeQuery(\PgSql\Connection $conn): void
    {
        $result = pg_query($conn, $this->query);
        if (!$result) {
            throw new \RuntimeException('查询失败: ' . pg_last_error($conn));
        }
        $this->results = $result;
    }

    // 序列化时仅保存可序列化的属性
    public function __sleep(): array
    {
        return ['query', 'connStr'];
    }

    // 唤醒时重新建立连接并执行查询
    public function __wakeup(): void
    {
        $conn = pg_connect($this->connStr);
        $this->executeQuery($conn);
    }
}

3. 正确使用类实例 #

使用时先建立数据库连接，再实例化类并调用方法获取结果：

$conn = pg_connect("host=localhost dbname=test user=postgres password=123456");
if (!$conn) {
    die('数据库连接失败');
}

$x = new foo($conn);
$row = pg_fetch_row($x->getResults());

关键注意事项 #

• PgSql\Result对象是一次性的，数据读取完毕后无法重复读取，需重新执行查询
• 绝对不要尝试序列化PgSql\Result对象或包含它的类实例，这是PHP 8.1+明确禁止的行为
• 数据库连接需在PgSql\Result使用期间保持活跃，连接关闭后结果对象会失效

内容的提问来源于stack exchange，提问作者Steady Eddie