事务用于将某些操作的多个SQL作为原子性操作，一旦有某一个出现错误，即可回滚到原来的状态，从而保证数据库数据完整性。
一堆sql语句：要么同时执行成功，要么同时失败 # 事务的原子性
场景: 转账；
#原子操作start transaction; update user set balance=900 where name=‘wsb‘; #买支付100元update user set balance=1010 where name=‘egon‘; #中介拿走10元update user set balance=1090 where name=‘ysb‘; #卖家拿到90元commit; #出现异常，回滚到初始状态start transaction; update user set balance=900 where name=‘wsb‘; #买支付100元update user set balance=1010 where name=‘egon‘; #中介拿走10元uppdate user set balance=1090 where name=‘ysb‘; #卖家拿到90元,出现异常没有拿到rollback; # 回滚到原来的状态 commit; # 只有提交了，事务操作才完成-------------------------------------------------------------------------------------------------------------------------------------------
---------------------------------------------------------------------------------------------------------------------------------------------------
---------------------------------------------------------------------------------------------------------------------------------------------------
------------------------------------------------------------------------------------------------------------------------
-------------------------------------------------------------------------------------------------------------------
#介绍delimiter // create procedure p4( out status int ) BEGIN 1. 声明如果出现异常则执行{ set status = 1; rollback; } 开始事务 -- 由秦兵账户减去100 -- 方少伟账户加90 -- 张根账户加10 commit; 结束 set status = 2; END // delimiter ;#实现
出现异常执行回滚
delimiter //create PROCEDURE p5( OUT p_return_code tinyint)BEGIN DECLARE exit handler for sqlexception #declare 声明一个 退出 sql异常处理 BEGIN -- ERROR # error set p_return_code = 1; rollback; # 出错就回滚 END; DECLARE exit handler for sqlwarning # 遇到警告回滚 BEGIN -- WARNING set p_return_code = 2; rollback; END;
#正常执行 START TRANSACTION; DELETE from tb1; #delete 执行失败 insert into blog(name,sub_time) values(‘yyy‘,now()); COMMIT; # 正常执行就commit -- SUCCESS set p_return_code = 0; # 0 代表执行成功END //delimiter ;#在mysql中调用存储过程set @res=123;call p5(@res);select @res;#在python中基于pymysql调用存储过程cursor.callproc(‘p5‘,(123,))print(cursor.fetchall()) #查询select的查询结果cursor.execute(‘select @_p5_0;‘)print(cursor.fetchall())事务
