MySQL 加鎖控制并發(fā)的方法
鎖總體可以分為樂觀鎖和悲觀鎖,簡單說,樂觀鎖用版本號控制,悲觀鎖用鎖控制。
下面是待會要用來測試的數(shù)據(jù)
# 添加一個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ā)更新單行記錄的時候的時候,只有一個進程更新成功,如下
UPDATE users SET name='雪山飛豬' WHERE id=3UPDATE users SET name='chenqionghe' WHERE id=3
上面這兩個sql最終都會更新成功,且以最后更新結(jié)果為主。
解決辦法是添加一個version字段
添加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=0UPDATE users SET name='chenqionghe',version=version+1 WHERE id=3 AND version=0
這次變成了只會更新成功一次,誰先搶到這條記錄以誰為主,因為當(dāng)前一個進程更新成功后版本號已經(jīng)變化了,第二個進程找不到這條記錄了。這就是最簡單的CAS機制。
二、悲觀鎖其實類似Go語言里的Mutex和RwMutex讀鎖
讀鎖也叫共享鎖或S鎖,當(dāng)給數(shù)據(jù)表加上共享鎖的時候,表就變成了只讀模式。我們可以鎖全表,也可以鎖全表或部分行,如下
全表鎖(LOCK TABLE 表 READ)語法如下
LOCK TABLE 表 READUNLOCK TABLE;
我們來測試一個,第一個進程執(zhí)行
LOCK TABLE users READ;
第二個進程執(zhí)行正常讀
SELECT * FROM users WHERE id=1;
可以正常查詢。我們再來執(zhí)行一下更新
UPDATE users SET name='chenqionghe' WHERE id=1
出現(xiàn)了等待。
我們給第一個進程解鎖
再看第二個進程,已經(jīng)更新成功
BEGIN;SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODECOMMIT;
必須配合事務(wù)使用,BEIN開始后,鎖定的行,外部只能查詢,不能更新
我們來測試一下,第一個進程執(zhí)行
BEGIN;SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE
這里鎖定了id為1和2的記錄行。我們第二個進程執(zhí)行更新
UPDATE users SET name='雪山飛豬' WHERE id=1
又一次出現(xiàn)了等待。好,這時候我們將第一個進程的事務(wù)提交
COMMIT;
第二個進程更新成功了,如下
寫鎖也排他鎖、獨占鎖,理解成讀和寫都不行了,語法如下
全表鎖(LOCK TABLE 表 WRITE)LOCK TABLE users WRITE;
這時候已經(jīng)鎖定全表,我們再用另一個進程查詢一下id為1的數(shù)據(jù)
SELECT * FROM users WHERE id=1
可以看到,查詢已經(jīng)發(fā)生了等待。我們再將第一個進程解鎖
UNLOCK TABLE
這時候,第二個進程立馬查詢成功
當(dāng)我們對數(shù)據(jù)進行更新的時候(INSERT、DELETE、UPDATE)的時候,數(shù)據(jù)庫會自動使用排它鎖,防止其他事務(wù)操作該數(shù)據(jù)
BEGIN;SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODECOMMIT;
我們再來測試一下,第一個進程鎖定id為1和2的記錄
BEGIN;SELECT * FROM users WHERE id IN (1,2) FOR UPDATE
注意:這時候事務(wù)沒提交
我們先用第二個進程來更新id為3的記錄(未被鎖定)
UPDATE users SET name='chenqionghe' WHERE id=3
執(zhí)行成功了。我們再來更新一個id為1的記錄
UPDATE users SET name='chenqionghe' WHERE id=1
發(fā)生了等待,說明已經(jīng)被鎖定了。好,我們提交第一個進程的事務(wù)
COMMIT;
再去看第二個進程,已經(jīng)更新成功
簡單說樂觀鎖用version控制,悲觀鎖的表鎖一般用不著,行的讀鎖用LOCK IN SHARE MODE,寫鎖用FRO UPDATE,就是這么簡單!
以上就是MySQL 加鎖控制并發(fā)的方法的詳細內(nèi)容,更多關(guān)于MySQL 加鎖控制并發(fā)的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. 一文帶你了解MySQL的左連接與右連接2. Access數(shù)據(jù)庫安全的幾個問題3. ORACLE中如何實現(xiàn)ASCII字符串和16進制串互相轉(zhuǎn)換4. 關(guān)于Oracle數(shù)據(jù)庫熱備份腳本深入剖析5. Sql server數(shù)據(jù)庫開發(fā)常用匯總6. Oracle的PDB數(shù)據(jù)庫創(chuàng)建DIRECTORY時遇到ORA-65254問題及解決方法7. MySQL 的啟動選項和系統(tǒng)變量實例詳解8. 如何遠程調(diào)用ACCESS數(shù)據(jù)庫9. MySQL雙主(主主)架構(gòu)配置方案10. mysql-bin.000001文件的來源及處理方法
