怎么在MySQL中通過加鎖控制并發(fā)?針對這個問題,這篇文章詳細(xì)介紹了相對應(yīng)的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

# 添加一個user表 CREATE TABLE `users` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID', `name` varchar(255) NOT NULL COMMENT '姓名', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8; # 插入3條數(shù)據(jù) INSERT INTO `users` (`id`, `name`) VALUES (1, '雪山飛豬'), (2, 'chenqionghe'), (3, 'cqh');
查詢結(jié)果如下:

核心原理是增加一個version的字段來控制。
舉個場景,我們希望并發(fā)更新單行記錄的時候的時候,只有一個進(jìn)程更新成功,如下
UPDATE users SET name="雪山飛豬" WHERE id=3 UPDATE users SET name="chenqionghe" WHERE id=3
上面這兩個sql最終都會更新成功,且以最后更新結(jié)果為主。
解決辦法是添加一個version字段
ALTER TABLE users ADD `version` INT NOT NULL DEFAULT '0'
解決辦法是添加一個version字段,每個更新時where條件都加上它,并且也更新它
UPDATE users SET name="雪山飛豬",version=version+1 WHERE id=3 AND version=0 UPDATE users SET name="chenqionghe",version=version+1 WHERE id=3 AND version=0
這次變成了只會更新成功一次,誰先搶到這條記錄以誰為主,因為當(dāng)前一個進(jìn)程更新成功后版本號已經(jīng)變化了,第二個進(jìn)程找不到這條記錄了。
這就是最簡單的CAS機制。
其實類似Go語言里的Mutex和RwMutex讀鎖
也叫共享鎖或S鎖,當(dāng)給數(shù)據(jù)表加上共享鎖的時候,表就變成了只讀模式。
我們可以鎖全表,也可以鎖全表或部分行,如下
語法如下
LOCK TABLE 表 READ UNLOCK TABLE;
我們來測試一個,第一個進(jìn)程執(zhí)行
LOCK TABLE users READ;

第二個進(jìn)程執(zhí)行正常讀
SELECT * FROM users WHERE id=1;

可以正常查詢。我們再來執(zhí)行一下更新
UPDATE users SET name="chenqionghe" WHERE id=1

出現(xiàn)了等待。
我們給第一個進(jìn)程解鎖

再看第二個進(jìn)程,已經(jīng)更新成功

BEGIN; SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE COMMIT;
必須配合事務(wù)使用,BEIN開始后,鎖定的行,外部只能查詢,不能更新
我們來測試一下,第一個進(jìn)程執(zhí)行
BEGIN; SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE

這里鎖定了id為1和2的記錄行。我們第二個進(jìn)程執(zhí)行更新
UPDATE users SET name="雪山飛豬" WHERE id=1
又一次出現(xiàn)了等待。
好,這時候我們將第一個進(jìn)程的事務(wù)提交
COMMIT;

第二個進(jìn)程更新成功了,如下
也排他鎖、獨占鎖,理解成讀和寫都不行了,語法如下
LOCK TABLE users WRITE;
這時候已經(jīng)鎖定全表,我們再用另一個進(jìn)程查詢一下id為1的數(shù)據(jù)
SELECT * FROM users WHERE id=1

可以看到,查詢已經(jīng)發(fā)生了等待。
我們再將第一個進(jìn)程解鎖
UNLOCK TABLE

這時候,第二個進(jìn)程立馬查詢成功

當(dāng)我們對數(shù)據(jù)進(jìn)行更新的時候(INSERT、DELETE、UPDATE)的時候,數(shù)據(jù)庫會自動使用排它鎖,防止其他事務(wù)操作該數(shù)據(jù)
BEGIN; SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE COMMIT;
我們再來測試一下,第一個進(jìn)程鎖定id為1和2的記錄
BEGIN; SELECT * FROM users WHERE id IN (1,2) FOR UPDATE
注意:這時候事務(wù)沒提交
我們先用第二個進(jìn)程來更新id為3的記錄(未被鎖定)
UPDATE users SET name="chenqionghe" WHERE id=3

執(zhí)行成功了。
我們再來更新一個id為1的記錄
UPDATE users SET name="chenqionghe" WHERE id=1

發(fā)生了等待,說明已經(jīng)被鎖定了。
好,我們提交第一個進(jìn)程的事務(wù)
COMMIT;
再去看第二個進(jìn)程,已經(jīng)更新成功

關(guān)于怎么在MySQL中通過加鎖控制并發(fā)問題的解答就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識。
網(wǎng)頁題目:怎么在MySQL中通過加鎖控制并發(fā)-創(chuàng)新互聯(lián)
當(dāng)前地址:http://chinadenli.net/article48/gccep.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站維護(hù)、商城網(wǎng)站、建站公司、App設(shè)計、企業(yè)建站、營銷型網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容