当前位置：首页 > PHP

php事务实现

2026-02-15 21:02:13PHP

PHP事务实现

在PHP中，事务通常用于确保数据库操作的原子性、一致性、隔离性和持久性（ACID）。以下是几种常见的实现方式：

使用PDO实现事务

PDO（PHP Data Objects）是PHP中用于数据库访问的轻量级接口，支持事务处理。

try {
    $pdo = new PDO("mysql:host=localhost;dbname=test", "username", "password");
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    $pdo->beginTransaction();

    $stmt1 = $pdo->prepare("UPDATE accounts SET balance = balance - :amount WHERE id = :id");
    $stmt1->execute(['amount' => 100, 'id' => 1]);

    $stmt2 = $pdo->prepare("UPDATE accounts SET balance = balance + :amount WHERE id = :id");
    $stmt2->execute(['amount' => 100, 'id' => 2]);

    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
    echo "Transaction failed: " . $e->getMessage();
}

使用MySQLi实现事务

MySQLi是PHP中专门用于MySQL数据库的扩展，也支持事务处理。

$mysqli = new mysqli("localhost", "username", "password", "test");

if ($mysqli->connect_error) {
    die("Connection failed: " . $mysqli->connect_error);
}

$mysqli->autocommit(FALSE);

try {
    $mysqli->query("UPDATE accounts SET balance = balance - 100 WHERE id = 1");
    $mysqli->query("UPDATE accounts SET balance = balance + 100 WHERE id = 2");

    $mysqli->commit();
} catch (Exception $e) {
    $mysqli->rollback();
    echo "Transaction failed: " . $e->getMessage();
}

$mysqli->close();

事务嵌套处理

某些数据库支持嵌套事务，可以通过保存点（savepoint）实现。

$pdo->beginTransaction();

try {
    $pdo->exec("INSERT INTO table1 (col1) VALUES ('value1')");

    $pdo->beginTransaction();
    try {
        $pdo->exec("INSERT INTO table2 (col2) VALUES ('value2')");
        $pdo->commit();
    } catch (Exception $e) {
        $pdo->rollBack();
        throw $e;
    }

    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
}

事务隔离级别设置

可以通过设置事务隔离级别来控制事务之间的可见性。

$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$pdo->exec("SET TRANSACTION ISOLATION LEVEL READ COMMITTED");
$pdo->beginTransaction();

分布式事务

对于跨数据库的事务，可以考虑使用XA协议或消息队列实现最终一致性。

php事务实现

// 示例：使用消息队列实现最终一致性
$db->beginTransaction();
try {
    $db->query("UPDATE inventory SET quantity = quantity - 1 WHERE product_id = 123");
    $queue->publish('order_created', ['product_id' => 123]);
    $db->commit();
} catch (Exception $e) {
    $db->rollBack();
}