php中如何使用mysql事务功能

PHP中使用MySQL事务功能详解

在数据库操作中，事务（Transaction）是一个非常重要的概念，它能够确保一组数据库操作要么全部成功执行，要么全部回滚到初始状态，从而保证数据的一致性和完整性，在PHP中，我们可以通过MySQLi或PDO扩展来使用MySQL的事务功能,本文将详细介绍如何在PHP中使用MySQL事务。

事务的基本概念

事务具有四个基本特性（ACID）：

原子性（Atomicity）：事务是一个不可分割的工作单位，事务中的操作要么都发生,要么都不发生。
一致性（Consistency）：事务必须使数据库从一个一致性状态变换到另一个一致性状态。
隔离性（Isolation）：一个事务的执行不能被其他事务干扰。
持久性（Durability）：一个事务一旦被提交,它对数据库中数据的改变就是永久性的。

使用MySQLi扩展实现事务

MySQLi提供了面向对象和面向过程两种方式来操作数据库,下面以面向对象方式为例：

<?php
// 创建数据库连接
$mysqli = new mysqli("localhost", "username", "password", "database");
// 检查连接
if ($mysqli->connect_error) {
    die("连接失败: " . $mysqli->connect_error);
}
// 设置自动提交为false，开启事务
$mysqli->autocommit(false);
try {
    // 执行第一个SQL语句
    $sql1 = "INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')";
    if (!$mysqli->query($sql1)) {
        throw new Exception("第一个SQL语句执行失败: " . $mysqli->error);
    }
    // 执行第二个SQL语句
    $sql2 = "UPDATE accounts SET balance = balance - 100 WHERE user_id = 1";
    if (!$mysqli->query($sql2)) {
        throw new Exception("第二个SQL语句执行失败: " . $mysqli->error);
    }
    // 提交事务
    $mysqli->commit();
    echo "事务提交成功！";
} catch (Exception $e) {
    // 回滚事务
    $mysqli->rollback();
    echo "事务回滚: " . $e->getMessage();
}
// 关闭连接
$mysqli->close();
?>

使用PDO扩展实现事务

PDO（PHP Data Objects）是PHP中一个更现代、更灵活的数据库访问层，支持多种数据库,使用事务也非常方便：

<?php
// 创建PDO连接
try {
    $pdo = new PDO("mysql:host=localhost;dbname=database", "username", "password");
    // 设置错误模式为异常
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
    die("连接失败: " . $e->getMessage());
}
try {
    // 开始事务
    $pdo->beginTransaction();
    // 执行第一个SQL语句
    $stmt1 = $pdo->prepare("INSERT INTO orders (user_id, product_id, quantity) VALUES (?, ?, ?)");
    $stmt1->execute([1, 101, 2]);
    // 执行第二个SQL语句
    $stmt2 = $pdo->prepare("UPDATE products SET stock = stock - ? WHERE id = ?");
    $stmt2->execute([2, 101]);
    // 提交事务
    $pdo->commit();
    echo "事务提交成功！";
} catch (Exception $e) {
    // 回滚事务
    $pdo->rollBack();
    echo "事务回滚: " . $e->getMessage();
}
// 关闭连接（PDO连接会在脚本结束时自动关闭）
?>

事务的注意事项

自动提交模式：默认情况下，MySQL是自动提交模式（autocommit=1），即每条SQL语句都会作为一个独立的事务自动提交，要使用事务,必须先关闭自动提交模式。
错误处理：在事务中，应该对每个SQL操作进行错误检查,一旦发现错误立即抛出异常并回滚事务。
隔离级别：可以通过设置事务的隔离级别来控制并发事务之间的可见性，MySQL支持四种隔离级别：READ UNCOMMITTED、READ COMMITTED、REPEATABLE READ和SERIALIZABLE。
长事务的影响：长事务会锁定资源，影响数据库性能,应尽量缩短事务的持续时间。
嵌套事务：MySQL本身不支持嵌套事务，但可以通过保存点（SAVEPOINT）来实现类似的功能。

使用保存点实现部分回滚

在某些情况下，我们可能希望只回滚事务的一部分操作,这时可以使用保存点：

<?php
// PDO示例
$pdo->beginTransaction();
try {
    // 执行操作1
    $pdo->exec("INSERT INTO log (message) VALUES ('操作1')");
    // 设置保存点
    $pdo->exec("SAVEPOINT sp1");
    // 执行操作2
    $pdo->exec("INSERT INTO log (message) VALUES ('操作2')");
    // 假设操作3失败
    throw new Exception("操作3失败");
} catch (Exception $e) {
    // 回滚到保存点
    $pdo->exec("ROLLBACK TO SAVEPOINT sp1");
    echo "已回滚到保存点: " . $e->getMessage();
}
// 继续执行其他操作或提交
$pdo->commit();
?>

事务是保证数据库操作原子性和一致性的重要机制，在PHP中使用MySQL事务可以通过MySQLi或PDO扩展实现,关键步骤包括：