登录
首页 >  文章 >  php教程

Laravel事务原生SQL使用方法

时间:2026-05-07 17:30:50 106浏览 收藏

在 Laravel 中执行多条原生 SQL 语句时,为确保数据一致性与操作原子性(即全部成功或全部回滚),必须将其置于数据库事务中;本文系统讲解了四种实用方案:利用 `DB::transaction()` 自动管理提交与回滚、通过 `beginTransaction()`/`commit()`/`rollback()` 手动控制流程、在事务内安全混合 `DB::select()` 与 `DB::statement()` 实现读写联动,以及使用 `DB::unprepared()` 执行多语句脚本(需禁用预处理模拟并严格防范 SQL 注入)——无论你是处理关键业务逻辑、复杂数据迁移,还是对接遗留 SQL 脚本,这些方法都能帮你稳稳守住数据 integrity 的最后一道防线。

Laravel如何在事务中使用原生SQL语句_Laravel原生SQL事务执行方法【数据库】

如果您在Laravel中需要确保多条原生SQL语句的原子性执行,例如插入、更新与删除操作必须全部成功或全部回滚,则必须将这些语句包裹在数据库事务中。以下是实现该目标的多种方法:

一、使用 DB::transaction() 包裹 DB::statement()

该方法利用 Laravel 的事务管理器自动处理提交与回滚,适用于执行不返回结果集的原生 SQL(如 INSERT、UPDATE、DELETE)。事务块内任意语句抛出异常时,整个事务将自动回滚。

1、在控制器或服务类中引入 DB 门面:use Illuminate\Support\Facades\DB;

2、调用 DB::transaction() 并传入闭包,在闭包中依次执行 DB::statement():DB::transaction(function () { DB::statement('INSERT INTO users (name, email) VALUES (?, ?)', ['Alice', 'alice@example.com']); DB::statement('UPDATE profiles SET bio = ? WHERE user_id = ?', ['Developer', 1]); });

3、若需手动触发回滚,可在闭包内抛出 Throwable 子类异常:throw new \Exception('Custom rollback condition');

二、使用 DB::beginTransaction() 与手动控制

该方法提供完全显式的事务生命周期控制,适用于需在执行过程中动态判断是否提交或回滚的场景,例如根据某条 SELECT 结果决定后续操作走向。

1、显式开启事务:DB::beginTransaction();

2、执行多条原生 SQL,包括查询与非查询语句:DB::statement('INSERT INTO logs (action) VALUES (?)', ['user_created']); $count = DB::select('SELECT COUNT(*) as cnt FROM users WHERE active = ?', [1])[0]->cnt;

3、根据业务逻辑决定提交或回滚:if ($count > 100) { DB::commit(); } else { DB::rollback(); }

三、在 DB::transaction() 中混合使用 DB::select() 与 DB::update()

当原生 SQL 涉及读取数据并基于结果执行写操作时,可在一个事务闭包中安全组合查询与修改语句,避免脏读或部分写入问题。

1、在事务闭包内先执行原生 SELECT 获取关键值:$balance = DB::select('SELECT balance FROM accounts WHERE id = ?', [123])[0]->balance;

2、基于查询结果构造并执行 UPDATE 语句:if ($balance >= 500) { DB::statement('UPDATE accounts SET balance = balance - ? WHERE id = ?', [500, 123]); DB::statement('INSERT INTO transactions (account_id, amount, type) VALUES (?, ?, ?)', [123, -500, 'withdrawal']); }

3、若条件不满足,闭包自然结束,事务自动回滚(因未发生写操作,亦可显式 throw 强制回滚):else { throw new \RuntimeException('Insufficient balance'); }

四、使用 DB::unprepared() 执行含多语句的原生 SQL 脚本

该方法适用于需一次性执行包含多个分号分隔语句的 SQL 脚本(如存储过程调用、批量 DDL/DML),但需注意:MySQL 驱动下必须启用 PDO::ATTR_EMULATE_PREPARES = false,且事务上下文仍需由外层 DB::transaction() 或 beginTransaction() 提供。

1、确认数据库连接配置中已禁用预处理模拟:'options' => [PDO::ATTR_EMULATE_PREPARES => false]

2、将多语句 SQL 字符串传入 DB::unprepared(),并置于事务块内:DB::transaction(function () { DB::unprepared('SET @x = 1; INSERT INTO tmp_values (val) VALUES (@x); UPDATE counters SET total = total + @x;'); });

3、注意 DB::unprepared() 不支持参数绑定,敏感数据须预先过滤或改用参数化语句拆分执行:禁止直接拼接用户输入到 unprepared 字符串中

终于介绍完啦!小伙伴们,这篇关于《Laravel事务原生SQL使用方法》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布文章相关知识,快来关注吧!

资料下载
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>