PHP存储过程[编辑 | 编辑源代码]

PHP存储过程（Stored Procedures）是预编译的SQL语句集合，存储在数据库服务器中，可通过PHP调用执行。存储过程提高了代码复用性、安全性和性能，尤其适合处理复杂的数据库操作。

概述[编辑 | 编辑源代码]

存储过程是数据库对象，包含一组SQL语句和控制结构（如条件判断、循环等），具有以下特点：

预编译执行：减少SQL解析开销
减少网络流量：只需传递过程名和参数
增强安全性：限制直接表访问
事务管理：可在过程中实现完整事务

基本语法[编辑 | 编辑源代码]

创建存储过程[编辑 | 编辑源代码]

MySQL语法示例：

DELIMITER //
CREATE PROCEDURE get_customer(IN cust_id INT)
BEGIN
    SELECT * FROM customers WHERE id = cust_id;
END //
DELIMITER ;

PHP调用存储过程[编辑 | 编辑源代码]

基本调用方式：

<?php
$pdo = new PDO("mysql:host=localhost;dbname=test", "user", "password");
$stmt = $pdo->prepare("CALL get_customer(?)");
$stmt->execute([42]);
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
print_r($result);
?>

参数类型[编辑 | 编辑源代码]

存储过程支持三种参数模式：

示例：带输出参数的存储过程[编辑 | 编辑源代码]

CREATE PROCEDURE count_products(OUT total INT)
BEGIN
    SELECT COUNT(*) INTO total FROM products;
END

PHP调用方式：

$stmt = $pdo->prepare("CALL count_products(@total)");
$stmt->execute();
$stmt = $pdo->query("SELECT @total AS total");
echo $stmt->fetch()['total']; // 输出产品总数

事务处理[编辑 | 编辑源代码]

存储过程可封装完整事务：

CREATE PROCEDURE transfer_funds(
    IN from_account INT,
    IN to_account INT,
    IN amount DECIMAL(10,2),
    OUT status VARCHAR(50)
)
BEGIN
    DECLARE EXIT HANDLER FOR SQLEXCEPTION
    BEGIN
        ROLLBACK;
        SET status = 'Error occurred';
    END;
    
    START TRANSACTION;
    UPDATE accounts SET balance = balance - amount WHERE id = from_account;
    UPDATE accounts SET balance = balance + amount WHERE id = to_account;
    COMMIT;
    SET status = 'Transfer successful';
END

性能优化[编辑 | 编辑源代码]

存储过程相比动态SQL的优势：

减少网络延迟
执行计划缓存
批量操作效率

性能对比公式： $T_{d y n a m i c} = n \times (t_{p a r s e} + t_{n e t w o r k} + t_{e x e c u t e})$ $T_{s t o r e d} = t_{n e t w o r k} + n \times t_{e x e c u t e}$

实际案例[编辑 | 编辑源代码]

电商平台订单处理[编辑 | 编辑源代码]

CREATE PROCEDURE process_order(
    IN user_id INT,
    IN product_ids VARCHAR(255),
    IN quantities VARCHAR(255),
    OUT order_id INT
)
BEGIN
    -- 变量声明
    DECLARE i INT DEFAULT 0;
    DECLARE product_count INT;
    DECLARE current_pid INT;
    DECLARE current_qty INT;
    
    -- 创建订单
    INSERT INTO orders (user_id, order_date) VALUES (user_id, NOW());
    SET order_id = LAST_INSERT_ID();
    
    -- 处理订单项
    SET product_count = LENGTH(product_ids) - LENGTH(REPLACE(product_ids, ',', '')) + 1;
    
    WHILE i < product_count DO
        SET current_pid = SUBSTRING_INDEX(SUBSTRING_INDEX(product_ids, ',', i+1), ',', -1);
        SET current_qty = SUBSTRING_INDEX(SUBSTRING_INDEX(quantities, ',', i+1), ',', -1);
        
        INSERT INTO order_items (order_id, product_id, quantity)
        VALUES (order_id, current_pid, current_qty);
        
        UPDATE products SET stock = stock - current_qty WHERE id = current_pid;
        
        SET i = i + 1;
    END WHILE;
    
    -- 更新订单总价
    UPDATE orders o
    SET total_amount = (
        SELECT SUM(p.price * oi.quantity)
        FROM order_items oi
        JOIN products p ON oi.product_id = p.id
        WHERE oi.order_id = o.id
    )
    WHERE o.id = order_id;
END