您是否遇到过在laravel cms 控制器中编写一些代码将一堆数据写入数据库的情况?
我经常构建接受大量数据负载的 API 端点,然后我们将一条记录写入数据库,然后使用关系将一堆相关数据写入这条新记录。
问题是,要将其全部正确存储,您的多个数据库写入都需要全部成功。否则,您将得到该实体的不完整表示。
有时我没有正确验证某些东西,或者由于某种原因在写入相关数据时出现异常。抛出一个异常,并且您的用户被告知出现了问题,但您仍然保留了一半的信息。
我最近有另一个案例,我用一个新项目扼杀了一个遗留项目。新项目将接收请求,将其存储在新项目中,然后需要将其中一些数据写回遗留项目,以便遗留系统仍然可以运行。由于此数据需要在两个系统之间保持同步,如果对任一系统的写入失败,我需要回滚所有更改的记录。
使用数据库事务很容易实现这一点。数据库事务允许我们进行一系列更改,使用这些更改的数据,然后在我们准备好时持久化它。
当您在多条路线上执行此操作时,您需要一种方法来轻松地将此逻辑应用于需要它的每条路线。
那么我们如何才能采用数据库事务的概念并将请求包装在其中呢?
带中间件!
我们可以编写一些中间件,将请求包装在数据库事务中,并在一切成功时提交事务。
这看起来像这样:
- use Illuminate\Support\Facades\DB;
-
- class WrapRequestInDatabaseTransaction
- {
- public function handle($request, Closure $next)
- {
- DB::beginTransaction();
-
- $response = $next($request);
-
- if ($response->exception) {
- DB::rollBack();
- return $response;
- }
-
- DB::commit();
-
- return $response;
- }
- }
$response
- 此时请求的其余部分已运行,这就是我们要返回给用户的内容$response
是异常您也可以更改它以将事务也放在特定连接上。事实上,如果确实需要,我们可以包装多个数据库连接。如果我们以上面的第二个例子为例,我正在扼杀一个遗留项目,那么中间件在多个连接上的样子如下:
- use Illuminate\Support\Facades\DB;
-
- class WrapRequestInDatabaseTransaction
- {
- public function handle($request, Closure $next)
- {
- DB::beginTransaction();
- DB::connection('another_connection')->beginTransaction();
-
- $response = $next($request);
-
- if ($response->exception) {
- DB::rollBack();
- DB::connection('another_connection')->rollBack();
- return $response;
- }
-
- DB::commit();
- DB::connection('another_connection')->commit();
-
- return $response;
- }
- }
这对于我需要它的用例非常有效,希望它也能帮助你