当前位置： 首页 > news >正文

MySQL事务

news 2025/9/4 20:37:33

事务简介

事务是一组操作的集合，它是一个不可分割的工作单位，事务会把所有的操作作为一个整体一起向系统提交或撤销操作请求，即这些操作要么同时成功，要么同时失败。

就比如: 张三给李四转账1000块钱，张三银行账户的钱减少1000，而李四银行账户的钱要增加1000。 这一组操作就必须在一个事务的范围内，要么都成功，要么都失败。

正常情况: 转账这个操作, 需要分为以下这么三步来完成 , 三步完成之后, 张三减少1000, 而李四增加1000, 转账成功 

异常情况: 转账这个操作, 也是分为以下这么三步来完成 , 在执行第三步是报错了, 这样就导致张三减少1000块钱, 而李四的金额没变, 这样就造成了数据的不一致, 就出现问题了。

默认MySQL的事务是自动提交的，也就是说，当执行完一条DML语句时，MySQL会立即隐式的提交事务。

事务四大特性

  • 原子性（Atomicity）：事务是不可分割的最小操作单元，要么全部成功，要么全部失败。

  • 一致性（Consistency）：事务完成时，必须使所有的数据都保持一致状态。

  • 隔离性（Isolation）：数据库系统提供的隔离机制，保证事务在不受外部并发操作影响的独立环境下运行。

  • 持久性（Durability）：事务一旦提交或回滚，它对数据库中的数据的改变就是永久的。

上述就是事务的四大特性，简称ACID。

原子性：事务必须都完成，或者不完成

一致性：查询的结果必须与开始查询的状态一致

隔离性：做出变更的会话，其他会话看不到未提交的记录

持久性：事务一旦完成，所有的用户立即看到

事务操作

数据准备：

drop table if exists account;
create table account(id    int primary key AUTO_INCREMENT comment 'ID',name  varchar(10) comment '姓名',money double(10, 2) comment '余额'
) comment '账户表';
insert into account(name, money) values ('张三', 2000), ('李四', 2000);

未控制事务

测试正常情况

-- 1. 查询张三余额
select * from account where name = '张三';
-- 2. 张三的余额减少1000
update account set money = money - 1000 where name = '张三';
-- 3. 李四的余额增加1000
update account set money = money + 1000 where name = '李四';

测试完毕之后检查数据的状态, 可以看到数据操作前后是一致的。

测试异常情况

-- 恢复数据
update account set money = 2000 where name in ('张三', '李四');
-- 1. 查询张三余额
select * from account where name = '张三';
-- 2. 张三的余额减少1000
update account set money = money - 1000 where name = '张三';
-- 友情提醒：”程序抛出异常...“   这几个字一定要加后面三个英文句号，不然不报错
程序抛出异常...
-- 3. 李四的余额增加1000
update account set money = money + 1000 where name = '李四';

我们把数据都恢复到2000， 然后再次一次性执行上述的SQL语句(出错了.... 这句话不符合SQL语法,执行就会报错)，检查最终的数据情况, 发现数据在操作前后不一致了。

控制事务一

查看/设置事务提交方式

-- 查看事务提交方式
SELECT @@autocommit;
-- 未提交事务之前当前窗口会产生了临时变化，在当前窗口查询可以得到变化之后的结果，但其他窗口要看到变化需要执行commit之后
-- 该设置的参数为会话参数，只针对当前窗口有效
-- 设置事务提交方式，1为自动提交，0为手动提交，该设置只对当前会话有效
SET @@autocommit = 0;

提交事务

-- 提交事务，手动提交把commit“授予”用户，此时选择多条sql执行，多条sql则成为一个事务
COMMIT;

回滚事务

-- 回滚事务
ROLLBACK;

上述的这种方式，我们是修改了事务的自动提交行为, 把默认的自动提交修改为了手动提交, 此时我们执行的DML语句都不会提交, 需要手动的执行commit进行提交。

控制事务二

开启事务

START TRANSACTION 或 BEGIN;

提交事务

COMMIT;

回滚事务

ROLLBACK;

使用begin/set @@autocommit的方式都需要手动commit

转账案例：

-- 开启事务
start transaction
-- 1. 查询张三余额
select * from account where name = '张三';
-- 2. 张三的余额减少1000
update account set money = money - 1000 where name = '张三';
-- 3. 李四的余额增加1000
update account set money = money + 1000 where name = '李四';
-- 如果正常执行完毕, 则提交事务
commit;
-- 如果执行过程中报错, 则回滚事务
-- rollback;

使用 SIGNAL

在 MySQL 中，事务的生命周期由 START TRANSACTION; 开始，直到遇到 COMMIT; 或 ROLLBACK; 结束。

即使发生了异常，只要没有显式回滚事务（ROLLBACK;），事务仍然处于“未完成”状态。

手动执行 commit; 会将事务中所有的操作提交到数据库中。

在 MySQL 中，如果发生异常（例如 SIGNAL 抛出的错误），事务不会自动回滚。

需要开发者显式地调用 ROLLBACK; 来回滚事务。

MySQL 提供了几种条件处理器，用于响应不同类型的异常、警告或 NOT FOUND 状态：

CONTINUE HANDLER：当触发条件时，执行完处理器中的代码后继续执行后续的 SQL 语句。

EXIT HANDLER：当触发条件时，执行完处理器中的代码后退出当前的 BEGIN...END 块。

drop procedure if exists transfer_money;
DELIMITER $$
CREATE PROCEDURE transfer_money()
BEGINdeclare m double(10,2);DECLARE EXIT HANDLER FOR SQLEXCEPTIONBEGINROLLBACK;END;START TRANSACTION;select money into m from account where name = '张三';if m < 1000 thensignal sqlstate '45000' set message_text = '余额不足';end if;-- 张三减少余额UPDATE account SET money = money - 1000 WHERE name = '张三';-- 李四增加余额UPDATE account SET money = money + 1000 WHERE name = '李四';COMMIT;
END$$

使用 ROW_COUNT()

MySQL 提供了一个内置函数 ROW_COUNT()，用于返回上一条 SQL 语句影响的行数。

这个函数可以判断是否有数据被修改。

对于INSERT，UPDATE，DELETE语句，返回受影响的行数。如果没有行被修改，则返回 0。

DROP PROCEDURE IF EXISTS TRANSFER_MONEY;
DELIMITER $$
CREATE PROCEDURE TRANSFER_MONEY()
BEGINTRANSFER: BEGIN -- 张三减少余额UPDATE ACCOUNT SET MONEY = MONEY - 1000 WHERE NAME = '张三' AND MONEY >= 1000;IF ROW_COUNT() = 0 THENROLLBACK;LEAVE TRANSFER;END IF;-- 李四增加余额UPDATE ACCOUNT SET MONEY = MONEY + 1000 WHERE NAME = '李四';COMMIT;END;
END$$
DELIMITER ;

LEAVE 是一种用于退出存储过程中某个特定代码块（如循环或条件分支）的方式。它通常与 BEGIN ... END 块配合使用。

-- 转钱的存储过程
drop procedure if exists transfer;
delimiter $$
create procedure transfer(a int,b int,c double)
my: begin-- 定义变量declare m double default 0;-- 打开事务start transaction;-- 查询张三的余额select ifnull(money,0) into m from account where id=a;if m<c thenrollback;-- 代码还是向下执行 leaveleave my;end if;-- 减去1000update account set money = money - cwhere id=a;-- 加上1000update account set money = money + cwhere id = b;-- 判断是否成功if row_count() = 0 thenrollback;end if;-- 提交事务commit;
end$$
delimiter ;
​
call transfer(3,1,4000);

存储过程与触发器

存储过程是 MySQL 中一种封装 SQL 逻辑的方式，支持显式地开启、提交和回滚事务。

特点

  • 存储过程可以通过 START TRANSACTION; 开启事务，并通过 COMMIT; 提交事务或通过 ROLLBACK; 回滚事务。

  • 可以结合异常处理机制（如 DECLARE EXIT HANDLER FOR SQLEXCEPTION）来实现自动回滚。

  • 如果存储过程中没有显式开启事务，默认情况下每条 SQL 语句会自动提交（Auto-commit 模式）。

  • 在存储过程中，事务的生命周期由 START TRANSACTION; 开始，直到遇到 COMMIT; 或 ROLLBACK; 结束。

触发器是一种特殊的数据库对象，它会在特定事件（如 INSERT、UPDATE 或 DELETE）发生时自动执行。

特点

  • 触发器本身不能显式地开启事务（即不能使用 START TRANSACTION;），因为触发器运行在一个已经存在的事务上下文中。

  • 如果触发器中发生了错误，整个事务会回滚（包括触发器外部的操作）。

  • 触发器不能显式地调用 COMMIT; 或 ROLLBACK;，因为它依赖于外部事务的上下文。

  • 如果触发器中抛出了异常（例如通过 SIGNAL），整个事务会被回滚。

  • 触发器的行为会影响事务的完整性，因此需要谨慎编写触发器逻辑。

特性存储过程触发器
事务控制可以显式开启、提交或回滚事务不能显式开启事务，依赖外部事务上下文
调用方式手动调用（通过 CALL）自动调用（由特定事件触发）
灵活性更灵活，可以包含复杂的业务逻辑较为受限，通常用于简单的数据验证或修改
错误处理可以定义异常处理器（如 DECLARE EXIT HANDLER）错误会直接导致事务回滚
DROP TRIGGER IF EXISTS CHANGE_MONEY;
​
CREATE TRIGGER CHANGE_MONEYAFTER UPDATEON ACCOUNTFOR EACH ROW
BEGINDECLARE M DOUBLE(10, 2) DEFAULT 0;IF NEW.MONEY < OLD.MONEY THENSIGNAL SQLSTATE '54000' SET MESSAGE_TEXT = '只能增加不能减少';END IF;SELECT NEW.MONEY - OLD.MONEY INTO M;UPDATE COMPANY SET MONEY = MONEY - M WHERE DEPT = 'YW';
END;
​
DROP TRIGGER IF EXISTS CHANGE_MONEY2;
​
CREATE TRIGGER CHANGE_MONEY2AFTER UPDATEON COMPANYFOR EACH ROW
BEGINIF OLD.MONEY <= 0 THENSIGNAL SQLSTATE '54000' SET MESSAGE_TEXT = '部门没钱了';END IF;
END;
​
UPDATE ACCOUNT SET MONEY = MONEY + 1000 WHERE ID = 1;
http://www.xdnf.cn/news/38719.html

相关文章：

  • 【训练】Datawhale AI春训营 发电功率预测
  • MySQL基础安装和学习
  • Javaweb之javascript的详细解析
  • 代码随想录打家劫舍+树形DP入门
  • docker安装mysqld-exporter
  • 大数据应用开发——大数据平台集群部署（三）
  • Tracepoints for the VFS?
  • 【单倍型理解及计算系列之三】怎么确定单倍型以及软件参数
  • RS232实现主单从多通讯
  • PTA | 与零交换
  • 220V转DC3V-3.2VLED供电WT5105
  • Nacos配置中心服务端源码解析
  • 程序性能(1)嵌入式基准测试工具
  • vmare识别不到共享文件夹，报错：fuse: bad mount point `/mnt/hgfs‘: No such file or directory
  • Python requests代理(Proxy)使用教程
  • Transformer（李宏毅）
  • C语言数据结构顺序表
  • 面试题--随机（一）
  • 每日算法-250419
  • 实验扩充 LED显示4*4键位值
  • 航电春季赛（七）1010 网格计数
  • python（八）-数据类型转换
  • 【C++算法】66.栈_比较含退格的字符串
  • linux软件仓库
  • 【AIVS】OPENAIVS开源视频推理系统简介
  • 【内置函数】84个Python内置函数全整理
  • 嘉立创原理图、PCB常见问题
  • 8.5/Q1，Charls最新文章解读
  • JavaScript 变量命名规范
  • LeetCode 2563.统计公平数对的数目：排序 + 二分查找