MySQL 加鎖控制并發(fā)的方法
前言
鎖總體可以分為樂觀鎖和悲觀鎖,簡單說,樂觀鎖用版本號(hào)控制,悲觀鎖用鎖控制。
下面是待會(huì)要用來測試的數(shù)據(jù)
# 添加一個(gè)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é)果如下:

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

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

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

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

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

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

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

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

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

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

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

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

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

簡單說樂觀鎖用version控制,悲觀鎖的表鎖一般用不著,行的讀鎖用LOCK IN SHARE MODE,寫鎖用FRO UPDATE,就是這么簡單!
以上就是MySQL 加鎖控制并發(fā)的方法的詳細(xì)內(nèi)容,更多關(guān)于MySQL 加鎖控制并發(fā)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Mysql錯(cuò)誤Every derived table must have its own alias解決方法
這篇文章主要介紹了Mysql錯(cuò)誤Every derived table must have its own alias解決方法,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-08-08
更改Mysql數(shù)據(jù)庫存儲(chǔ)位置的具體步驟
首先把mysql的服務(wù)先停掉,更改MySQL配置文件My.ini中的數(shù)據(jù)庫存儲(chǔ)主路徑,將老的數(shù)據(jù)庫存儲(chǔ)主路徑中的數(shù)據(jù)庫文件和文件夾復(fù)制到新的存儲(chǔ)主路徑,接下來重啟搞定2013-07-07
10個(gè)MySQL性能調(diào)優(yōu)的方法
本文介紹了10個(gè)MySQL性能調(diào)優(yōu)的方法,每個(gè)方法的講解都很細(xì)致,非常實(shí)用,,需要的朋友可以參考下2015-07-07
深入解析MySQL中的Redo Log、Undo Log和Binlog
本文詳細(xì)介紹了MySQL中的RedoLog、UndoLog和Binlog的背景、業(yè)務(wù)場景、功能、底層實(shí)現(xiàn)原理以及使用措施,通過Java代碼示例展示了如何與這些日志進(jìn)行交互,進(jìn)一步深化了對(duì)MySQL日志系統(tǒng)的理解,理解并合理使用這些日志,可以有效地提升數(shù)據(jù)庫的性能和可靠性2024-10-10
利用JuiceFS使MySQL?備份驗(yàn)證性能提升?10?倍
這篇文章主要介紹了如何讓?MySQL?備份驗(yàn)證性能提升?10?倍,JuiceFS?非常適合用來做?MySQL?物理備份,通過不斷調(diào)整?XtraBackup?的參數(shù)和?JuiceFS?的掛載參數(shù),在一個(gè)小時(shí)內(nèi)將時(shí)間縮短到原先的?1/10,下文一起來看相關(guān)內(nèi)容的詳細(xì)介紹吧2022-03-03

