MySQL事务如何在PHP中使用：PHP处理MySQL事务的完整指南
在数据库驱动的Web应用中，确保数据的一致性和完整性是至关重要的。MySQL事务提供了一种机制，将多个数据库操作捆绑成一个单一的逻辑单元，要么全部成功，要么全部失败。本文将详细介绍如何在PHP中高效、安全地使用MySQL事务。
一、MySQL事务基础概念
事务是数据库管理系统执行过程中的一个逻辑单位，由一个有限的数据库操作序列构成。它必须满足ACID属性：
原子性（Atomicity）：事务中的所有操作要么全部完成，要么全部不完成。
一致性（Consistency）：事务必须使数据库从一个一致性状态变换到另一个一致性状态。
隔离性（Isolation）：多个事务并发执行时，一个事务的执行不应影响其他事务。
持久性（Durability）：一旦事务被提交，它对数据库的改变就是永久性的。
在MySQL中，并非所有存储引擎都支持事务。最常用的支持事务的引擎是InnoDB。因此，在创建表时，应确保使用正确的存储引擎。
二、PHP中MySQL事务的基本流程
在PHP中处理MySQL事务，通常遵循以下四个步骤：
开启事务
执行一系列SQL语句
判断执行结果，决定提交或回滚
提交事务（成功时）或回滚事务（失败时）
三、使用MySQLi扩展处理事务
MySQLi（MySQL improved）扩展提供了面向对象和面向过程两种方式来操作数据库。以下是两种方式的示例。
1. 面向对象方式
<?php
$servername = "localhost";
$username = "your_username";
$password = "your_password";
$dbname = "your_database";
// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);
// 检查连接
if ($conn->connect_error) {
die("连接失败: " . $conn->connect_error);
}
// 关闭自动提交，开启事务
$conn->autocommit(FALSE);
try {
// 执行第一个SQL操作：从账户A扣款
$sql1 = "UPDATE bank_accounts SET balance = balance - 100 WHERE account_id = 1";
if (!$conn->query($sql1)) {
throw new Exception("扣款失败: " . $conn->error);
}
// 执行第二个SQL操作：向账户B存款
$sql2 = "UPDATE bank_accounts SET balance = balance + 100 WHERE account_id = 2";
if (!$conn->query($sql2)) {
throw new Exception("存款失败: " . $conn->error);
}
// 如果所有操作都成功，提交事务
$conn->commit();
echo "转账事务成功提交！";
} catch (Exception $e) {
// 如果任何操作失败，回滚事务
$conn->rollback();
echo "事务失败，已回滚。错误信息: " . $e->getMessage();
}
// 恢复自动提交模式（可选）
$conn->autocommit(TRUE);
$conn->close();
?>2. 面向过程方式
<?php
$link = mysqli_connect("localhost", "your_username", "your_password", "your_database");
if (!$link) {
die("连接失败: " . mysqli_connect_error());
}
// 关闭自动提交，开启事务
mysqli_autocommit($link, FALSE);
$error_flag = false;
// 执行第一个SQL操作
$sql1 = "UPDATE products SET stock = stock - 5 WHERE id = 101";
if (!mysqli_query($link, $sql1)) {
$error_flag = true;
echo "更新库存错误: " . mysqli_error($link);
}
// 执行第二个SQL操作
$sql2 = "INSERT INTO orders (product_id, quantity) VALUES (101, 5)";
if (!mysqli_query($link, $sql2)) {
$error_flag = true;
echo "创建订单错误: " . mysqli_error($link);
}
// 根据标志位决定提交或回滚
if ($error_flag) {
mysqli_rollback($link);
echo "所有操作已回滚。";
} else {
mysqli_commit($link);
echo "订单事务成功完成。";
}
// 恢复自动提交
mysqli_autocommit($link, TRUE);
mysqli_close($link);
?>四、使用PDO扩展处理事务
PDO（PHP Data Objects）提供了一个数据访问抽象层，能使用相同的方法操作不同的数据库。PDO处理事务的代码更加简洁。
<?php
$host = 'localhost';
$db = 'your_database';
$user = 'your_username';
$pass = 'your_password';
$charset = 'utf8mb4';
$dsn = "mysql:host=$host;dbname=$db;charset=$charset";
$options = [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES => false,
];
try {
$pdo = new PDO($dsn, $user, $pass, $options);
} catch (PDOException $e) {
throw new PDOException($e->getMessage(), (int)$e->getCode());
}
try {
// 开启事务
$pdo->beginTransaction();
// 准备并执行第一个语句
$stmt1 = $pdo->prepare("INSERT INTO users (username, email) VALUES (?, ?)");
$stmt1->execute(['john_doe', 'john@example.com']);
$new_user_id = $pdo->lastInsertId();
// 准备并执行第二个语句，依赖于第一个操作的结果
$stmt2 = $pdo->prepare("INSERT INTO user_profiles (user_id, full_name) VALUES (?, ?)");
$stmt2->execute([$new_user_id, 'John Doe']);
// 提交事务
$pdo->commit();
echo "用户及其档案创建成功！";
} catch (Exception $e) {
// 发生异常，回滚事务
$pdo->rollBack();
echo "事务失败，已回滚。错误: " . $e->getMessage();
}
?>PDO的ERRMODE_EXCEPTION模式使得错误处理更加优雅，任何SQL错误都会抛出异常，从而可以轻松地在catch块中触发回滚。
五、事务隔离级别与设置
MySQL支持不同的事务隔离级别，以平衡数据一致性和并发性能。你可以在PHP连接后设置它。
<?php
// 使用MySQLi设置隔离级别为 READ COMMITTED
$conn = new mysqli(...);
$conn->query("SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED");
// 使用PDO设置隔离级别为 REPEATABLE READ（默认级别）
$pdo = new PDO(...);
$pdo->exec("SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ");
?>常见的隔离级别有：READ UNCOMMITTED、READ COMMITTED、REPEATABLE READ（MySQL InnoDB默认级别）和SERIALIZABLE。
六、保存点（SAVEPOINT）
对于复杂的事务，你可以设置保存点，以便回滚到事务中的特定点，而不是回滚整个事务。
<?php
$pdo->beginTransaction();
try {
$pdo->exec("UPDATE accounts SET balance = balance - 200 WHERE id = 1");
// 设置一个保存点
$pdo->exec("SAVEPOINT point_after_withdraw");
$pdo->exec("UPDATE accounts SET balance = balance + 200 WHERE id = 2");
// 假设这里有一个条件检查，如果失败则回滚到保存点
if ($some_condition_failed) {
$pdo->exec("ROLLBACK TO SAVEPOINT point_after_withdraw");
// 可以在这里执行其他操作，然后提交部分结果
}
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
}
?>七、最佳实践与常见陷阱
最佳实践：
保持事务短小：尽量减少事务的执行时间，以降低锁竞争和死锁风险。
始终处理异常：使用
try...catch块确保在错误发生时能够回滚。明确指定存储引擎：创建表时使用
ENGINE=InnoDB以确保事务支持。选择正确的隔离级别：根据应用需求选择最低的、能满足一致性的隔离级别。
常见陷阱：
忘记关闭自动提交：在开启事务前，必须将自动提交设置为
FALSE（MySQLi）或调用beginTransaction()（PDO）。在事务中执行DDL语句：执行如
CREATE TABLE或ALTER TABLE等DDL语句会导致隐式提交，破坏事务原子性。未正确处理连接错误：在事务过程中，如果数据库连接断开，需要有针对性的重连和状态恢复机制。
八、总结
在PHP中处理MySQL事务是构建健壮、可靠应用的关键技能。无论是选择MySQLi还是PDO，核心原则都是：开启事务、执行操作、检查结果、提交或回滚。通过理解ACID属性、合理设置隔离级别、并遵循最佳实践，开发者可以有效地利用事务来保障复杂业务逻辑下的数据完整性与一致性。建议在新项目中优先考虑使用PDO，因为它提供了更统一的API和更优的异常处理机制。