数据库事务处理能确保一系列操作要么全部成功，要么全部回滚，防止数据不一致。PHP中通过PDO或MySQLi执行增删改查，推荐使用PDO因其支持多数据库、预处理防注入且更安全。
PHP代码与数据库的交互，说白了，就是通过特定的扩展（最常见的是PDO或MySQLi）建立连接，然后执行SQL语句进行数据的增删改查。而数据库事务处理，则是为了确保一系列相关的数据库操作要么全部成功，要么全部失败回滚，从而保证数据的完整性和一致性。它通过
beginTransaction()
开启事务，
commit()
提交所有更改，以及在发生错误时通过
rollBack()
撤销所有更改来实现。
解决方案
在PHP中操作数据库，我个人更倾向于使用PDO（PHP Data Objects）扩展，因为它提供了一个统一的接口来访问多种数据库，并且在安全性（如预处理语句）和错误处理方面表现出色。
要使用数据库，核心流程大致是这样：
建立数据库连接： 使用PDO的构造函数创建数据库连接实例。这通常需要数据库类型、主机、数据库名、用户名和密码。配置错误处理： 设置PDO的错误模式，比如
PDO::ERRMODE_EXCEPTION
，这样在SQL执行失败时会抛出异常，方便我们捕获和处理。执行SQL查询： 对于简单的查询，可以直接使用
query()
方法。但对于包含用户输入或可能被注入的查询，务必使用预处理语句（
prepare()
和
execute()
）。处理查询结果： 对于
SELECT
查询，通过
fetch()
、
fetchAll()
等方法获取结果集。对于
INSERT
、
UPDATE
、
DELETE
，通常关注受影响的行数。关闭连接（可选）： PHP脚本执行完毕后，连接会自动关闭。但如果你想提前释放资源，可以将PDO对象设置为
null
。
而事务处理，则是在这些基本操作之上，提供了一层数据完整性保障。当一系列操作必须作为一个不可分割的单元时，事务就显得尤为重要。
立即学习“PHP免费学习笔记（深入）”；
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置错误模式为抛出异常 $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); // 默认获取关联数组 // 开启事务 $pdo->beginTransaction(); // 假设这是一个转账操作：从用户A扣款，给用户B加款 // 操作1: 从用户A的账户扣除100 $stmt1 = $pdo->prepare("UPDATE accounts SET balance = balance - ? WHERE user_id = ? AND balance >= ?"); $stmt1->execute([100, 1, 100]); // 假设用户A的ID是1 if ($stmt1->rowCount() === 0) { // 如果扣款失败（比如余额不足），则回滚 throw new Exception("用户A余额不足或扣款失败。"); } // 模拟一个潜在的错误，比如网络延迟或数据库写入失败 // if (rand(0, 1) === 0) { // throw new Exception("模拟操作2失败。"); // } // 操作2: 给用户B的账户增加100 $stmt2 = $pdo->prepare("UPDATE accounts SET balance = balance + ? WHERE user_id = ?"); $stmt2->execute([100, 2]); // 假设用户B的ID是2 if ($stmt2->rowCount() === 0) { // 如果加款失败，也需要回滚 throw new Exception("用户B加款失败。"); } // 所有操作都成功，提交事务 $pdo->commit(); echo "转账成功！";} catch (PDOException $e) { // 数据库操作异常，回滚事务 if ($pdo->inTransaction()) { $pdo->rollBack(); } echo "数据库操作失败: " . $e->getMessage(); // 实际应用中，这里应该记录日志} catch (Exception $e) { // 其他业务逻辑异常，回滚事务 if ($pdo->inTransaction()) { $pdo->rollBack(); } echo "业务逻辑失败: " . $e->getMessage(); // 实际应用中，这里也应该记录日志} finally { // 无论成功失败，确保连接关闭（可选，PHP脚本结束会自动关闭） $pdo = null;}?>
为什么需要数据库事务处理？它能解决哪些实际问题？
在我看来，数据库事务处理是保证数据“靠谱”的核心机制之一。想象一下，如果你的系统在处理一个银行转账业务，从A账户扣钱，再给B账户加钱。如果没有事务，万一A账户扣款成功了，但给B账户加钱的时候，系统突然崩溃了、网络断了、或者数据库报错了，那钱就凭空消失了！A的钱少了，B的钱没多，这显然是灾难性的。
事务的出现，就是为了解决这种“部分成功”带来的数据不一致问题。它遵循ACID原则（原子性、一致性、隔离性、持久性），确保：
原子性（Atomicity）： 事务是一个不可分割的整体，要么全部完成，要么全部不完成。就像上面转账的例子，扣款和加款必须同时成功或同时失败。一致性（Consistency）： 事务执行前后，数据库从一个有效状态转换到另一个有效状态。比如账户余额不能是负数，事务必须维护这些业务规则。隔离性（Isolation）： 多个事务并发执行时，一个事务的执行不应该影响其他事务。每个事务都感觉自己是唯一在操作数据库的。持久性（Durability）： 事务一旦提交，其所做的更改就是永久性的，即使系统崩溃也不会丢失。
实际应用中，除了转账，订单创建（需要同时扣库存、生成订单记录、更新用户积分等）、复杂的数据迁移、或者任何涉及多个相互依赖的数据库操作的场景，都需要事务来保障数据的完整性。没有它，你的系统数据就很容易“乱套”，导致各种难以追踪的bug和业务损失。
PHP中如何实现数据库连接与基本操作？PDO和MySQLi哪个更好？
在PHP中实现数据库连接和基本操作，主要有两种主流方式：PDO（PHP Data Objects）和MySQLi扩展。它们都能很好地完成任务，但在现代Web开发中，我个人更推荐使用PDO。
PDO (PHP Data Objects)
PDO提供了一个轻量级的、一致的接口来访问多种数据库。这意味着，如果你未来需要从MySQL切换到PostgreSQL或SQLite，你的大部分数据库操作代码都不需要大改，只需要修改连接字符串。
连接： 使用
new PDO($dsn, $username, $password)
构造函数。
$dsn
是关键，它定义了数据库类型、主机、数据库名等信息。基本操作：查询（SELECT）： 使用
prepare()
创建预处理语句，
execute()
执行，然后用
fetch()
或
fetchAll()
获取结果。插入/更新/删除（INSERT/UPDATE/DELETE）： 同样使用
prepare()
和
execute()
，然后通过
rowCount()
获取受影响的行数。优势：多数据库支持： 兼容性强，代码可移植性好。预处理语句： 内置支持预处理语句，这是防止SQL注入的最佳实践。它将SQL逻辑和数据分离，数据库在执行前会编译SQL模板，然后将数据作为参数绑定，从而避免恶意代码被当作SQL执行。统一的错误处理： 可以设置统一的错误模式，通过异常来捕获和处理数据库错误。面向对象： 设计更现代化，更符合OO编程范式。
MySQLi (MySQL Improved Extension)
MySQLi是专门为MySQL数据库设计的扩展，它提供了面向对象和面向过程两种接口。
连接： 可以使用面向对象的
new mysqli($host, $user, $pass, $db)
或面向过程的
mysqli_connect()
。基本操作： 同样支持预处理语句，例如
prepare()
和
bind_param()
。优势：MySQL特有功能： 如果你确定只用MySQL，MySQLi可能会提供一些PDO没有的MySQL特有功能（虽然这在大多数应用中不常见）。性能： 在某些特定场景下，理论上MySQLi可能会比PDO稍快一点点，但这种差异在实际应用中通常微乎其微，可以忽略不计。
哪个更好？
对于现代PHP开发，我强烈建议使用PDO。它的跨数据库兼容性、强大的预处理语句支持（有效防止SQL注入）、以及更优雅的面向对象设计，使其成为更安全、更灵活、更易维护的选择。除非你有非常特殊的需求，并且确定你的项目永远不会离开MySQL，否则PDO是更“通用”和“未来友好”的方案。
这里是一个使用PDO进行连接和基本查询的示例：
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 抛出异常 $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); // 默认关联数组 // 插入数据 $name = 'Alice'; $email = 'alice@example.com'; $stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (?, ?)"); $stmt->execute([$name, $email]); echo "用户 " . $name . " 插入成功，ID为: " . $pdo->lastInsertId() . "
"; // 查询数据 $userId = 1; // 假设要查询ID为1的用户 $stmt = $pdo->prepare("SELECT id, name, email FROM users WHERE id = ?"); $stmt->execute([$userId]); $user = $stmt->fetch(); // 获取一行数据 if ($user) { echo "查询到用户: ID=" . $user['id'] . ", 姓名=" . $user['name'] . ", 邮箱=" . $user['email'] . "
"; } else { echo "未找到ID为 " . $userId . " 的用户。
"; } // 更新数据 $newName = 'Alicia'; $updateId = 1; $stmt = $pdo->prepare("UPDATE users SET name = ? WHERE id = ?"); $stmt->execute([$newName, $updateId]); echo "更新了 " . $stmt->rowCount() . " 行数据。
";} catch (PDOException $e) { echo "数据库操作失败: " . $e->getMessage();} finally { $pdo = null; // 关闭连接}?>
PHP数据库事务处理的具体步骤与错误处理机制是怎样的？
PHP中进行数据库事务处理，核心在于围绕
beginTransaction()
、
commit()
和
rollBack()
这三个方法构建你的代码逻辑，并且结合异常处理机制来确保在任何环节出错时都能正确回滚。这套流程能让你的数据操作更加健壮。
具体步骤：
建立PDO连接并设置错误模式： 这是所有数据库操作的基础。务必将错误模式设置为
PDO::ERRMODE_EXCEPTION
，这样当SQL执行失败时，PDO会抛出一个
PDOException
，我们就可以通过
try-catch
块来捕获它。
$pdo = new PDO($dsn, $username, $password);$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
开启事务： 在你开始执行一系列需要原子性保证的数据库操作之前，调用
beginTransaction()
方法。这会告诉数据库，接下来的所有操作都是一个事务的一部分，在
commit()
之前，它们对其他连接是不可见的（取决于隔离级别），并且可以被撤销。
$pdo->beginTransaction();
执行一系列数据库操作： 在
beginTransaction()
之后，你可以执行任意数量的
INSERT
、
UPDATE
、
DELETE
等操作。这些操作都会被临时存储，但尚未永久写入数据库。
// 操作1$stmt1 = $pdo->prepare("UPDATE accounts SET balance = balance - ? WHERE user_id = ?");$stmt1->execute([100, $senderId]);// 操作2$stmt2 = $pdo->prepare("UPDATE accounts SET balance = balance + ? WHERE user_id = ?");$stmt2->execute([100, $receiverId]);
提交事务： 如果所有操作都成功完成，没有抛出任何异常，那么你就应该调用
commit()
方法。这会将之前所有临时性的更改永久性地写入数据库。
$pdo->commit();
回滚事务（错误处理机制）： 这是事务处理的关键。如果在这个事务的任何一个操作中发生了错误（无论是数据库层面抛出的
PDOException
，还是你自定义的业务逻辑异常），你都应该捕获这个异常，并且调用
rollBack()
方法。
rollBack()
会撤销自
beginTransaction()
以来所有未提交的更改，将数据库恢复到事务开始前的状态。
try { $pdo->beginTransaction(); // ... 执行一系列操作 ... $pdo->commit();} catch (Throwable $e) { // 捕获所有Error和Exception if ($pdo->inTransaction()) { // 确保当前有事务在进行中，避免重复回滚或对未开始事务回滚 $pdo->rollBack(); } // 处理错误，比如记录日志，给用户友好提示 echo "操作失败: " . $e->getMessage();}
这里使用
Throwable
是为了捕获PHP 7+中的
Error
和
Exception
，提供更全面的错误覆盖。
需要注意的几点：
inTransaction()
检查： 在调用
rollBack()
之前，最好先用
$pdo->inTransaction()
检查一下当前是否真的处于事务中。这可以避免在没有事务时尝试回滚而导致的错误。业务逻辑错误： 除了数据库层面的错误，你的业务逻辑也可能出现问题（例如，转账时发现余额不足）。在这种情况下，你也应该手动抛出异常，让
catch
块捕获并触发回滚。资源清理： 即使事务失败，也要确保你的PDO连接对象最终被清理（例如在
finally
块中将
$pdo = null;
）。隔离级别： 了解数据库的事务隔离级别也很重要，它决定了并发事务之间相互影响的程度。默认的隔离级别通常能满足大部分需求，但对于高并发或特定业务场景，可能需要调整。死锁： 在高并发的事务处理中，可能会遇到死锁问题。当两个或多个事务互相等待对方释放资源时，就会发生死锁。数据库通常会自动检测并解除死锁（通常是回滚其中一个事务），但你的应用需要能够处理这种回滚并可能重试操作。
通过以上步骤和错误处理机制，你可以构建出稳定可靠的PHP数据库事务处理逻辑，大大提升你应用的数据完整性和健壮性。
以上就是PHP代码怎么使用数据库_ PHP数据库事务处理与回滚指南的详细内容，更多请关注php中文网其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1320858.html
微信扫一扫 
支付宝扫一扫 
