开启事务可确保多条sql操作的原子性,通过START TRANSACTION、COMMIT和ROLLBACK控制流程,在转账等场景中保证数据一致性。
在 mysql 中,使用事务可以确保多条 SQL 操作要么全部成功执行,要么全部不生效,从而保证数据的一致性。这在处理如转账、订单创建等涉及多个步骤的业务逻辑时尤为重要。
开启事务手动控制流程
MySQL 默认每条 SQL 语句自动提交(autocommit = 1),要使用事务需关闭自动提交,手动控制提交或回滚。
基本语法:
- START TRANSACTION; 或 BEGIN; —— 显式开始一个事务
- COMMIT; —— 提交事务,使所有更改永久生效
- ROLLBACK; —— 回滚事务,撤销所有未提交的更改
示例:银行转账场景
START TRANSACTION; UPDATE accounts SET balance = balance - 100 WHERE user_id = 1; UPDATE accounts SET balance = balance + 100 WHERE user_id = 2; -- 如果两条更新都成功 COMMIT; -- 若其中一条失败,执行 -- ROLLBACK;
设置保存点实现部分回滚
在复杂操作中,可能只需要回滚部分语句。MySQL 支持通过 SAVEPOINT 设置中间节点。
用法:
- SAVEPOINT savepoint_name; —— 创建保存点
- ROLLBACK TO savepoint_name; —— 回滚到指定保存点
- RELEASE SAVEPOINT savepoint_name; —— 释放保存点
示例:
START TRANSACTION; INSERT INTO logs (msg) VALUES ('step1'); SAVEPOINT sp1; INSERT INTO logs (msg) VALUES ('step2'); -- 出错时可回退到 sp1 ROLLBACK TO sp1; COMMIT;
注意事务隔离与锁机制
事务的隔离级别会影响并发行为。MySQL 默认为 REPEATABLE READ,可通过以下命令调整:
高并发下应关注死锁和长事务问题。尽量缩短事务执行时间,避免在事务中进行用户交互或网络请求。
在编程语言中正确使用事务
实际开发中通常通过代码控制事务。以 python + PyMySQL 为例:
try: connection.begin() cursor.execute("UPDATE a SET val=val-10 WHERE id=1") cursor.execute("UPDATE b SET val=val+10 WHERE id=1") connection.commit() except Exception as e: connection.rollback() print("事务执行失败,已回滚")
关键是在异常发生时主动触发 rollback,防止脏数据写入。
基本上就这些。只要开启事务、合理使用提交与回滚、注意异常处理,就能有效保障多条 SQL 的一致性。