foreach与MySQL事务处理结合

在PHP中，foreach循环和MySQL事务处理可以结合使用，以便在处理多个数据库操作时确保数据的一致性和完整性。事务处理是一种将多个数据库操作组合成一个单元的方法，这样可以确保所有操作都成功执行，否则回滚到事务开始之前的状态。

以下是一个使用foreach循环和MySQL事务处理的示例：

<?php
// 连接数据库
$conn = new mysqli('localhost', 'username', 'password', 'database');

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

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

try {
    // 需要执行的数据库操作数组
    $operations = [
        ['table' => 'table1', 'data' => ['column1' => 'value1', 'column2' => 'value2']],
        ['table' => 'table2', 'data' => ['column1' => 'value3', 'column2' => 'value4']],
    ];

    // 使用 foreach 循环遍历操作数组并执行
    foreach ($operations as $operation) {
        $table = $operation['table'];
        $data = $operation['data'];

        // 创建插入语句
        $columns = implode(', ', array_keys($data));
        $values = implode(', ', array_map(function ($value) use ($conn) {
            return "'" . $conn->real_escape_string($value) . "'";
        }, $data));

        $sql = "INSERT INTO $table ($columns) VALUES ($values)";

        // 执行插入操作
        if (!$conn->query($sql)) {
            throw new Exception("Error: " . $sql . "<br>" . $conn->error);
        }
    }

    // 提交事务
    $conn->commit();
    echo "All operations completed successfully!";
} catch (Exception $e) {
    // 发生错误，回滚事务
    $conn->rollback();
    echo "Error: " . $e->getMessage();
}

// 关闭数据库连接
$conn->close();
?>

在这个示例中，我们首先创建了一个包含多个数据库操作的数组。然后，我们使用foreach循环遍历这些操作，并在循环内部执行每个操作。如果所有操作都成功执行，我们将提交事务。如果在执行过程中发生任何错误，我们将回滚事务，以确保数据库保持在事务开始之前的状态。