PHP调用MySQL存储过程主要通过PDO实现,需先启用PDO扩展并建立数据库连接。1. 使用new PDO()连接MySQL;2. 调用无参存储过程如CALL get_users(),执行后获取结果集;3. 对带输入参数的存储过程使用bindParam绑定参数;4. 处理OUT参数时通过用户变量(如@total)并额外查询获取值;5. 若存储过程返回多个结果集,需用nextRowset()依次读取。正确处理参数与结果集即可高效安全调用存储过程。

PHP调用MySQL存储过程主要通过PDO或MySQLi扩展来实现。下面以PDO为例,详细介绍执行存储过程的步骤,包括连接数据库、调用带参数和不带参数的存储过程、处理结果集等。
1. 确保使用PDO扩展
PHP中推荐使用PDO(PHP Data Objects)来调用MySQL存储过程,因为它支持预处理语句和多种数据库,安全性高且语法清晰。确保PHP环境中已启用PDO和PDO_MySQL扩展。可以在php.ini中检查以下配置:
extension=pdo_mysql
2. 连接MySQL数据库
使用PDO连接数据库是调用存储过程的第一步。需要提供DSN(数据源名称)、用户名和密码。示例代码:
$host = 'localhost'; $dbname = 'test_db'; $username = 'root'; $password = 'your_password';try { $pdo = new PDO("mysql:host=$host;dbname=$dbname;charset=utf8", $username, $password); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { die("数据库连接失败: " . $e->getMessage()); }
3. 调用无参存储过程
假设MySQL中有一个名为get_users的存储过程,用于查询所有用户信息。MySQL中创建存储过程示例:
立即学习“PHP免费学习笔记(深入)”;
DELIMITER //
CREATE PROCEDURE get_users()
BEGIN
SELECT id, name, email FROM users;
END //
DELIMITER ;PHP调用该存储过程:
$stmt = $pdo->prepare("CALL get_users()");
$stmt->execute();
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($result as $row) {
echo "ID: " . $row['id'] . ", 名称: " . $row['name'] . "
";
}
4. 调用带参存储过程(输入参数)
如果存储过程需要传入参数,比如根据用户ID查询信息。MySQL中创建带输入参数的存储过程:
DELIMITER //
CREATE PROCEDURE get_user_by_id(IN user_id INT)
BEGIN
SELECT id, name, email FROM users WHERE id = user_id;
END //
DELIMITER ;PHP调用并传参:
$userId = 1;
$stmt = $pdo->prepare("CALL get_user_by_id(?)");
$stmt->bindParam(1, $userId, PDO::PARAM_INT);
$stmt->execute();
$user = $stmt->fetch(PDO::FETCH_ASSOC);
if ($user) {
echo "找到用户: " . $user['name'];
} else {
echo "未找到用户";
}
5. 调用带输出参数的存储过程
有时存储过程会通过OUT参数返回值,例如统计用户数量。MySQL创建带OUT参数的存储过程:
DELIMITER //
CREATE PROCEDURE count_users(OUT total INT)
BEGIN
SELECT COUNT(*) INTO total FROM users;
END //
DELIMITER ;PHP调用并获取输出参数:
// 注意:PDO不直接支持OUT参数绑定,需通过SELECT获取
$stmt = $pdo->prepare("CALL count_users(@total)");
$stmt->execute();
// 查询输出变量的值
$result = $pdo->query("SELECT @total as total")->fetch(PDO::FETCH_ASSOC);
echo "用户总数: " . $result['total'];
6. 处理多个结果集
某些存储过程可能返回多个结果集,需使用nextRowset()方法逐个读取。示例存储过程返回两个查询结果:
DELIMITER //
CREATE PROCEDURE get_users_and_count()
BEGIN
SELECT * FROM users;
SELECT COUNT(*) as total FROM users;
END //
DELIMITER ;PHP处理多个结果集:
$stmt = $pdo->prepare("CALL get_users_and_count()");
$stmt->execute();
// 第一个结果集:用户列表
$users = $stmt->fetchAll(PDO::FETCH_ASSOC);
echo "用户列表:
";
foreach ($users as $user) {
echo $user['name'] . "
";
}
// 移动到下一个结果集
$stmt->nextRowset();
// 第二个结果集:总数
$count = $stmt->fetch(PDO::FETCH_ASSOC);
echo "总人数: " . $count['total'];
基本上就这些。只要正确使用PDO的CALL语句,并注意参数绑定和结果集处理,PHP调用MySQL存储过程并不复杂,但容易忽略多结果集和OUT参数的特殊处理方式。











