异常教程

PHP mysqli_multi_query() 函数（保姆级教程）

更新时间:

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战 / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

  • 新项目:《从零手撸：仿小红书（微服务架构）》 正在持续爆肝中，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;
  • 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前， 星球 内专栏累计输出 82w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 2900+ 小伙伴加入学习 ，欢迎点击围观

前言

在 PHP 开发中，数据库操作是核心场景之一。随着业务复杂度的提升，开发者常常需要同时执行多个 SQL 语句。例如，在用户注册时，可能需要同时插入用户信息、记录日志、更新统计表等。此时，逐个执行查询不仅效率低下，还会增加代码冗余。PHP mysqli_multi_query() 函数正是为了解决这类问题而设计，它允许通过一次数据库连接发送并执行多个 SQL 语句，从而提升性能和代码简洁性。

本文将从基础语法、实际案例、注意事项等角度，深入浅出地讲解这一函数，帮助开发者高效利用它优化数据库交互逻辑。

基础语法与使用场景

语法结构

mysqli_multi_query() 的基本语法如下：

mysqli_multi_query(连接对象, SQL 查询字符串);
  • 连接对象：已建立的 MySQLi 数据库连接。
  • SQL 查询字符串：包含多个以分号 ; 分隔的 SQL 语句。

使用场景举例

以下场景适合使用 mysqli_multi_query()：

  1. 批量插入或更新：例如，同时插入多条用户数据并更新统计表。
  2. 依赖性操作：如创建表后立即插入默认数据。
  3. 减少网络开销：多个独立查询合并为一次数据库通信。

比喻：
可以将 mysqli_multi_query() 想象为“交通信号灯”。当多个车辆（SQL 语句）需要通过同一路口（数据库连接）时，它会按顺序管理这些车辆的通行，避免拥堵和重复等待。

参数详解与核心逻辑

参数分析

函数仅接受两个参数，但第二个参数通常不常用，因此主要关注第一个参数：

  • 第一个参数：数据库连接对象，确保连接有效且未关闭。
  • 第二个参数（可选）：用于存储扩展信息，但 PHP 官方文档未详细说明其用途，建议忽略。

执行流程解析

函数执行时，会按以下步骤处理 SQL 字符串：

  1. 解析查询：将 SQL 字符串按分号 ; 分割为独立语句。
  2. 逐句执行：依次执行每个查询，并返回第一个结果集。
  3. 后续结果处理：通过 mysqli_next_result() 获取后续结果集。

比喻：
这类似于“生产线上的工位”——每个 SQL 语句在独立工位上执行，而 mysqli_multi_query() 负责协调整个流程，确保每个步骤按顺序完成。

分步解析：从基础到进阶

第一步：建立数据库连接

// 建立连接  
$mysqli = new mysqli("localhost", "username", "password", "database");  
if ($mysqli->connect_error) {  
    die("连接失败: " . $mysqli->connect_error);  
}

第二步：编写多查询语句

// 合并插入和查询语句  
$sql = "  
    INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com');  
    SELECT * FROM users WHERE id = LAST_INSERT_ID();  
";

第三步：执行多查询并获取结果

// 执行多查询  
if ($mysqli->multi_query($sql)) {  
    // 处理第一个结果集（插入操作无返回，直接跳过）  
    $mysqli->next_result();  

    // 处理第二个结果集（查询新插入的用户）  
    $result = $mysqli->store_result();  
    if ($result->num_rows > 0) {  
        while ($row = $result->fetch_assoc()) {  
            print_r($row);  
        }  
    }  
    $result->free();  
} else {  
    echo "错误: " . $mysqli->error;  
}

实际案例：用户注册与日志记录

场景描述

用户注册时需完成以下操作：

  1. 插入用户数据到 users 表。
  2. 记录注册时间到 logs 表。
  3. 更新 stats 表中的注册总数。

实现代码

// 构建多查询语句  
$user_name = "Bob";  
$user_email = "bob@example.com";  
$timestamp = time();  

$sql = "  
    INSERT INTO users (name, email) VALUES ('$user_name', '$user_email');  
    INSERT INTO logs (user_id, action, time) VALUES (LAST_INSERT_ID(), '注册', $timestamp);  
    UPDATE stats SET total_users = total_users + 1;  
";  

// 执行并验证结果  
if ($mysqli->multi_query($sql)) {  
    echo "操作成功！";  
} else {  
    echo "错误: " . $mysqli->error;  
}

关键点说明

  • LAST_INSERT_ID()：获取上一条 INSERT 语句生成的自增 ID。
  • 顺序依赖：第二个查询依赖第一个的 id，因此必须按顺序执行。

注意事项与常见问题

1. 错误处理的复杂性

当多个查询中某个失败时，默认仅返回第一个错误。需逐个检查：

if ($mysqli->multi_query($sql)) {  
    do {  
        if ($result = $mysqli->store_result()) {  
            // 处理结果集  
            $result->free();  
        }  
    } while ($mysqli->more_results() && $mysqli->next_result());  
} else {  
    echo "第一个查询失败: " . $mysqli->error;  
}

2. SQL 注入风险

直接拼接用户输入可能导致注入攻击。建议使用预处理语句：

// 安全示例  
$stmt = $mysqli->prepare("  
    INSERT INTO users (name, email) VALUES (?, ?);  
    SELECT * FROM users WHERE id = LAST_INSERT_ID();  
");  
$stmt->bind_param("ss", $name, $email);  
$stmt->execute();

3. 查询分隔符的注意事项

  • 分号 ; 必须位于 SQL 语句末尾，且无尾随空格。
  • 避免在字符串中包含分号（如 INSERT INTO notes (content) VALUES ('Hello; World')），可用 mysqli_real_escape_string() 转义。

高级技巧与性能优化

1. 结合事务保证原子性

// 开启事务  
$mysqli->begin_transaction();  

// 执行多查询  
if ($mysqli->multi_query($sql)) {  
    // 全部成功则提交  
    $mysqli->commit();  
} else {  
    // 错误则回滚  
    $mysqli->rollback();  
}

2. 减少网络延迟

将多个独立查询合并为一条多查询语句，避免多次往返数据库。

3. 动态生成查询语句

通过循环构建 SQL 字符串：

$queries = [];  
foreach ($data as $row) {  
    $queries[] = "INSERT INTO table (col1, col2) VALUES ('" . $row['val1'] . "', '" . $row['val2'] . "')";  
}  
$full_sql = implode(";", $queries);

对比其他方法：逐个查询 vs. PDO 的多查询

逐个查询的缺点

// 需要多次调用 query()  
$mysqli->query("INSERT ...");  
$mysqli->query("SELECT ...");  
// 网络开销高，代码冗余

PDO 的多查询支持

PDO 通过 setAttribute(PDO::ATTR_EMULATE_PREPARES, true) 支持多查询，但可能因配置不同而失效，需谨慎使用。

结论

PHP mysqli_multi_query() 函数是一个强大且易用的工具，尤其在需要批量执行 SQL 语句时，能显著提升效率和代码的可维护性。通过合理设计查询顺序、结合事务保证数据一致性，并严格防范安全风险，开发者可以充分利用这一函数优化项目性能。

建议读者在实践中逐步尝试：

  1. 从简单查询开始，逐步增加复杂度。
  2. 使用日志记录调试多查询的执行过程。
  3. 结合预处理语句确保安全性。

掌握 mysqli_multi_query() 将为处理复杂数据库逻辑提供坚实基础，助您在 PHP 开发中更游刃有余。

最新发布

查看更多文章