PHP与MySQL数据库事务处理与锁机制详解

PHP与MySQL数据库事务处理与锁机制详解

在实际开发中，我们经常会遇到需要同时执行多个SQL操作的情况。比如转账业务，需要同时更新两个账户的余额。这时候如果某个操作失败，就会导致数据不一致。今天我就结合自己踩过的坑，跟大家详细聊聊PHP中如何使用MySQL的事务和锁机制来保证数据完整性。

一、什么是数据库事务

事务（Transaction）是一组要么全部成功，要么全部失败的SQL操作。它必须满足ACID特性：

• 原子性：事务中的所有操作要么全部完成，要么全部不完成
• 一致性：事务执行前后，数据库的完整性约束不被破坏
• 隔离性：并发事务之间互不干扰
• 持久性：事务完成后，对数据的修改是永久性的

二、PHP中实现事务处理

让我用一个实际的转账例子来演示：

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

try {
    // 扣除转出账户余额
    $sql1 = "UPDATE accounts SET balance = balance - 100 WHERE user_id = 1";
    $pdo->exec($sql1);
    
    // 增加转入账户余额
    $sql2 = "UPDATE accounts SET balance = balance + 100 WHERE user_id = 2";
    $pdo->exec($sql2);
    
    // 提交事务
    $pdo->commit();
    echo "转账成功！";
} catch (Exception $e) {
    // 回滚事务
    $pdo->rollBack();
    echo "转账失败：" . $e->getMessage();
}

踩坑提醒：一定要使用try-catch来捕获异常，否则事务无法正常回滚。我曾经就因为没有正确处理异常，导致数据出现不一致的情况。

三、MySQL锁机制详解

在高并发场景下，仅仅使用事务还不够。比如秒杀活动，多个用户同时购买同一商品，就可能出现超卖问题。这时候就需要用到锁机制。

四、悲观锁的实现

悲观锁认为数据在并发操作时一定会发生冲突，所以在操作前先加锁：

$pdo->beginTransaction();

try {
    // 使用SELECT ... FOR UPDATE加锁
    $stmt = $pdo->prepare("SELECT stock FROM products WHERE id = 1 FOR UPDATE");
    $stmt->execute();
    $product = $stmt->fetch();
    
    if ($product['stock'] > 0) {
        // 扣减库存
        $updateStmt = $pdo->prepare("UPDATE products SET stock = stock - 1 WHERE id = 1");
        $updateStmt->execute();
    }
    
    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
}

实战经验：FOR UPDATE会在事务提交或回滚后自动释放锁，但要注意锁的粒度，锁太多会影响性能。

五、乐观锁的实现

乐观锁认为冲突很少发生，通过版本号机制来实现：

// 先查询当前版本号
$stmt = $pdo->prepare("SELECT stock, version FROM products WHERE id = 1");
$stmt->execute();
$product = $stmt->fetch();

// 更新时检查版本号
$updateStmt = $pdo->prepare("
    UPDATE products 
    SET stock = stock - 1, version = version + 1 
    WHERE id = 1 AND version = :version
");

$updateStmt->execute([':version' => $product['version']]);

// 检查是否更新成功
if ($updateStmt->rowCount() === 0) {
    echo "更新失败，可能已被其他用户修改";
}

六、事务隔离级别

MySQL提供了4种事务隔离级别，我建议在大多数场景下使用REPEATABLE READ：

// 设置事务隔离级别
$pdo->exec("SET TRANSACTION ISOLATION LEVEL REPEATABLE READ");

七、总结与最佳实践

经过多年的项目实践，我总结出以下几点经验：

• 事务要尽量简短，长时间的事务会锁定资源
• 根据业务场景选择合适的锁机制
• 一定要处理异常，确保事务能够正确回滚
• 在高并发场景下，考虑使用乐观锁减少锁竞争

希望这篇文章能帮助大家更好地理解和使用MySQL的事务和锁机制。如果在实践中遇到问题，欢迎在评论区交流讨论！