当前位置： 技术文章>> PHP 中如何执行事务？

文章标题：PHP 中如何执行事务？
  • 文章分类: 后端
  • 8358 阅读

在PHP中执行数据库事务是确保数据完整性和一致性的关键步骤，特别是在处理复杂的数据操作，如转账、订单处理或任何需要多个步骤同时成功或同时失败的场景时。事务提供了一种机制，使得这些操作要么全部成功，要么在遇到任何错误时全部回滚到操作前的状态。在PHP中，通常通过使用支持事务的数据库（如MySQL的InnoDB存储引擎、PostgreSQL等）配合相应的数据库扩展（如PDO或mysqli）来实现事务管理。

1. 理解事务的四个基本属性（ACID）

在深入探讨如何在PHP中执行事务之前，了解事务的四个基本属性（ACID）是很重要的：

  • 原子性（Atomicity）：事务中的所有操作要么全部成功，要么全部失败，不会结束在中间某个环节。
  • 一致性（Consistency）：事务必须使数据库从一个一致性状态变换到另一个一致性状态。
  • 隔离性（Isolation）：并发执行的事务之间不会互相干扰，每个事务都像是独立运行一样。
  • 持久性（Durability）：一旦事务被提交，它对数据库的改变应该是永久的，即使系统发生故障也不应该丢失。

2. 使用PDO进行事务处理

PHP Data Objects (PDO) 提供了一个数据访问抽象层，这意味着，无论使用哪种数据库，你都可以通过统一的接口进行数据库操作。PDO支持事务处理，并且易于使用。

示例：使用PDO进行转账操作

假设你正在开发一个银行转账系统，需要从用户A的账户扣除一定金额，并将其添加到用户B的账户中。这是一个典型的需要事务处理的场景。

首先，确保你的数据库连接使用了支持事务的PDO驱动，并且数据库表使用了支持事务的存储引擎（如InnoDB）。

<?php
// 数据库连接参数
$dsn = 'mysql:host=localhost;dbname=bank_db;charset=utf8';
$username = 'your_username';
$password = 'your_password';

try {
    // 创建PDO实例
    $pdo = new PDO($dsn, $username, $password, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_AUTOCOMMIT => false // 关闭自动提交，开启事务
    ]);

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

    // 尝试从用户A的账户扣除金额
    $stmt = $pdo->prepare("UPDATE accounts SET balance = balance - ? WHERE user_id = ?");
    $stmt->execute([$amount, $userIdA]);

    // 检查上一个操作是否成功
    if (!$stmt) {
        throw new Exception("扣除用户A余额失败");
    }

    // 尝试给用户B的账户增加金额
    $stmt = $pdo->prepare("UPDATE accounts SET balance = balance + ? WHERE user_id = ?");
    $stmt->execute([$amount, $userIdB]);

    // 检查上一个操作是否成功
    if (!$stmt) {
        throw new Exception("给用户B增加余额失败");
    }

    // 如果没有抛出异常，则提交事务
    $pdo->commit();
    echo "转账成功！";
} catch (Exception $e) {
    // 如果发生异常，则回滚事务
    $pdo->rollBack();
    echo "转账失败：".$e->getMessage();
}

// 关闭PDO连接（可选，PHP脚本结束时通常会自动关闭）
$pdo = null;
?>

在上述示例中，我们首先关闭了PDO的自动提交功能，这允许我们手动控制事务的提交。通过beginTransaction()方法开始事务，然后执行两个SQL语句进行转账操作。如果在执行这些操作中的任何一个时发生了错误（这里通过检查$stmt是否为false来模拟），我们将抛出一个异常。如果整个过程中没有抛出异常，我们通过调用commit()方法来提交事务，否则调用rollBack()方法来回滚事务，以确保数据的一致性。

3. 使用mysqli进行事务处理

虽然PDO提供了跨数据库的抽象层，但如果你出于某种原因需要使用mysqli扩展，你也可以通过mysqli来实现事务处理。

示例：使用mysqli进行事务处理

<?php
// 数据库连接参数
$host = 'localhost';
$dbname = 'bank_db';
$username = 'your_username';
$password = 'your_password';

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

// 检查连接是否成功
if ($mysqli->connect_error) {
    die("连接失败: " . $mysqli->connect_error);
}

// 关闭自动提交，开启事务
$mysqli->autocommit(FALSE);

try {
    // 尝试从用户A的账户扣除金额
    $stmt = $mysqli->prepare("UPDATE accounts SET balance = balance - ? WHERE user_id = ?");
    $stmt->bind_param("di", $amount, $userIdA);
    $stmt->execute();

    // 检查上一个操作是否成功
    if ($stmt->affected_rows <= 0) {
        throw new Exception("扣除用户A余额失败");
    }

    // 尝试给用户B的账户增加金额
    $stmt->close();
    $stmt = $mysqli->prepare("UPDATE accounts SET balance = balance + ? WHERE user_id = ?");
    $stmt->bind_param("di", $amount, $userIdB);
    $stmt->execute();

    // 检查上一个操作是否成功
    if ($stmt->affected_rows <= 0) {
        throw new Exception("给用户B增加余额失败");
    }

    // 提交事务
    $mysqli->commit();
    echo "转账成功！";
} catch (Exception $e) {
    // 如果发生异常，则回滚事务
    $mysqli->rollback();
    echo "转账失败：".$e->getMessage();
}

// 关闭连接
$mysqli->close();
?>

在这个mysqli的示例中，我们使用autocommit(FALSE)来关闭自动提交，然后通过prepare()和execute()方法执行SQL语句。如果执行过程中遇到错误，我们同样会抛出异常，并在catch块中处理这些异常，包括回滚事务。

4. 总结

在PHP中执行事务处理是确保数据一致性和完整性的重要手段。通过使用PDO或mysqli扩展，我们可以很容易地在PHP脚本中开启、提交或回滚事务。无论选择哪种方法，关键在于理解事务的ACID属性，并在代码中正确地管理异常和事务的边界。通过合理使用事务，你可以构建更加健壮和可靠的数据库应用。

在码小课网站上，我们深入探讨了PHP中事务管理的各个方面，包括如何优化事务处理、处理并发冲突以及如何在不同的数据库环境中实施事务策略。这些资源将帮助你更好地理解如何在PHP项目中有效地应用事务管理。

推荐文章