如何用PDO::beginTransaction结合PDO::rollBack实现事务回滚操作？

gitbox 2025-08-11

在数据库操作中，事务管理是一个非常重要的概念，它保证了数据操作的原子性、一致性、隔离性和持久性（即ACID特性）。在PHP中，我们可以使用PDO（PHP Data Objects）来与数据库进行交互，而事务管理则可以通过PDO提供的beginTransaction()、commit()和rollBack()方法来实现。本文将详细介绍如何使用PDO的beginTransaction结合rollBack来实现事务回滚操作。

1. 什么是事务？

事务（Transaction）是指一组操作的集合，这些操作要么全部成功，要么全部失败。事务确保了数据库操作的一致性和完整性。在数据库系统中，事务的基本特性可以通过ACID来描述：

原子性（Atomicity）：事务中的所有操作要么全部完成，要么全部不做。
一致性（Consistency）：事务的执行会使数据库从一个一致性状态转变到另一个一致性状态。
隔离性（Isolation）：多个事务并发执行时，一个事务的执行不应受其他事务的干扰。
持久性（Durability）：一旦事务提交，对数据库的更改就会永久保存。

2. 事务的基本操作

在PDO中，事务的基本操作包括：

beginTransaction()：开始事务。
commit()：提交事务。
rollBack()：回滚事务。

通常，在数据库操作过程中，如果某个步骤出错，可以使用rollBack()方法回滚事务，撤销之前的所有操作。

3. 使用beginTransaction()和rollBack()的示例

假设我们需要执行多个数据库操作，如插入记录、更新记录等。如果其中一个操作失败，我们希望能够撤销之前的所有操作，以确保数据库的一致性。这时，我们就可以使用beginTransaction()和rollBack()方法。

<span><span><span class="hljs-meta">&lt;?php</span></span><span>
</span><span><span class="hljs-keyword">try</span></span><span> {
    </span><span><span class="hljs-comment">// 创建PDO连接</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span> = </span><span><span class="hljs-keyword">new</span></span><span> </span><span><span class="hljs-title function_ invoke__">PDO</span></span><span>(</span><span><span class="hljs-string">'mysql:host=localhost;dbname=testdb'</span></span><span>, </span><span><span class="hljs-string">'username'</span></span><span>, </span><span><span class="hljs-string">'password'</span></span><span>);
    </span><span><span class="hljs-comment">// 设置错误模式为异常</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">setAttribute</span></span><span>(PDO::</span><span><span class="hljs-variable constant_">ATTR_ERRMODE</span></span><span>, PDO::</span><span><span class="hljs-variable constant_">ERRMODE_EXCEPTION</span></span><span>);

    </span><span><span class="hljs-comment">// 开始事务</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">beginTransaction</span></span><span>();

    </span><span><span class="hljs-comment">// 执行第一个SQL操作</span></span><span>
    </span><span><span class="hljs-variable">$sql1</span></span><span> = </span><span><span class="hljs-string">"INSERT INTO users (username, email) VALUES ('john_doe', '[email protected]')"</span></span><span>;
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">exec</span></span><span>(</span><span><span class="hljs-variable">$sql1</span></span><span>);

    </span><span><span class="hljs-comment">// 执行第二个SQL操作</span></span><span>
    </span><span><span class="hljs-variable">$sql2</span></span><span> = </span><span><span class="hljs-string">"UPDATE accounts SET balance = balance - 100 WHERE username = 'john_doe'"</span></span><span>;
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">exec</span></span><span>(</span><span><span class="hljs-variable">$sql2</span></span><span>);

    </span><span><span class="hljs-comment">// 如果一切正常，提交事务</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">commit</span></span><span>();
    </span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"事务提交成功！"</span></span><span>;

} </span><span><span class="hljs-keyword">catch</span></span><span> (</span><span><span class="hljs-built_in">Exception</span></span><span> </span><span><span class="hljs-variable">$e</span></span><span>) {
    </span><span><span class="hljs-comment">// 如果发生错误，回滚事务</span></span><span>
    </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">rollBack</span></span><span>();
    </span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"事务回滚："</span></span><span>, </span><span><span class="hljs-variable">$e</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">getMessage</span></span><span>();
}
</span><span><span class="hljs-meta">?&gt;</span></span><span>
</span></span>

4. 解释代码流程

建立PDO连接：首先，我们通过PDO连接到MySQL数据库，并设置错误模式为PDO::ERRMODE_EXCEPTION，以便在发生错误时抛出异常。
开始事务：通过调用$pdo->beginTransaction()，我们告诉PDO开始一个事务。此时，所有的数据库操作都处于事务管理之下，任何一项操作失败，其他操作将不会被提交。
执行SQL操作：
- 第一个SQL操作是插入一个用户记录。
- 第二个SQL操作是更新一个用户账户的余额。
提交事务：如果所有操作都成功，我们通过调用$pdo->commit()提交事务，将所有操作永久保存到数据库中。
回滚事务：如果在执行过程中发生异常（比如第二个SQL操作失败），就会触发catch块中的代码，调用$pdo->rollBack()进行事务回滚，撤销所有未提交的操作。

5. 注意事项

事务的原子性：使用beginTransaction()后，所有的数据库操作都将视为一个整体。如果发生错误，rollBack()可以撤销整个事务，保证数据一致性。
异常处理：务必使用try-catch块来捕获异常，确保在操作失败时能及时回滚事务。
多次事务操作：在一个事务中执行多次操作时，只要在事务提交之前没有出现错误，所有操作都会生效。

6. 总结

通过PDO的beginTransaction()和rollBack()方法，我们可以在PHP中高效地管理事务，并在出现错误时进行事务回滚操作，确保数据库操作的原子性和一致性。这种方式在需要执行多个数据库操作的场景中非常有用，尤其是在处理资金交易、订单处理等敏感操作时，事务回滚可以避免数据不一致的问题。

相关标签:
PDO

PDO::beginTransaction