一、事務

  事務用於將某些操作的多個SQL作為原子性操作，一旦有某一個出現錯誤，即可回滾到原來的狀態，從而保證數據庫數據完整性。                      
   
 一堆sql語句：要麽同時執行成功，要麽同時失敗    # 事務的原子性
    
場景: 轉賬；

1、先建立表

#原子操作
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())

事務

14 MySQL--事務&函數與流程控制