使用 PDO 迭代存储过程结果集：PHP 教程-php教程-PHP中文网

使用 PDO 迭代存储过程结果集：PHP 教程

聖光之護

发布： 2025-10-15 12:34:24

原创

388人浏览过

使用 pdo 迭代存储过程结果集：php 教程

本文旨在帮助开发者理解如何使用 PHP 的 PDO (PHP Data Objects) 扩展，安全有效地迭代存储过程返回的结果集。我们将通过一个实际案例，详细讲解如何正确地获取和遍历存储过程的结果，并提供相应的代码示例和注意事项。

在使用 PDO 调用存储过程并处理返回结果时，常见的错误是直接在类实例上调用 fetch() 方法，导致 "Call to undefined method" 错误。这是因为 getCountries() 方法返回的是 PDOStatement 对象，而不是结果集本身。正确的做法是从 PDOStatement 对象中获取数据，并进行迭代。

以下是一个完整的示例，展示了如何使用 PDO 迭代存储过程返回的结果集：

1. 数据库连接类 (dbh.classes.php):

立即学习“PHP免费学习笔记（深入）”；

<?php

class Dbh {
    private $host = "localhost";
    private $user = "your_username";
    private $pwd = "your_password";
    private $dbName = "your_database";

    protected function connect() {
        try {
            $dsn = 'mysql:host=' . $this->host . ';dbname=' . $this->dbName;
            $pdo = new PDO($dsn, $this->user, $this->pwd);
            $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
            return $pdo;
        } catch (PDOException $e) {
            echo "Connection failed: " . $e->getMessage();
            die();
        }
    }
}

登录后复制

注意事项:

请将 $host, $user, $pwd, 和 $dbName 替换为你的实际数据库连接信息。
PDO::ATTR_DEFAULT_FETCH_MODE 设置为 PDO::FETCH_ASSOC 可以让结果集以关联数组的形式返回，方便访问。

2. 列表类 (list.classes.php):

<?php
class Lists extends Dbh {
    public function getCountries() {
        $stmt = $this->connect()->prepare("CALL spl_countries()"); // 使用 CALL 关键字调用存储过程

        if(!$stmt->execute()) {
            $stmt = null;
            header("location: ../index.php?error=stmtfailed");
            exit();
        }

        if($stmt->rowCount() == 0) {
            $stmt = null;
            header("location: ../index.php?error=countrynotfound");
            exit();
        }
        return $stmt;
    }
}

登录后复制

关键点:

豆包AI编程

豆包推出的AI编程助手

483

查看详情

使用 CALL spl_countries() 语句调用存储过程。
确保数据库用户拥有执行存储过程的权限。

3. 存储过程 (spl_countries):

-- 如果存储过程存在，先删除
IF EXISTS (SELECT * FROM sys.procedures WHERE name = 'spl_countries')
    DROP PROCEDURE spl_countries;
GO

-- 创建存储过程
CREATE PROCEDURE spl_countries
AS
BEGIN
    SELECT countryID, country, iso2, iso3, phoneCode, niceName, numCode
    FROM CO_Country
    ORDER BY country ASC;
END;
GO

登录后复制

注意:

此示例针对 SQL Server。MySQL 等其他数据库的语法可能略有不同。
根据你的数据库表结构调整 SELECT 语句。
务必在实际环境中测试存储过程的性能。

4. 测试文件 (test.php):

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Country List</title>
</head>
<body>
    <?php
    include "classes/dbh.classes.php";
    include "classes/list.classes.php";

    $listCountry = new Lists();
    $countries = $listCountry->getCountries(); // 获取 PDOStatement 对象

    ?>
    <select>
        <?php
        // 正确的迭代方式：使用 fetchAll 或 while 循环
        // 方式一：使用 fetchAll 获取所有结果
        //$countryList = $countries->fetchAll();
        //foreach ($countryList as $row) {
        //    echo "<option value='" . $row['countryID'] . "'>" . $row['phoneCode'] . " - " . $row['country'] . "</option>";
        //}

        // 方式二：使用 while 循环逐行获取结果
        while($row = $countries->fetch()) { // 使用 fetch() 方法获取每一行数据
            echo "<option value='" . $row['countryID'] . "'>" . $row['phoneCode'] . " - " . $row['country'] . "</option>";
        }

        // 释放资源
        $countries = null;
        ?>
    </select>
</body>
</html>

登录后复制

核心代码解释:

获取 PDOStatement 对象: $countries = $listCountry->getCountries(); 从 getCountries() 方法获取 PDOStatement 对象。
迭代结果集: 有两种主要方式迭代结果集：
- fetchAll(): 一次性获取所有结果到一个数组中。适用于结果集较小的情况。$countryList = $countries->fetchAll();，然后使用 foreach 循环遍历 $countryList。
- while 循环和 fetch(): 逐行获取结果。适用于结果集较大的情况，可以减少内存占用。while($row = $countries->fetch())，fetch() 方法每次调用返回一行数据，直到没有更多数据为止。
访问数据: 使用 $row['column_name'] 的形式访问每一列的数据，其中 column_name 是数据库表中的列名。
释放资源: $countries = null; 释放 PDOStatement 对象，这是一个良好的编程习惯。

总结:

通过以上步骤，你可以安全有效地使用 PDO 迭代存储过程返回的结果集。记住，关键在于正确地获取 PDOStatement 对象，并使用 fetchAll() 或 while 循环和 fetch() 方法来获取数据。同时，要注意数据库连接信息和存储过程的正确配置，并根据实际情况选择合适的迭代方式。确保释放资源，避免内存泄漏。

以上就是使用 PDO 迭代存储过程结果集：PHP 教程的详细内容，更多请关注php中文网其它相关文章！