mysql事务

事务用于将某些操作的多个SQL作为原子性操作，一旦有某一个出现错误，即可回滚到原来的状态，从而保证数据库数据完整性。

原始数据

1create table user(
2id int primary key auto_increment,
3name char(32),
4balance int
5);
6
7insert into user(name,balance)
8values
9('wsb',1000),
10('egon',1000),
11('ysb',1000);

#原子操作

1start transaction;
2update user set balance=900 where name='wsb'; #买支付100元
3update user set balance=1010 where name='egon'; #中介拿走10元
4update user set balance=1090 where name='ysb'; #卖家拿到90元
5commit;

#出现异常，回滚到初始状态

1start transaction;
2update user set balance=900 where name='wsb'; #买支付100元
3update user set balance=1010 where name='egon'; #中介拿走10元
4uppdate user set balance=1090 where name='ysb'; #卖家拿到90元,出现异常没有拿到
5rollback;
6commit;
7mysql> select * from user;
8+----+------+---------+
9| id | name | balance |
10+----+------+---------+
11|  1 | wsb  |    1000 |
12|  2 | egon |    1000 |
13|  3 | ysb  |    1000 |
14+----+------+---------+
15rows in set (0.00 sec)

#介绍

1delimiter //
2            create procedure p4(
3                out status int
4            )
5            BEGIN
6                1. 声明如果出现异常则执行{
7                    set status = 1;
8                    rollback;
9                }
10
11                开始事务
12                    -- 由秦兵账户减去100
13                    -- 方少伟账户加90
14                    -- 张根账户加10
15                    commit;
16                结束
17
18                set status = 2;
19
20
21            END //
22            delimiter ;

View Code

#实现

1delimiter //
2create PROCEDURE p5(
3    OUT p_return_code tinyint
4)
5BEGIN 
6    DECLARE exit handler for sqlexception 
7    BEGIN 
8        -- ERROR 
9        set p_return_code = 1; 
10        rollback; 
11    END; 
12
13    DECLARE exit handler for sqlwarning 
14    BEGIN 
15        -- WARNING 
16        set p_return_code = 2; 
17        rollback; 
18    END; 
19
20    START TRANSACTION; 
21        DELETE from tb1; #执行失败
22        insert into blog(name,sub_time) values('yyy',now());
23    COMMIT; 
24
25    -- SUCCESS 
26    set p_return_code = 0; #0代表执行成功
27
28END //
29delimiter ;

View Code

调用

#在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())