在 Laravel 框架中，`DB::transaction()` 是用于执行数据库事务的一种便捷方式，它确保在一组数据库操作中，所有操作要么全部成功，要么全部失败。然而，在处理多数据库环境时，可能会遇到 `DB::transaction()` 事务失效的问题。这个问题通常出现在尝试在一个事务中涉及多个数据库连接时，Laravel 默认的事务管理器可能无法正确地跟踪和处理这些跨库的更改。
本文将深入探讨这个问题的原因以及如何解决。
### 问题描述
在 Laravel 应用程序中，如果使用了多个数据库配置（例如 `mysql` 和 `mysql2`），并且在 `DB::transaction()` 块内执行针对不同数据库的操作，事务可能不会按预期工作。例如，以下代码可能导致事务失效：
```php
DB::transaction(function () use ($uid, $roleId) {
RoomUserRole::insert([ // 连接 'mysql'
'uid' => $uid,
'role_id' => $roleId,
'created_at' => LARAVEL_START,
'updated_at' => LARAVEL_START,
]);
RoomUserRoleLog::insert([ // 假设这是 'mysql2' 的模型
'uid' => $uid,
'handle_type' => 1,
'admin_uid' => Auth::user()->id,
'created_at' => LARAVEL_START,
'updated_at' => LARAVEL_START,
]);
});
```
在这种情况下，尽管第二条 SQL 语句（针对 `mysql2` 数据库）引发错误并抛出异常，但第一条 SQL 语句（针对 `mysql` 数据库）仍然成功执行，导致事务失效。
### 原因分析
`DB::transaction()` 函数默认使用 Laravel 配置中的默认数据库连接。当在事务内部执行跨数据库操作时，Laravel 的事务管理器无法感知到这些不同的连接，因此无法在两个数据库之间协调事务。这就是事务失效的根本原因。
### 解决方案
要解决这个问题，你需要明确指定要使用哪个数据库连接来开启和管理事务。可以修改代码如下：
```php
DB::connection('mysql2')->transaction(function () use ($uid, $roleId) {
RoomUserRole::on('mysql')->insert([ // 明确指定 'mysql' 连接
'uid' => $uid,
'role_id' => $roleId,
'created_at' => LARAVEL_START,
'updated_at' => LARAVEL_START,
]);
RoomUserRoleLog::insert([ // 已经在 'mysql2' 连接的事务内
'uid' => $uid,
'handle_type' => 1,
'admin_uid' => Auth::user()->id,
'created_at' => LARAVEL_START,
'updated_at' => LARAVEL_START,
]);
});
```
这里，`RoomUserRole::on('mysql')` 方法用于指定 `RoomUserRole` 模型应该使用 `mysql` 连接。这样，整个事务块都在 `mysql2` 的上下文中运行，而第一条 SQL 语句则明确指定了 `mysql` 连接。
除了使用 `on` 方法，你还可以直接在事务开始时指定数据库连接：
```php
DB::connection('mysql2')->beginTransaction();
try {
RoomUserRole::insert([ // 使用 'mysql' 连接
'uid' => $uid,
'role_id' => $roleId,
'created_at' => LARAVEL_START,
'updated_at' => LARAVEL_START,
]);
RoomUserRoleLog::insert([ // 在 'mysql2' 连接下
'uid' => $uid,
'handle_type' => 1,
'admin_uid' => Auth::user()->id,
'created_at' => LARAVEL_START,
'updated_at' => LARAVEL_START,
]);
DB::connection('mysql2')->commit();
} catch (\Exception $e) {
DB::connection('mysql2')->rollBack();
// 处理异常
}
```
这种方法更加显式，可以确保事务在正确的数据库上执行，并在发生错误时正确回滚。
### 总结
在 Laravel 中处理多数据库事务时，必须明确指定每个数据库操作所使用的连接。使用 `DB::connection('database_name')->transaction()` 或者结合 `->on('database_name')` 方法来确保事务的正确性。否则，Laravel 的默认行为可能导致事务失效，从而在关键操作中引入数据不一致性。遵循这些最佳实践，可以有效地管理跨数据库的事务，确保数据的一致性和完整性。
