PHP增删改查怎么实现批量插入

在PHP的增删改查开发中，批量插入是处理多数据入库场景的核心操作，相比单条循环插入，它能大幅减少数据库交互次数，提升写入效率。下面介绍几种常见的PHP批量插入实现方式。

单条循环插入的问题

很多新手会采用循环执行单条插入语句的方式处理批量数据，这种方式每插入一条数据就要和数据库进行一次交互，当数据量达到上百条时，性能会明显下降。示例代码如下：

<?php
$servername = "localhost";
$username = "root";
$password = "123456";
$dbname = "test_db";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检查连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

// 待插入的用户数据
$userList = [
    ['name' => '张三', 'age' => 20, 'email' => 'zhangsan@ipipp.com'],
    ['name' => '李四', 'age' => 22, 'email' => 'lisi@ipipp.com'],
    ['name' => '王五', 'age' => 25, 'email' => 'wangwu@ipipp.com']
];

// 单条循环插入
foreach ($userList as $user) {
    $sql = "INSERT INTO users (name, age, email) VALUES ('{$user['name']}', {$user['age']}, '{$user['email']}')";
    if ($conn->query($sql) === TRUE) {
        echo "插入成功<br>";
    } else {
        echo "插入失败: " . $conn->error . "<br>";
    }
}

$conn->close();
?>

拼接SQL语句实现批量插入

拼接一条包含多条数据值的插入SQL语句，是更高效的批量插入方式，只需要一次数据库交互就能完成所有数据写入。实现步骤如下：

• 准备待插入的数据数组
• 拼接SQL的VALUES部分，将多个数据值用逗号分隔
• 执行一次插入语句

示例代码如下：

<?php
$servername = "localhost";
$username = "root";
$password = "123456";
$dbname = "test_db";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检查连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

// 待插入的用户数据
$userList = [
    ['name' => '张三', 'age' => 20, 'email' => 'zhangsan@ipipp.com'],
    ['name' => '李四', 'age' => 22, 'email' => 'lisi@ipipp.com'],
    ['name' => '王五', 'age' => 25, 'email' => 'wangwu@ipipp.com']
];

// 拼接插入的字段部分
$sql = "INSERT INTO users (name, age, email) VALUES ";

// 拼接VALUES部分
$valueArr = [];
foreach ($userList as $user) {
    $valueArr[] = "('{$user['name']}', {$user['age']}, '{$user['email']}')";
}
$sql .= implode(',', $valueArr);

// 执行批量插入
if ($conn->query($sql) === TRUE) {
    echo "批量插入成功，共插入" . count($userList) . "条数据";
} else {
    echo "批量插入失败: " . $conn->error;
}

$conn->close();
?>

使用预处理语句实现批量插入

预处理语句可以有效防止SQL注入，同时配合批量绑定参数，也能实现高效的批量插入。示例代码如下：

<?php
$servername = "localhost";
$username = "root";
$password = "123456";
$dbname = "test_db";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检查连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

// 待插入的用户数据
$userList = [
    ['name' => '张三', 'age' => 20, 'email' => 'zhangsan@ipipp.com'],
    ['name' => '李四', 'age' => 22, 'email' => 'lisi@ipipp.com'],
    ['name' => '王五', 'age' => 25, 'email' => 'wangwu@ipipp.com']
];

// 准备预处理语句
$sql = "INSERT INTO users (name, age, email) VALUES (?, ?, ?)";
$stmt = $conn->prepare($sql);

if ($stmt) {
    // 绑定参数
    $stmt->bind_param("sis", $name, $age, $email);
    
    // 循环绑定数据并执行
    foreach ($userList as $user) {
        $name = $user['name'];
        $age = $user['age'];
        $email = $user['email'];
        $stmt->execute();
    }
    
    echo "预处理批量插入成功，共插入" . count($userList) . "条数据";
    $stmt->close();
} else {
    echo "预处理语句准备失败: " . $conn->error;
}

$conn->close();
?>

不同批量插入方式的效率对比

我们测试插入1000条数据时的耗时情况，结果如下：

批量插入的注意事项

• MySQL的max_allowed_packet参数限制了单条SQL语句的最大长度，拼接SQL批量插入时要注意数据量，避免超过该限制，可通过SHOW VARIABLES LIKE 'max_allowed_packet';查看当前配置。
• 如果批量插入的数据量极大，建议分批次插入，比如每500条执行一次插入操作，避免单次操作占用过多数据库资源。
• 插入前最好对数据进行合法性校验，避免无效数据导致整批插入失败。
• 事务可以配合批量插入使用，当某一批数据插入失败时，可回滚之前的操作，保证数据一致性。

分批次批量插入示例

当数据量超过数据库单条SQL限制时，分批次插入是更稳妥的方案，代码如下：

<?php
$servername = "localhost";
$username = "root";
$password = "123456";
$dbname = "test_db";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检查连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

// 模拟大量待插入数据
$totalCount = 2000;
$userList = [];
for ($i = 0; $i < $totalCount; $i++) {
    $userList[] = [
        'name' => '用户' . $i,
        'age' => rand(18, 60),
        'email' => 'user' . $i . '@ipipp.com'
    ];
}

// 每批次插入的数量
$batchSize = 500;
$currentIndex = 0;

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

try {
    while ($currentIndex < $totalCount) {
        // 截取当前批次的数据
        $batchData = array_slice($userList, $currentIndex, $batchSize);
        $currentIndex += $batchSize;
        
        // 拼接批次SQL
        $sql = "INSERT INTO users (name, age, email) VALUES ";
        $valueArr = [];
        foreach ($batchData as $user) {
            $valueArr[] = "('{$user['name']}', {$user['age']}, '{$user['email']}')";
        }
        $sql .= implode(',', $valueArr);
        
        // 执行批次插入
        if ($conn->query($sql) !== TRUE) {
            throw new Exception("批次插入失败: " . $conn->error);
        }
        echo "第" . ceil($currentIndex / $batchSize) . "批次插入完成，共" . count($batchData) . "条数据<br>";
    }
    // 提交事务
    $conn->commit();
    echo "所有数据插入完成，总计" . $totalCount . "条";
} catch (Exception $e) {
    // 回滚事务
    $conn->rollback();
    echo "插入失败，已回滚: " . $e->getMessage();
}

$conn->close();
?>

PHP批量插入增删改查MySQL修改时间：2026-06-28 07:54:39