php mysql实现行锁定

基础概念

行锁定（Row Locking）是数据库管理系统（DBMS）中的一种并发控制机制，用于确保多个事务在同时访问同一数据时不会发生冲突。在MySQL中，行锁定可以通过SELECT ... FOR UPDATE或SELECT ... LOCK IN SHARE MODE语句实现。

类型

共享锁（Shared Lock）：允许多个事务同时读取同一行数据，但阻止其他事务对该行进行修改。
排他锁（Exclusive Lock）：阻止其他事务读取或修改被锁定的行。

应用场景

行锁定通常用于以下场景：

金融交易：确保资金转移的原子性和一致性。
库存管理：防止库存数量在更新时出现负值。
订单处理：确保订单状态在处理过程中不被其他事务干扰。

示例代码

以下是一个使用PHP和MySQL实现行锁定的示例：

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";

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

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

// 开始事务
$conn->begin_transaction();

try {
    // 使用行锁定查询并更新数据
    $sql = "SELECT amount FROM accounts WHERE id = 1 FOR UPDATE";
    $result = $conn->query($sql);

    if ($result->num_rows > 0) {
        $row = $result->fetch_assoc();
        $new_amount = $row['amount'] - 100;

        $update_sql = "UPDATE accounts SET amount = $new_amount WHERE id = 1";
        if ($conn->query($update_sql) === TRUE) {
            echo "更新成功";
        } else {
            throw new Exception("更新失败: " . $conn->error);
        }
    }

    // 提交事务
    $conn->commit();
} catch (Exception $e) {
    // 回滚事务
    $conn->rollback();
    echo "事务回滚: " . $e->getMessage();
}

$conn->close();
?>