最近要對(duì)數(shù)據(jù)庫(kù)的數(shù)據(jù)進(jìn)行一個(gè)定時(shí)遷移,為了防止在執(zhí)行過(guò)程sql語(yǔ)句因?yàn)槟承┰驁?bào)錯(cuò)而導(dǎo)致數(shù)據(jù)轉(zhuǎn)移混亂,因此要對(duì)我們的腳本加以事務(wù)進(jìn)行控制。
首先我們建一張tran_test表
CREATE TABLE tran_test(
f1 VARCHAR(10) NOT NULL,
f2 INT(1) DEFAULT NULL,
PRIMARY KEY (f1)
)ENGINE=INNODB CHARSET=utf8
我想對(duì)tran_test插入兩條數(shù)據(jù),但是為了防止插入中報(bào)錯(cuò),因此我要把插入語(yǔ)句控制在一個(gè)事務(wù)內(nèi)。
這時(shí)候,如果你查一下有些人的文章,許多時(shí)候會(huì)給出你這么一條答案。
START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
ROLLBACK;
或
START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
COMMIT;
看上去很簡(jiǎn)單的sql語(yǔ)句,并且這兩句也確實(shí)能實(shí)現(xiàn)提交或回滾。
然而這真的能達(dá)到我們的目的嗎?答案是否定的。
比如第一段,它是將你在事務(wù)中的sql語(yǔ)句無(wú)論對(duì)錯(cuò)全部進(jìn)行ROLLBACK。這樣絕對(duì)的回滾使得你的sql沒(méi)有任何意義了。
因此我們想要真正的控制好事務(wù),我的思路是對(duì)要執(zhí)行的sql進(jìn)行異常檢測(cè)。如果sql沒(méi)有出現(xiàn)異常,COMMIT,如果捕獲到了異常,則ROLLBACK。
這時(shí)候,我們就需要建一個(gè)存儲(chǔ)過(guò)程來(lái)捕獲異常。執(zhí)行成功時(shí)進(jìn)行COMMIT,sql執(zhí)行失敗時(shí)則進(jìn)行ROLLBACK。
兩種思路可以達(dá)到我想要的效果。
第一種是對(duì)我們要執(zhí)行的sql進(jìn)行異常捕獲,我們?cè)俣x一個(gè)變量t_error,當(dāng)捕獲到異常的時(shí)候,讓t_error=1。再對(duì)t_error進(jìn)行條件判斷,如果t_error=1則進(jìn)行ROLLBACK,否則進(jìn)行COMMIT。
DROP PROCEDURE IF EXISTS t_test;
DELIMITER //
CREATE PROCEDURE t_test()
BEGIN
DECLARE t_error INTEGER;
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error = 1;
START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
IF t_error = 1 THEN
ROLLBACK;
ELSE
COMMIT;
END IF;
END//
CALL t_test();
另一只則是第一種的簡(jiǎn)化,即捕獲到異常直接進(jìn)行ROLLBACK,如果沒(méi)捕獲到異常,直接COMMIT
DROP PROCEDURE IF EXISTS t_test;
DELIMITER //
CREATE PROCEDURE t_test()
BEGIN
DECLARE EXIT HANDLER FOR SQLEXCEPTION ROLLBACK;
START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
COMMIT;
END//
CALL t_test()
這樣,這兩個(gè)insert語(yǔ)句便真正的被控制在了一個(gè)事務(wù)內(nèi)了。
以上實(shí)例大家可以在本次測(cè)試一下,如果有其他補(bǔ)充和疑問(wèn)可以直接聯(lián)系小編,感謝大家對(duì)腳本之家的支持。
您可能感興趣的文章:- MySQL找出未提交事務(wù)的SQL實(shí)例淺析
- MySQL找出未提交事務(wù)信息的方法分享
- Mysql事務(wù)隔離級(jí)別之讀提交詳解
- 探究MySQL中索引和提交頻率對(duì)InnoDB表寫(xiě)入速度的影響
- php將textarea數(shù)據(jù)提交到mysql出現(xiàn)很多空格的解決方法
- mysql實(shí)現(xiàn)事務(wù)的提交和回滾實(shí)例
- python連接mysql并提交mysql事務(wù)示例
- JSP+ MySQL中文亂碼問(wèn)題post提交亂碼解決方案
- 詳解MySQL與Spring的自動(dòng)提交(autocommit)