MySQL 加鎖控制並發的方法

前言

鎖總體可以分為樂觀鎖和悲觀鎖,簡單說,樂觀鎖用版本號控制,悲觀鎖用鎖控制。

下面是待會要用來測試的數據

# 添加一個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條數據
INSERT INTO `users` (`id`, `name`)
VALUES
 (1, '雪山飛豬'),
 (2, 'chenqionghe'),
 (3, 'cqh');

查詢結果如下:

一、樂觀鎖

核心原理是增加一個version的字段來控制。
舉個場景,我們希望並發更新單行記錄的時候的時候,隻有一個進程更新成功,如下

UPDATE users SET name="雪山飛豬" WHERE id=3
UPDATE users SET name="chenqionghe" WHERE id=3

上面這兩個sql最終都會更新成功,且以最後更新結果為主。

解決辦法是添加一個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=0
UPDATE users SET name="chenqionghe",version=version+1 WHERE id=3 AND version=0

這次變成瞭隻會更新成功一次,誰先搶到這條記錄以誰為主,因為當前一個進程更新成功後版本號已經變化瞭,第二個進程找不到這條記錄瞭。
這就是最簡單的CAS機制。

二、悲觀鎖

其實類似Go語言裡的Mutex和RwMutex讀鎖

讀鎖

也叫共享鎖或S鎖,當給數據表加上共享鎖的時候,表就變成瞭隻讀模式。
我們可以鎖全表,也可以鎖全表或部分行,如下

全表鎖(LOCK TABLE 表 READ)

語法如下

LOCK TABLE 表 READ
UNLOCK TABLE;

我們來測試一個,第一個進程執行

LOCK TABLE users READ;

第二個進程執行正常讀

SELECT * FROM users WHERE id=1;

可以正常查詢。我們再來執行一下更新

UPDATE users SET name="chenqionghe" WHERE id=1

出現瞭等待。

我們給第一個進程解鎖

再看第二個進程,已經更新成功

行鎖(SELECT … LOCK IN SHARE MODE)

BEGIN;
SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE
COMMIT;

必須配合事務使用,BEIN開始後,鎖定的行,外部隻能查詢,不能更新

我們來測試一下,第一個進程執行

BEGIN;
SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE

這裡鎖定瞭id為1和2的記錄行。我們第二個進程執行更新

UPDATE users SET name="雪山飛豬" WHERE id=1

又一次出現瞭等待。
好,這時候我們將第一個進程的事務提交

COMMIT;

第二個進程更新成功瞭,如下

寫鎖

也排他鎖、獨占鎖,理解成讀和寫都不行瞭,語法如下

全表鎖(LOCK TABLE 表 WRITE)

LOCK TABLE users WRITE;

這時候已經鎖定全表,我們再用另一個進程查詢一下id為1的數據

SELECT * FROM users WHERE id=1

可以看到,查詢已經發生瞭等待。
我們再將第一個進程解鎖

UNLOCK TABLE

這時候,第二個進程立馬查詢成功

行鎖(SELECT … FOR UPDATE)

當我們對數據進行更新的時候(INSERT、DELETE、UPDATE)的時候,數據庫會自動使用排它鎖,防止其他事務操作該數據

BEGIN;
SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE
COMMIT;

我們再來測試一下,第一個進程鎖定id為1和2的記錄

BEGIN;
SELECT * FROM users WHERE id IN (1,2) FOR UPDATE

註意:這時候事務沒提交

我們先用第二個進程來更新id為3的記錄(未被鎖定)

UPDATE users SET name="chenqionghe" WHERE id=3

執行成功瞭。
我們再來更新一個id為1的記錄

UPDATE users SET name="chenqionghe" WHERE id=1

發生瞭等待,說明已經被鎖定瞭。
好,我們提交第一個進程的事務

COMMIT;

再去看第二個進程,已經更新成功

簡單說樂觀鎖用version控制,悲觀鎖的表鎖一般用不著,行的讀鎖用LOCK IN SHARE MODE,寫鎖用FRO UPDATE,就是這麼簡單!

以上就是MySQL 加鎖控制並發的方法的詳細內容,更多關於MySQL 加鎖控制並發的資料請關註WalkonNet其它相關文章!