PDO::beginTransaction 应该如何配合设置事务隔离级别来防止并发问题？

gitbox 2025-08-22

1. 什么是事务隔离级别？

事务隔离级别定义了事务在执行时能看到其他事务对数据的修改情况。不同的隔离级别提供不同程度的数据隔离，常见的隔离级别包括：

读未提交（Read Uncommitted）
允许一个事务读取另一个事务未提交的数据，可能会发生脏读现象。
读已提交（Read Committed）
只允许一个事务读取已提交的数据，避免脏读，但可能会发生不可重复读。
可重复读（Repeatable Read）
确保一个事务中的所有查询都返回相同的数据，避免不可重复读，但仍然可能发生幻读。
串行化（Serializable）
强制事务串行执行，完全避免脏读、不可重复读和幻读，但性能会受到较大影响。

2. 使用 PDO 设置事务隔离级别

PDO 允许在事务开始之前设置事务隔离级别。这一操作通常通过 SQL 语句来完成。具体方法是在调用 PDO::beginTransaction() 之前，使用 SET TRANSACTION ISOLATION LEVEL 语句来设置所需的隔离级别。例如：

<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=test'</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__">exec</span></span><span>(</span><span><span class="hljs-string">"SET TRANSACTION ISOLATION LEVEL REPEATABLE READ"</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">// 执行数据库操作</span></span><span>
</span><span><span class="hljs-comment">// ...</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>

在上面的代码中，SET TRANSACTION ISOLATION LEVEL REPEATABLE READ 会设置事务隔离级别为可重复读。这意味着在当前事务中执行的查询将始终返回相同的结果，即使其他事务在其间修改了数据。

3. 常见的事务隔离级别对并发问题的防范

不同的事务隔离级别对并发问题的防范效果不同。以下是它们在防止并发问题方面的具体表现：

读未提交（Read Uncommitted）
在这个隔离级别下，事务可以读取到其他事务未提交的数据，可能会导致脏读，进而导致数据不一致。由于没有对其他事务的操作进行限制，因此非常容易发生并发问题。
读已提交（Read Committed）
该隔离级别避免了脏读问题，因为事务只能读取已提交的数据。然而，它仍然可能发生不可重复读现象，即一个事务在两次读取相同数据时，数据可能发生变化。对于一些对数据一致性要求不高的场景，这个隔离级别可以在性能和一致性之间取得平衡。
可重复读（Repeatable Read）
可重复读隔离级别确保一个事务中的所有查询都返回一致的数据，避免了不可重复读。然而，可能会发生幻读，即另一个事务在当前事务查询之间插入新数据。该隔离级别对并发写操作的控制更加严格，有助于提高数据一致性。
串行化（Serializable）
串行化隔离级别是最严格的，它通过强制事务串行化来避免所有并发问题，包括脏读、不可重复读和幻读。这种隔离级别对性能的影响较大，通常适用于需要严格一致性的场景。

4. 如何根据业务需求选择事务隔离级别？

选择合适的事务隔离级别需要根据具体的业务需求进行权衡：

如果是对性能要求较高，但对数据一致性要求不高的应用场景，可以选择 读已提交 隔离级别。这将能够避免脏读，同时允许并发事务对数据进行修改。
对于大多数应用程序，可重复读 是一个比较好的选择，因为它能够防止不可重复读和脏读，在保证数据一致性的同时，性能损失相对较小。
在需要确保数据严格一致性且并发量不高的系统中，可以选择 串行化 隔离级别，虽然其性能较差，但能完全避免所有并发问题。

5. 示例：防止并发问题的实际应用

假设我们正在开发一个银行系统，需要确保用户的账户余额不会因并发操作而产生错误。我们可以通过设置可重复读隔离级别来防止在一个事务中查询的余额被其他事务修改：

<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=bank'</span></span><span>, </span><span><span class="hljs-string">'root'</span></span><span>, </span><span><span class="hljs-string">'password'</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-string">"SET TRANSACTION ISOLATION LEVEL REPEATABLE READ"</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">// 查询账户余额</span></span><span>
</span><span><span class="hljs-variable">$stmt</span></span><span> = </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">prepare</span></span><span>(</span><span><span class="hljs-string">"SELECT balance FROM accounts WHERE account_id = ?"</span></span><span>);
</span><span><span class="hljs-variable">$stmt</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">execute</span></span><span>([</span><span><span class="hljs-number">1</span></span><span>]);
</span><span><span class="hljs-variable">$balance</span></span><span> = </span><span><span class="hljs-variable">$stmt</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">fetchColumn</span></span><span>();

</span><span><span class="hljs-comment">// 执行某些业务逻辑</span></span><span>
</span><span><span class="hljs-keyword">if</span></span><span> (</span><span><span class="hljs-variable">$balance</span></span><span> &gt; </span><span><span class="hljs-number">100</span></span><span>) {
    </span><span><span class="hljs-comment">// 扣款操作</span></span><span>
    </span><span><span class="hljs-variable">$stmt</span></span><span> = </span><span><span class="hljs-variable">$pdo</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">prepare</span></span><span>(</span><span><span class="hljs-string">"UPDATE accounts SET balance = balance - 100 WHERE account_id = ?"</span></span><span>);
    </span><span><span class="hljs-variable">$stmt</span></span><span>-&gt;</span><span><span class="hljs-title function_ invoke__">execute</span></span><span>([</span><span><span class="hljs-number">1</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>

在这个例子中，设置了可重复读隔离级别，保证了查询到的余额不会因为其他事务的修改而发生变化，从而避免了数据不一致的情况。

6. 总结

PDO::beginTransaction() 是一个强大的工具，可以帮助我们在 PHP 中管理数据库事务。通过配合合理的事务隔离级别设置，我们可以有效地防止并发问题，确保数据的一致性和完整性。在开发过程中，我们应该根据业务需求选择合适的事务隔离级别，以平衡性能和数据一致性之间的关系。

相关标签:
PDO

PDO::beginTransaction