PHP Mysql - 创建自己的银行系统

Question

我正在开发一个项目，用户将用真钱购买“硬币”。他们还可以在交易系统中以真实货币出售这些代币。他们甚至可以向其他用户发送硬币。这将用 PHP 编写。我了解 mysql 交易，但我不能 100% 确定这需要 100% 来自并发错误。我创建了伪代码，我认为其中存在缺陷。

    function withdraw($id, $amount_to_withdraw) {
       $ret = false;
       $balance = $db->getBalanceById($id);

       $this->makeSureAmountIsNotNegative($amount_to_withdraw);

       $new_balance = $balance - $amount_to_withdraw;

       if ($new_balance >= 0.00) {
        try {
             $db->startTransaction();

            // THIS IS WHERE THE FLAW IS!!!
            $db->do("UPDATE account SET balance = ? WHERE id = ?", array($new_balance, $id));

            $db->commit();

            $ret = true;
        } catch (Exception $e) {
            $db->rollback();
        }
    }

    return $ret;
}

根据我的理解，在 PHP 中，在完全完成之前执行另一个请求是可能的，并且可能将余额设置为低于零和其他不良并发错误。 我该如何编写这段代码才能避免这些错误。 我是否需要行级 mysql 锁定，例如:

// ROW LEVEL LOCKING FOR UPDATE
$balance = $db->select("SELECT balance FROM account WHERE id = ? FOR UPDATE;", array($id));

谢谢 布赖恩

Answer 1

您需要将获取旧余额的查询和设置新余额的查询放在同一事务中。所以你需要输入$db->startTransaction()之前$db->getBalance($id); ，并将所有这些放入 try 中 block 。

function withdraw($id, $amount_to_withdraw) {
    $ret = false;

    try {
        $db->startTransaction();

        $balance = $db->getBalanceById($id);

        $this->makeSureAmountIsNotNegative($amount_to_withdraw);

        $new_balance = $balance - $amount_to_withdraw;

        if ($new_balance >= 0.00) {
            $db->do("UPDATE account SET balance = ? WHERE id = ?", array($new_balance, $id));

            $ret = true;
        }
        $db->commit();

    } catch (Exception $e) {
        $db->rollback();
    }

    return $ret;
}

但更简单的方法是在 UPDATE 中进行减法查询，而不是执行两次查询。

$db->do("UPDATE account SET balance = balance - ? 
        WHERE id = ? AND balance >= ?", array($amount_to_withdraw, $id, $amount_to_withdraw));

您不需要为此显式创建事务，因为语句始终是其自己的事务。