在PHP的数据库开发场景中,经常会遇到需要一次性执行多条SQL语句的需求,比如同时查询不同表的数据、批量插入多条记录等,这时候使用mysqli扩展的多语句查询功能可以大幅提升操作效率,减少不必要的数据库连接开销。

mysqli多条SQL语句查询的核心函数
mysqli扩展提供了mysqli_multi_query函数用于执行多条SQL语句,该函数可以接收一条包含多个用分号分隔的SQL语句的字符串,然后依次执行这些语句。它的基本语法如下:
bool mysqli_multi_query(mysqli $mysql, string $query)
参数说明:第一个参数是已经建立好的mysqli连接对象,第二个参数是包含多条SQL语句的字符串,多条语句之间用英文分号分隔。函数执行成功返回true,失败返回false。
完整的使用步骤
1. 建立数据库连接
首先需要使用mysqli_connect函数建立到MySQL数据库的连接,示例代码如下:
<?php
// 数据库连接配置
$host = '127.0.0.1';
$user = 'root';
$password = '123456';
$database = 'test_db';
// 建立连接
$conn = mysqli_connect($host, $user, $password, $database);
// 检查连接是否成功
if (!$conn) {
die('数据库连接失败:' . mysqli_connect_error());
}
?>
2. 执行多条SQL语句
准备需要执行的多条SQL语句,用分号分隔后调用mysqli_multi_query执行,示例如下:
<?php
// 多条SQL语句,查询用户表和订单表的前5条数据
$sql = "SELECT * FROM users LIMIT 5;SELECT * FROM orders LIMIT 5;";
// 执行多条SQL语句
if (mysqli_multi_query($conn, $sql)) {
echo '多条SQL语句执行成功';
} else {
echo 'SQL语句执行失败:' . mysqli_error($conn);
}
?>
3. 获取所有结果集
多条SQL语句执行后会产生多个结果集,需要使用mysqli_store_result获取当前结果集,使用mysqli_next_result切换到下一个结果集,直到所有结果集处理完毕。示例如下:
<?php
$sql = "SELECT * FROM users LIMIT 5;SELECT * FROM orders LIMIT 5;";
if (mysqli_multi_query($conn, $sql)) {
$resultIndex = 1;
do {
// 获取当前结果集
$result = mysqli_store_result($conn);
if ($result) {
echo '<h3>第' . $resultIndex . '条查询结果</h3>';
// 遍历结果集
while ($row = mysqli_fetch_assoc($result)) {
print_r($row);
echo '<br/>';
}
// 释放结果集
mysqli_free_result($result);
$resultIndex++;
}
} while (mysqli_next_result($conn));
}
?>
注意事项与常见问题
- 多条SQL语句之间必须用英文分号分隔,否则会被识别为单条语句导致执行错误。
- 如果其中某一条SQL语句执行失败,后续的语句都不会继续执行,可以通过
mysqli_error获取错误信息。 - 处理完所有结果集前不要关闭数据库连接,否则会导致后续结果集无法获取。
- 使用
mysqli_multi_query时需要注意SQL注入问题,如果是动态拼接的SQL语句,建议对参数做转义处理或者使用预处理语句(不过预处理语句不支持一次执行多条不同结构的SQL)。
适用场景说明
这种方式适合需要一次性执行多条独立SQL语句的场景,比如同时查询多个不相关的表数据、批量执行DDL语句等。如果多条SQL语句之间有依赖关系,或者需要事务支持,建议结合事务使用,确保所有语句要么全部执行成功,要么全部回滚。
<?php
// 开启事务
mysqli_begin_transaction($conn);
try {
$sql = "UPDATE account SET balance = balance - 100 WHERE id = 1;UPDATE account SET balance = balance + 100 WHERE id = 2;";
if (mysqli_multi_query($conn, $sql)) {
// 确保所有结果集都处理完毕
do {
$result = mysqli_store_result($conn);
if ($result) {
mysqli_free_result($result);
}
} while (mysqli_next_result($conn));
// 提交事务
mysqli_commit($conn);
echo '转账操作执行成功';
} else {
throw new Exception(mysqli_error($conn));
}
} catch (Exception $e) {
// 回滚事务
mysqli_rollback($conn);
echo '操作失败,已回滚:' . $e->getMessage();
}
?>
最后使用完数据库连接后记得关闭连接,调用mysqli_close($conn)即可。
mysqli多条sql语句查询mysqli_multi_query数据库查询PHP修改时间:2026-06-19 18:30:30