Laravel跨库跨连接的事务操作

发表于   |   分类于   |  

今天在操作一个事务的时候 发现了一个奇怪的事情，在代码中开启了一个事务 然后中间操作了 2 张不同数据库的表 最后发现其中一个表不受到 commit 和 rollback 的影响 数据正常操作进去了

因为是在项目中配置了多个数据库连接 后面测试发现只有默认连接的那个 MySQL 事务才生效了 另外一个数据库的所有事务操作对它都不生效！

然后搜索了一圈发现 Laravel 下的跨库事务操作是基于连接的 当执行 DB::beginTransaction(); 的时候 其实是和默认的数据库配置建立了连接 后面的操作 commit 或者 rollback 都是操作的这个默认数据库 如果在这中间操作了其他的数据库 对他是不生效的

解决方案

开始事务的时候就指定连接

同时 commit 和 rollback 都 指定连接

以 Laravel5.5 为例

增加多数据库配置

在配置目录 config/database.php 文件中的 connections 数组下 增加多数据库连接配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
'mysql' => [
    'driver' => 'mysql',
    'host' => env('DB_HOST', '127.0.0.1'),
    'port' => env('DB_PORT', '3306'),
    'database' => env('DB_DATABASE', 'forge'),
    'username' => env('DB_USERNAME', 'forge'),
    'password' => env('DB_PASSWORD', ''),
    'unix_socket' => env('DB_SOCKET', ''),
    'charset' => 'utf8mb4',
    'collation' => 'utf8mb4_unicode_ci',
    'prefix' => env('DB_PREFIX', ''),
    'strict' => true,
    'engine' => null,
],
//增加test数据库配置
'test' => [
    'driver' => 'mysql',
    'host' => env('DB_TEST_HOST', '127.0.0.1'),
    'port' => env('DB_TEST_PORT', '3306'),
    'database' => env('DB_TEST_DATABASE', 'forge'),
    'username' => env('DB_TEST_USERNAME', 'forge'),
    'password' => env('DB_TEST_PASSWORD', ''),
    'unix_socket' => env('DB_TEST_SOCKET', ''),
    'charset' => 'utf8mb4',
    'collation' => 'utf8mb4_unicode_ci',
    'prefix' => env('DB_TEST_PREFIX', ''),
    'strict' => true,
    'engine' => null,
],

给Model指定数据库连接

新建一个test数据库的连接基类

指定连接为上面配置的连接别名

1
2
3
4
5
6
use Illuminate\Database\Eloquent\Model;
class BaseModel extends Model
{
    protected $connection = "test";
}

跨库事务操作

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
try {
    //开启默认数据库的事务
    DB::beginTransaction();
    //开启test数据库的事务
    DB::connection('test')->beginTransaction();
    //中间各种数据库操作
    Table1::xxxxxx();
    Table2::xxxxxx();
    if (true) {
        //一起提交
        DB::commit();
        DB::connection('test')->commit();
    } else {
        //一起回滚
        DB::rollback();
        DB::connection('test')->rollback();
    }
} catch (\Exception $exception) {
    echo "catch some errors:".$exception->getMessage();
}
-------------The End-------------