简介：在本教程中，您将学习如何在PHP中处理MySQL事务以确保数据库的数据完整性。

事务是一组相互依赖的SQL语句，需要以全有或全无模式执行。
如果所有SQL语句成功执行，则事务成功。
任何语句失败都会触发系统回滚到原始状态，以避免数据不一致。

交易的经典示例是从一个银行帐户到另一个银行帐户的汇款交易。
它需要三个步骤：

• 检查已转帐帐户的余额，以查看该金额是否足以进行转帐。

• 如果金额足够，请从转帐的余额中扣除该金额。

• 将转帐金额添加到收款帐户的余额中。

如果第二步出错，则第三步不应继续。
另外，如果在第三步中发生错误，则第二步必须逆转。
如果发生故障，两个银行帐户的金额均保持不变，或者如果交易成功完成，则可以正确调整。

PHP中的MySQL事务

当您使用PDO创建与支持事务的数据库的连接时，将设置自动提交模式。
这意味着您发出的每个查询都包装在一个隐式事务中。

请注意，并非MySQL中的所有存储引擎都支持事务，例如MyISAM不支持事务，但是InnoDB支持。

要在PHP中处理MySQL事务，请使用以下步骤：

• 通过调用PDO对象的beginTransaction()方法来启动事务。

• 将SQL语句和commit()方法调用放在try块中。

• 通过调用PDO对象的rollBack()方法在catch块中回滚事务。

PHP MySQL交易示例

我们将创建一个名为accounts的表，以演示两个银行帐户之间的资金转移。

首先，执行以下语句创建accounts表：

CREATE TABLE accounts (
    id     INT AUTO_INCREMENT PRIMARY KEY,
    name   VARCHAR (50)    NOT NULL,
    amount DECIMAL (19, 4) NOT NULL
);

第二，在accounts表中插入两行：

INSERT INTO accounts(name,amount)
VALUES('John',25000),
      ('Mary',95000);

三，查询账户表：

SELECT *
  FROM accounts;

让我们看一下下面的TransactionDemo类：

<?php

/**
 * PHP MySQL Transaction Demo
 */
class TransactionDemo {

    const DB_HOST = 'localhost';
    const DB_NAME = 'classicmodels';
    const DB_USER = 'root';
    const DB_PASSWORD = '';

    /**
     * Open the database connection
     */
    public function __construct() {
        // open database connection
        $conStr = sprintf("mysql:host=%s;dbname=%s", self::DB_HOST, self::DB_NAME);
        try {
            $this->pdo = new PDO($conStr, self::DB_USER, self::DB_PASSWORD);
        } catch (PDOException $e) {
            die($e->getMessage());
        }
    }

    /**
     * PDO instance
     * @var PDO 
     */
    private $pdo = null;

    /**
     * Transfer money between two accounts
     * @param int $from
     * @param int $to
     * @param float $amount
     * @return true on success or false on failure.
     */
    public function transfer($from, $to, $amount) {

        try {
            $this->pdo->beginTransaction();

            // get available amount of the transferer account
            $sql = 'SELECT amount FROM accounts WHERE id=:from';
            $stmt = $this->pdo->prepare($sql);
            $stmt->execute(array(":from" => $from));
            $availableAmount = (int) $stmt->fetchColumn();
            $stmt->closeCursor();

            if ($availableAmount < $amount) {
                echo 'Insufficient amount to transfer';
                return false;
            }
            // deduct from the transferred account
            $sql_update_from = 'UPDATE accounts
				SET amount = amount - :amount
				WHERE id = :from';
            $stmt = $this->pdo->prepare($sql_update_from);
            $stmt->execute(array(":from" => $from, ":amount" => $amount));
            $stmt->closeCursor();

            // add to the receiving account
            $sql_update_to = 'UPDATE accounts
                                SET amount = amount + :amount
                                WHERE id = :to';
            $stmt = $this->pdo->prepare($sql_update_to);
            $stmt->execute(array(":to" => $to, ":amount" => $amount));

            // commit the transaction
            $this->pdo->commit();

            echo 'The amount has been transferred successfully';

            return true;
        } catch (PDOException $e) {
            $this->pdo->rollBack();
            die($e->getMessage());
        }
    }

    /**
     * close the database connection
     */
    public function __destruct() {
        // close the database connection
        $this->pdo = null;
    }

}

// test the transfer method
$obj = new TransactionDemo();

// transfer 30K from from account 1 to 2
$obj->transfer(1, 2, 30000);

// transfer 5K from from account 1 to 2
$obj->transfer(1, 2, 5000);

我们使用__construct()方法打开数据库连接，并使用__destruct()方法关闭数据库连接。
在transfer()方法中：

• 首先，我们查询转帐帐户的金额并将其与转帐金额进行比较，以检查转帐帐户的余额是否足够。

• 其次，在金额足够的情况下，我们从已转帐帐户中扣除转帐金额，并将其添加到接收帐户中。

• 第三，我们通过调用commit()方法来提交事务。
  如果发生任何错误，我们在catch块中调用rollBack()方法以回滚事务。

让我们测试transfer()方法。

// transfer 30K from from account 1 to 2
$obj->transfer(1, 2, 30000);

我们从John的帐户中将3万转移到了Mary的帐户中。
我们收到以下消息：

Insufficient amount to transfer

再进行一次转移：

// transfer 5K from from account 1 to 2
$obj->transfer(1, 2, 5000);

该脚本返回以下消息：

The amount has been transferred successfully.

我们已成功在两个银行帐户之间转帐。

您可以通过以下链接下载源代码：

下载PHP MySQL事务源代码

在本教程中，我们逐步向您展示了如何在PHP中处理MySQL事务以确保数据完整性。