php数据库如何使用事务 php数据库银行转账操作的实例

事务可确保数据库操作的原子性与一致性,PHP中通过PDO的beginTransaction()开启事务,执行SQL后若全部成功则commit()提交,任一步失败则rollback()回滚,如银行转账实例所示。

在PHP中操作数据库时,使用事务可以确保一组SQL操作要么全部成功,要么全部失败。这在银行转账这类对数据一致性要求极高的场景中非常关键。下面通过一个具体的银行账户转账实例来说明如何在PHP中使用数据库事务。

什么是事务?

事务是一组数据库操作的集合,具有ACID特性(原子性、一致性、隔离性、持久性)。这意味着:

  • 原子性:所有操作要么全部执行,要么全部不执行
  • 一致性:数据库始终从一个有效状态转移到另一个有效状态
  • 隔离性:并发事务之间互不影响
  • 持久性:一旦事务提交,结果是永久性的

开启事务的基本步骤

使用PDO进行数据库操作时,开启事务的流程如下:

  • 关闭自动提交模式:$pdo->beginTransaction()
  • 执行多个SQL语句
  • 全部成功则调用 $pdo->commit()
  • 任意一步失败则调用 $pdo->rollback() 回滚所有操作

银行转账代码实例

假设我们有两个用户账户表 accounts,包含字段 id、name、balance(余额)。

$dsn = "mysql:host=$host;dbname=$db;charset=$charset";
$options = [
PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES   => false,
];

try { $pdo = new PDO($dsn, $user, $pass, $options);

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

// 转出账户减钱(例如:用户A转出100元)
$sql1 = "UPDATE accounts SET balance = balance - 100 WHERE id = 1";
$stmt1 = $pdo->prepare($sql1);
$stmt1->execute();

// 检查是否更新成功
if ($stmt1->rowCount() == 0) {
    throw new Exception("转出账户操作失败,账户可能不存在");
}

// 转入账户加钱(用户B收到100元)
$sql2 = "UPDATE accounts SET balance = balance + 100 WHERE id = 2";
$stmt2 = $pdo->prepare($sql2);
$stmt2->execute();

if ($stmt2->rowCount() == 0) {
    throw new Exception("转入账户操作失败,账户可能不存在");
}

// 检查转入账户余额是否正常(可选校验)
$checkSql = "SELECT balance FROM accounts WHERE id = 2";
$checkStmt = $pdo->query($checkSql);
$result = $checkStmt->fetch();
if ($result['balance'] < 0) {
    throw new Exception("目标账户余额异常");
}

// 所有操作成功,提交事务
$pdo->commit();
echo "转账成功!";

} catch (Exception $e) { // 出现异常,回滚事务 $pdo->rollback(); echo "转账失败:" . $e->getMessage(); }

注意事项与最佳实践

在实际开发中需要注意以下几点:

  • 确保数据库引擎支持事务(如MySQL的InnoDB)
  • 开启事务后应尽快完成操作并提交或回滚,避免长时间锁定资源
  • 捕获异常并及时回滚,防止数据不一致
  • 可以在事务中加入日志记录,便于追踪问题
  • 对于高并发场景,考虑使用行锁或乐观锁机制

基本上就这些。只要合理使用事务,就能有效保证像银行转账这种关键业务的数据安全和一致性。