PHP和PDO: 如何执行批量插入和更新

<?php
// 数据库连接配置
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root';
$password = '';

try {
    // 创建PDO对象
    $pdo = new PDO($dsn, $username, $password);

    // 数据准备
    $data = [
        ['name' => '张三', 'age' => 20],
        ['name' => '李四', 'age' => 25],
        ['name' => '王五', 'age' => 30],
    ];

    // 开启事务
    $pdo->beginTransaction();

    // 预处理插入语句
    $stmt = $pdo->prepare('INSERT INTO users (name, age) VALUES (:name, :age)');

    // 执行批量插入
    foreach ($data as $item) {
        $stmt->bindValue(':name', $item['name']);
        $stmt->bindValue(':age', $item['age']);
        $stmt->execute();
    }

    // 提交事务
    $pdo->commit();

    echo "批量插入成功！";
} catch (PDOException $e) {
    // 回滚事务
    $pdo->rollBack();

    echo "插入失败：" . $e->getMessage();
}

<?php
// 数据库连接配置
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root';
$password = '';

try {
    // 创建PDO对象
    $pdo = new PDO($dsn, $username, $password);
  
    // 数据准备
    $data = [
        ['id' => 1, 'name' => '张三'],
        ['id' => 2, 'name' => '李四'],
        ['id' => 3, 'name' => '王五'],
    ];
  
    // 开启事务
    $pdo->beginTransaction();
  
    foreach ($data as $item) {
        // 预处理更新语句
        $stmt = $pdo->prepare('UPDATE users SET name = :name WHERE id = :id');
        $stmt->bindValue(':name', $item['name']);
        $stmt->bindValue(':id', $item['id']);
        $stmt->execute();
    }
  
    // 提交事务
    $pdo->commit();
  
    echo "批量更新成功！";
} catch (PDOException $e) {
    // 回滚事务
    $pdo->rollback();
  
    echo "更新失败：" . $e->getMessage();
}