本文旨在帮助开发者理解如何使用 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;
}
}关键点:
- 使用 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() 方法来获取数据。同时，要注意数据库连接信息和存储过程的正确配置，并根据实际情况选择合适的迭代方式。 确保释放资源，避免内存泄漏。
