如何在 PHP 中调用 MySQL 存储过程并获取结果集

在 PHP 项目中，把复杂的查询逻辑封装到 MySQL 存储过程里，可以让代码更清晰，也方便数据库端优化。本文介绍如何使用 PHP 的 PDO 和 mysqli 两种常见方式调用 MySQL 存储过程，并正确获取返回的结果集。

使用 PDO 调用存储过程

PDO 扩展提供了统一的数据库访问接口。调用存储过程时，只需要用预处理语句执行 CALL 命令，然后像普通查询一样读取结果。

示例代码

<?php
// 假设已有存储过程: CREATE PROCEDURE get_users() BEGIN SELECT id, name FROM users; END

$dsn = 'mysql:host=localhost;dbname=test;charset=utf8mb4';
$pdo = new PDO($dsn, 'root', 'password');

// 调用存储过程
$stmt = $pdo->prepare('CALL get_users()');
$stmt->execute();

// 获取结果集
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($rows as $row) {
    echo $row['id'] . ':' . $row['name'] . PHP_EOL;
}

// 关闭游标，便于后续调用其他存储过程
$stmt->closeCursor();
?>

使用 mysqli 调用存储过程

mysqli 是 PHP 原生的 MySQL 扩展。如果存储过程只返回一个结果集，可以直接用 query() 方法执行 CALL 语句。

示例代码

<?php
$mysqli = new mysqli('localhost', 'root', 'password', 'test');

if ($mysqli->connect_error) {
    die('连接失败: ' . $mysqli->connect_error);
}

// 调用存储过程
if ($result = $mysqli->query('CALL get_users()')) {
    while ($row = $result->fetch_assoc()) {
        echo $row['id'] . ':' . $row['name'] . PHP_EOL;
    }
    $result->free();
}

// 清理可能残留的额外结果集
while ($mysqli->more_results() && $mysqli->next_result()) {
    if ($res = $mysqli->store_result()) {
        $res->free();
    }
}

$mysqli->close();
?>

处理带参数的存储过程

如果存储过程需要传入参数或返回输出参数，可以用占位符绑定。下面以 PDO 传入参数为例：

<?php
$stmt = $pdo->prepare('CALL get_user_by_id(:uid)');
$stmt->bindValue(':uid', 10, PDO::PARAM_INT);
$stmt->execute();

$user = $stmt->fetch(PDO::FETCH_ASSOC);
print_r($user);

$stmt->closeCursor();
?>

注意事项

• 存储过程可能返回多个结果集，尤其是包含中间 SELECT 时，必须循环清理多余结果，否则后续查询会报错。
• PDO 调用后建议执行 closeCursor()，避免游标占用连接。
• 在 mysqli 中，使用 multi_query() 能更灵活地处理多结果集场景。

合理封装存储过程可以减少重复 SQL，但也要注意调试和权限管理，避免业务逻辑过度依赖数据库端。

小结

通过 PDO 或 mysqli 扩展，PHP 调用 MySQL 存储过程并获取结果集并不复杂。核心在于正确执行 CALL 语句、读取返回数据，以及妥善清理多结果集。根据项目使用的扩展选择合适写法即可。

PHPMySQLstored_procedure修改时间：2026-07-27 19:18:19