來自:掘金撬槽,作者:不一樣的科技宅
前言
Insert into select請慎用堵未。這天xxx接到一個需求,需要將表A的數(shù)據(jù)遷移到表B中去做一個備份。本想通過程序先查詢查出來然后批量插入。但xxx覺得這樣有點慢,需要耗費大量的網(wǎng)絡I/O株扛,決定采取別的方法進行實現(xiàn)养距。通過在Baidu的海洋里遨游诉探,他發(fā)現(xiàn)了可以使用insert into select實現(xiàn),這樣就可以避免使用網(wǎng)絡I/O棍厌,直接使用SQL依靠數(shù)據(jù)庫I/O完成肾胯,這樣簡直不要太棒了。然后他就被開除了耘纱。
事故發(fā)生的經(jīng)過敬肚。
由于數(shù)據(jù)數(shù)據(jù)庫中order_today數(shù)據(jù)量過大,當時好像有700W了并且每天在以30W的速度增加束析。所以上司命令xxx將order_today內的部分數(shù)據(jù)遷移到order_record中艳馒,并將order_today中的數(shù)據(jù)刪除。這樣來降低order_today表中的數(shù)據(jù)量员寇。
由于考慮到會占用數(shù)據(jù)庫I/O弄慰,為了不影響業(yè)務第美,計劃是9:00以后開始遷移,但是xxx在8:00的時候曹动,嘗試遷移了少部分數(shù)據(jù)(1000條)斋日,覺得沒啥問題,就開始考慮大批量遷移墓陈。
- 在遷移的過程中恶守,應急群是先反應有小部分用戶出現(xiàn)支付失敗,隨后反應大批用戶出現(xiàn)支付失敗的情況贡必,以及初始化訂單失敗的情況兔港,同時騰訊也開始報警。
- 然后xxx就慌了仔拟,立即停止了遷移衫樊。
本以為停止遷移就就可以恢復了,但是并沒有利花。后面發(fā)生的你們可以腦補一下科侈。
事故還原
在本地建立一個精簡版的數(shù)據(jù)庫,并生成了100w的數(shù)據(jù)炒事。模擬線上發(fā)生的情況臀栈。
建立表結構
訂單表
CREATE TABLE `order_today` (
`id` varchar(32) NOT NULL COMMENT '主鍵',
`merchant_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '商戶編號',
`amount` decimal(15,2) NOT NULL COMMENT '訂單金額',
`pay_success_time` datetime NOT NULL COMMENT '支付成功時間',
`order_status` varchar(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '支付狀態(tài) S:支付成功、F:訂單支付失敗',
`remark` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '備注',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '創(chuàng)建時間',
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改時間 -- 修改時自動更新',
PRIMARY KEY (`id`) USING BTREE,
KEY `idx_merchant_id` (`merchant_id`) USING BTREE COMMENT '商戶編號'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
訂單記錄表
CREATE TABLE order_record like order_today;
今日訂單表數(shù)據(jù)
模擬遷移
把8號之前的數(shù)據(jù)都遷移到order_record表中去挠乳。
INSERT INTO order_record SELECT
*
FROM
order_today
WHERE
pay_success_time < '2020-03-08 00:00:00';
在navicat中運行遷移的sql,同時開另個一個窗口插入數(shù)據(jù)权薯,模擬下單。
從上面可以發(fā)現(xiàn)一開始能正常插入睡扬,但是后面突然就卡住了盟蚣,并且耗費了23s才成功,然后才能繼續(xù)插入卖怜。這個時候已經(jīng)遷移成功了屎开,所以能正常插入了。
出現(xiàn)的原因
在默認的事務隔離級別下:insert into order_record select * from order_today 加鎖規(guī)則是:order_record表鎖马靠,order_today逐步鎖(掃描一個鎖一個)牍戚。
分析執(zhí)行過程。
通過觀察遷移sql的執(zhí)行情況你會發(fā)現(xiàn)order_today是全表掃描虑粥,也就意味著在執(zhí)行insert into select from 語句時,mysql會從上到下掃描order_today內的記錄并且加鎖宪哩,這樣一來不就和直接鎖表是一樣了娩贷。
這也就可以解釋,為什么一開始只有少量用戶出現(xiàn)支付失敗锁孟,后續(xù)大量用戶出現(xiàn)支付失敗彬祖,初始化訂單失敗等情況茁瘦,因為一開始只鎖定了少部分數(shù)據(jù),沒有被鎖定的數(shù)據(jù)還是可以正常被修改為正常狀態(tài)储笑。由于鎖定的數(shù)據(jù)越來越多甜熔,就導致出現(xiàn)了大量支付失敗。最后全部鎖住突倍,導致無法插入訂單腔稀,而出現(xiàn)初始化訂單失敗。
解決方案
由于查詢條件會導致order_today全表掃描羽历,什么能避免全表掃描呢焊虏,很簡單嘛,給pay_success_time字段添加一個idx_pay_suc_time索引就可以了秕磷,由于走索引查詢诵闭,就不會出現(xiàn)掃描全表的情況而鎖表了,只會鎖定符合條件的記錄澎嚣。
最終的sql
INSERT INTO order_record SELECT
*
FROM
order_today FORCE INDEX (idx_pay_suc_time)
WHERE
pay_success_time <= '2020-03-08 00:00:00';
執(zhí)行過程
總結
使用insert into tablA select * from tableB語句時疏尿,一定要確保tableB后面的where,order或者其他條件易桃,都需要有對應的索引褥琐,來避免出現(xiàn)tableB全部記錄被鎖定的情況。
參考
https://blog.csdn.net/asdfsadfasdfsa/article/details/83030011