MySQL 中,單個 Store Procedure(SP) 不是原子操作,而 Oracle 則是原子的。如下的存儲過程,即使語句2 失敗,語句 1 仍然會被 commit 到數據庫中:
create table testproc(id int(4) primary key, name varchar(100)); CREATE PROCEDURE test_proc_ins( IN i_id INT, IN i_name VARCHAR(100) ) BEGIN INSERT INTO testproc VALUES (i_id, i_name); -- 語句1 INSERT INTO testproc VALUES (i_id, i_name); -- 語句2(因為id為PK,此語句將出錯)。 END;
要使整個存儲過程成為一個原子操作的辦法是:在存儲過程主體開始部分,指定開始一個事務。語句 2 失敗,語句 1 不會被 commit 到數據庫中,存儲過程將會在調用時拋出一個異常。
CREATE PROCEDURE test_proc_ins( IN i_id INT, IN i_name VARCHAR(100) ) BEGIN start transaction; --整個存儲過程指定為一個事務 INSERT INTO testproc VALUES (i_id, i_name); INSERT INTO testproc VALUES (i_id+1, i_name); -- 這里把id+1,避免主鍵沖突 commit; -- 語句1。必須主動提交 END;
CREATE PROCEDURE test_proc_ins( IN i_id INT, IN i_name VARCHAR(100), OUT o_ret INT) BEGIN start transaction; INSERT INTO testproc VALUES (i_id, i_name); INSERT INTO testproc VALUES (i_id+1,i_name); commit; -- 語句1,提交后,事務已結束 set o_ret = 1; start transaction; -- 再啟一個事務 INSERT INTO testproc VALUES (i_id+2,i_name); -- 語句2 INSERT INTO testproc VALUES (i_id+2,i_name); -- 語句3 set o_ret = 2; commit; -- 數據正常的情況下,需要再次commit以結束事務 END;
MySQL的回滾事物的操作
在處理事務時,使用SQLException捕獲SQL錯誤,然后處理; 按照這個推論,我們必須在MySQL存儲過程中捕獲SQL錯誤,最后判斷是回滾(ROLLBACK)還是提交(COMMIT)。
DROP PROCEDURE IF EXISTS test_sp1 CREATE PROCEDURE test_sp1( ) BEGIN DECLARE t_error INTEGER DEFAULT 0; DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1; START TRANSACTION; INSERT INTO test VALUES(NULL, 'test sql 001'); INSERT INTO test VALUES('1', 'test sql 002'); IF t_error = 1 THEN ROLLBACK; ELSE COMMIT; END IF; select t_error; //返回標識位的結果集; END
mysql事物處理實例
MYSQL的事務處理主要有兩種方法
1.用begin,rollback,commit來實現
begin開始一個事務
rollback事務回滾
commit 事務確認
2.直接用set來改變mysql的自動提交模式
mysql默認是自動提交的,也就是你提交一個query,就直接執行!可以通過
set autocommit = 0 禁止自動提交
set autocommit = 1 開啟自動提交
來實現事務的處理。
但要注意當用set autocommit = 0 的時候,你以后所有的sql都將作為事務處理,直到你用commit確認或 rollback結束,注意當你結束這個事務的同時也開啟了新的事務!按第一種方法只將當前的做為一個事務!
MYSQL只有 INNODB和BDB類型的數據表才支持事務處理,其他的類型是不支持的!
