在MySQL的实际使用中,经常会遇到需要一次函数调用就完成多条SQL语句执行的需求,比如需要同时向用户表和用户详情表插入数据,或者批量更新多个状态字段,这时候就需要掌握对应的实现方式。

使用存储过程实现一次函数调用执行多条语句
存储过程是MySQL中预编译的SQL集合,我们可以把多条SQL语句封装到存储过程里,之后只需要调用这个存储过程,就能一次性执行所有封装的语句。
创建存储过程的语法
创建存储过程的基本语法如下,我们可以在其中编写多条要执行的SQL语句:
-- 创建存储过程,实现同时插入用户表和用户详情表
DELIMITER //
CREATE PROCEDURE insert_user_with_detail(
IN user_name VARCHAR(50),
IN user_age INT,
IN detail_address VARCHAR(200)
)
BEGIN
-- 第一条语句:插入用户表
INSERT INTO user (name, age) VALUES (user_name, user_age);
-- 第二条语句:插入用户详情表,关联刚插入的用户ID
INSERT INTO user_detail (user_id, address) VALUES (LAST_INSERT_ID(), detail_address);
END //
DELIMITER ;
调用存储过程执行多条语句
存储过程创建完成后,只需要使用CALL语句调用一次,就能执行内部的所有SQL:
-- 调用存储过程,传入参数,一次性执行两条插入语句
CALL insert_user_with_detail('张三', 25, '北京市朝阳区');
在客户端代码中拼接多条语句执行
如果不需要在数据库端封装逻辑,也可以在应用层的客户端代码中,把多条SQL语句拼接成一个字符串,然后通过一次函数调用发送给MySQL执行。
PHP示例
在PHP中使用mysqli扩展的multi_query方法可以执行拼接的多条语句:
<?php
$conn = new mysqli('127.0.0.1', 'root', 'password', 'test_db');
// 拼接多条SQL语句,用分号分隔
$sql = "INSERT INTO user (name, age) VALUES ('李四', 30);";
$sql .= "INSERT INTO user_detail (user_id, address) VALUES (LAST_INSERT_ID(), '上海市浦东新区');";
// 一次函数调用执行多条语句
if ($conn->multi_query($sql)) {
echo "多条语句执行成功";
}
$conn->close();
?>
注意事项
- 拼接语句时要注意SQL注入风险,不要直接拼接用户输入的内容,建议使用参数化查询或者严格过滤输入。
- 不同客户端对多条语句执行的支持不同,比如默认的mysqli查询方法只能执行单条语句,需要使用
multi_query这类专门的方法。
使用事务包裹多条语句
如果多条语句需要保证要么全部执行成功,要么全部失败回滚,就可以把多条语句放在事务中,通过一次函数调用开启事务、执行语句、提交事务,实现原子性的多条语句执行。
事务的基本使用示例如下:
-- 开启事务 START TRANSACTION; -- 第一条语句 UPDATE account SET balance = balance - 100 WHERE id = 1; -- 第二条语句 UPDATE account SET balance = balance + 100 WHERE id = 2; -- 提交事务,两条语句都执行成功才生效 COMMIT; -- 如果执行中出现错误,可以执行ROLLBACK回滚所有操作
不同方法的适用场景对比
我们可以通过下面的表格对比几种方法的适用场景:
| 实现方法 | 适用场景 | 优点 | 缺点 |
|---|---|---|---|
| 存储过程 | 多条语句逻辑固定,需要反复调用 | 预编译性能好,逻辑封装在数据库端,减少客户端代码量 | 修改逻辑需要修改数据库对象,移植性稍差 |
| 客户端拼接语句 | 临时需要执行多条简单语句,逻辑不固定 | 无需修改数据库结构,灵活度高 | 有SQL注入风险,需要客户端处理语句拼接逻辑 |
| 事务包裹 | 多条语句需要保证原子性,数据一致性要求高 | 保证数据要么全成功要么全失败,避免数据不一致 | 会增加数据库锁的持有时间,高并发场景需要注意性能 |
注意:如果使用的是共享数据库环境,部分服务商可能会禁用存储过程或者多语句执行权限,使用前需要确认数据库的权限配置。