自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

MySQL 中的 insERT 是怎么加鎖的?

數(shù)據(jù)庫 MySQL
我自認(rèn)為對(duì)常見 SQL 語句的加鎖原理已經(jīng)掌握的足夠了,但看到熱心網(wǎng)友在評(píng)論中提出的一個(gè)問題,我還是徹底被問蒙了。

[[434542]]

在之前的博客中,我寫了一系列的文章,比較系統(tǒng)的學(xué)習(xí)了 MySQL 的事務(wù)、隔離級(jí)別、加鎖流程以及死鎖,我自認(rèn)為對(duì)常見 SQL 語句的加鎖原理已經(jīng)掌握的足夠了,但看到熱心網(wǎng)友在評(píng)論中提出的一個(gè)問題,我還是徹底被問蒙了。

他的問題是這樣的:

加了插入意向鎖后,插入數(shù)據(jù)之前,此時(shí)執(zhí)行了 select...lock in share mode 語句(沒有取到待插入的值),然后插入了數(shù)據(jù),下一次再執(zhí)行 select...lock in share mode(不會(huì)跟插入意向鎖沖突),發(fā)現(xiàn)多了一條數(shù)據(jù),于是又產(chǎn)生了幻讀。會(huì)出現(xiàn)這種情況嗎?

這個(gè)問題初看上去很簡單,在 RR 隔離級(jí)別下,假設(shè)要插入的記錄不存在,如果先執(zhí)行 select...lock in share mode 語句,很顯然會(huì)在記錄間隙之間加上 GAP 鎖,而 insert 語句首先會(huì)對(duì)記錄加插入意向鎖,插入意向鎖和 GAP 鎖沖突,所以不存在幻讀;如果先執(zhí)行 insert 語句后執(zhí)行 select...lock in share mode 語句,由于 insert 語句在插入記錄之后,會(huì)對(duì)記錄加 X 鎖,它會(huì)阻止 select...lock in share mode 對(duì)記錄加 S 鎖,所以也不存在幻讀。兩種情況如下所示:

先執(zhí)行 insERT 后執(zhí)行 SELECT:

先執(zhí)行 SELECT 后執(zhí)行 insERT:

但是我們仔細(xì)想一想就會(huì)發(fā)現(xiàn)哪里有點(diǎn)不對(duì)勁,我們知道 insert 語句會(huì)先在插入間隙上加上插入意向鎖,然后開始寫數(shù)據(jù),寫完數(shù)據(jù)之后再對(duì)記錄加上 X 記錄鎖。

那么問題就來了,如果在 insert 語句加插入意向鎖之后,寫數(shù)據(jù)之前,執(zhí)行了 select...lock in share mode 語句,這個(gè)時(shí)候 GAP 鎖和插入意向鎖是不沖突的,查詢出來的記錄數(shù)為 0,然后 insert 語句寫數(shù)據(jù),加 X 記錄鎖,因?yàn)橛涗涙i和 GAP 鎖也是不沖突的,所以 insert 成功插入了一條數(shù)據(jù),這個(gè)時(shí)候如果事務(wù)提交,select...lock in share mode 語句再次執(zhí)行查詢出來的記錄數(shù)就是 1,豈不是就出現(xiàn)了幻讀?

最新面試題整理好了,點(diǎn)擊Java面試庫小程序在線刷題。

整個(gè)流程如下所示(我們把 insert 語句的執(zhí)行分成兩個(gè)階段,insERT 1 加插入意向鎖,還沒寫數(shù)據(jù),insERT 2 寫數(shù)據(jù),加記錄鎖):

一、insERT 加鎖的困惑

在得出上面的結(jié)論時(shí),我也感到很驚訝。按理是不可能出現(xiàn)這種情況的,只可能是我對(duì)這兩個(gè)語句的加鎖過程還沒有想明白。

于是我又去復(fù)習(xí)了一遍 MySQL 官方文檔,Locks Set by Different SQL Statements in InnoDB 這篇文檔對(duì)各個(gè)語句的加鎖有詳細(xì)的描述,其中對(duì) insert 的加鎖過程是這樣說的(這應(yīng)該是網(wǎng)絡(luò)上介紹 MySQL 加鎖機(jī)制被引用最多的文檔,估計(jì)也是被誤解最多的文檔):

insERT sets an exclusive lock on the inserted row. This lock is an index-record lock, not a next-key lock (that is, there is no gap lock) and does not prevent other sessions from inserting into the gap before the inserted row.

Prior to inserting the row, a type of gap lock called an insert intention gap lock is set. This lock signals the intent to insert in such a way that multiple transactions inserting into the same index gap need not wait for each other if they are not inserting at the same position within the gap. Suppose that there are index records with values of 4 and 7. Separate transactions that attempt to insert values of 5 and 6 each lock the gap between 4 and 7 with insert intention locks prior to obtaining the exclusive lock on the inserted row, but do not block each other because the rows are nonconflicting.

If a duplicate-key error occurs, a shared lock on the duplicate index record is set. This use of a shared lock can result in deadlock should there be multiple sessions trying to insert the same row if another session already has an exclusive lock. This can occur if another session deletes the row.

這里講到了 insert 會(huì)對(duì)插入的這條記錄加排他記錄鎖,在加記錄鎖之前還會(huì)加一種 GAP 鎖,叫做插入意向鎖,如果出現(xiàn)唯一鍵沖突,還會(huì)加一個(gè)共享記錄鎖。這和我之前的理解是完全一樣的,那么究竟是怎么回事呢?難道 MySQL 的 RR 真的會(huì)出現(xiàn)幻讀現(xiàn)象?

在 Google 上搜索了很久,并沒有找到 MySQL 幻讀的問題,百思不得其解之際,遂決定從 MySQL 的源碼中一探究竟。另外,MySQL 系列面試題和答案全部整理好了,微信搜索Java技術(shù)棧,在后臺(tái)發(fā)送:面試,可以在線閱讀。

二、編譯 MySQL 源碼

編譯 MySQL 的源碼非常簡單,但是中間也有幾個(gè)坑,如果能繞過這幾個(gè)坑,在本地調(diào)試 MySQL 是一件很容易的事(當(dāng)然能調(diào)試源碼是一回事,能看懂源碼又是另一回事了)。

我的環(huán)境是 Windows 10 x64,系統(tǒng)上安裝了 Visual Studio 2012,如果你的開發(fā)環(huán)境和我不一樣,編譯步驟可能也會(huì)不同。

在開始之前,首先要從官網(wǎng)下載 MySQL 源碼:

這里我選擇的是 5.6.40 版本,操作系統(tǒng)下拉列表里選 Source Code,OS Version 選擇 Windows(Architecture Independent),然后就可以下載打包好的 zip 源碼了。

將源碼解壓縮到 D:\mysql-5.6.40 目錄,在編譯之前,還需要再安裝幾個(gè)必要軟件:

  •  CMake:CMake 本身并不是編譯工具,它是通過編寫一種平臺(tái)無關(guān)的 CMakeList.txt 文件來定制編譯流程的,然后再根據(jù)目標(biāo)用戶的平臺(tái)進(jìn)一步生成所需的本地化 Makefile 和工程文件,如 Unix 的 Makefile 或 Windows 的 Visual Studio 工程;
  •  Bison:MySQL 在執(zhí)行 SQL 語句時(shí),必然要對(duì) SQL 語句進(jìn)行解析,一般來說語法解析器會(huì)包含兩個(gè)模塊:詞法分析和語法規(guī)則。詞法分析和語法規(guī)則模塊有兩個(gè)較成熟的開源工具 Flex 和 Bison 分別用來解決這兩個(gè)問題。MySQL 出于性能和靈活考慮,選擇了自己完成詞法解析部分,語法規(guī)則部分使用了 Bison,所以這里我們還要先安裝 Bison。Bison 的默認(rèn)安裝路徑為 C:\Program Files\GnuWin32,但是千萬不要這樣,一定要記得選擇一個(gè)不帶空格的目錄,譬如 C:\GnuWin32 要不然在后面使用 Visual Studio 編譯 MySQL 時(shí)會(huì)卡死;
  •  Visual Studio:沒什么好說的,Windows 環(huán)境下估計(jì)沒有比它更好的開發(fā)工具了吧。

安裝好 CMake 和 Bison 之后,記得要把它們都加到 PATH 環(huán)境變量中。做好準(zhǔn)備工作,我們就可以開始編譯了,首先用 CMake 生成 Visual Studio 的工程文件: 

  1. D:\mysql-5.6.40> mkdir project  
  2. D:\mysql-5.6.40> cd project  
  3. D:\mysql-5.6.40\project> cmake -G "Visual Studio 11 2012 Win64" .. 

cmake 的 -G 參數(shù)用于指定生成哪種類型的工程文件,這里是 Visual Studio 2012,可以直接輸入 cmake -G 查看支持的工程類型。如果沒問題,會(huì)在 project 目錄下生成一堆文件,其中 MySQL.sln 就是我們要用的工程文件,使用 Visual Studio 打開它。

打開 MySQL.sln 文件,會(huì)在 Solution Explorer 看到 130 個(gè)項(xiàng)目,其中有一個(gè)叫 ALL_BUILD,這個(gè)時(shí)候如果直接編譯,編譯會(huì)失敗,在這之前,我們還要對(duì)代碼做點(diǎn)修改:

  •  首先是 sql\sql_locale.cc 文件,看名字就知道這個(gè)文件用于國際化與本土化,這個(gè)文件里有各個(gè)國家的語言字符,但是這個(gè)文件卻是 ANSI 編碼,所以要將其改成 Unicode 編碼;
  •  打開 sql\mysqld.cc 文件的第 5239 行,將 DBUG_ASSERT(0) 改成 DBUG_ASSERT(1),要不然調(diào)試時(shí)會(huì)觸發(fā)斷言;

現(xiàn)在我們可以編譯整個(gè)工程了,選中 ALL_BUILD 項(xiàng)目,Build,然后靜靜的等待 5 到 10 分鐘,如果出現(xiàn)了 Build: 130 succeeded, 0 failed 這樣的提示,那么恭喜,你現(xiàn)在可以盡情的調(diào)試 MySQL 了。

我們將 mysqld 設(shè)置為 Startup Project,然后加個(gè)命令行參數(shù) --console,這樣可以在控制臺(tái)里查看打印的調(diào)試信息:

另外 client\Debug\mysql.exe 這個(gè)文件是對(duì)應(yīng)的 MySQL 的客戶端,可以直接雙擊運(yùn)行,默認(rèn)使用的用戶為 ODBC@localhost,如果要以 root 用戶登錄,可以執(zhí)行 mysql.exe -u root,不需要密碼。

三、調(diào)試 insERT 加鎖流程

首先我們創(chuàng)建一個(gè)數(shù)據(jù)庫 test,然后創(chuàng)建一個(gè)測試表 t,主鍵為 id,并插入測試數(shù)據(jù): 

  1. > use test;  
  2. > create table t(id int NOT NULL AUTO_INCREMENT , PRIMARY KEY (id));  
  3. > insert into t(id) values(1),(10),(20),(50); 

然后我們開兩個(gè)客戶端會(huì)話,一個(gè)會(huì)話執(zhí)行 insert into t(id) value(30),另一個(gè)會(huì)話執(zhí)行 select * from t where id = 30 lock in share mode。很顯然,如果我們能在 insert 語句加插入意向鎖之后寫數(shù)據(jù)之前下個(gè)斷點(diǎn),再在另一個(gè)會(huì)話中執(zhí)行 select 就可以模擬出這種場景了。

那么我們來找下 insert 語句是在哪加插入意向鎖的。第一次看 MySQL 源碼可能會(huì)有些不知所措,調(diào)著調(diào)著就會(huì)迷失在深深的調(diào)用層級(jí)中,我們看 insert 語句的調(diào)用堆棧,一開始時(shí)還比較容易理解,從 mysql_parse -> mysql_execute_command -> mysql_insert -> write_record -> handler::ha_write_row -> innobase::write_row -> row_insert_for_mysql,這里就進(jìn)入 InnoDb 引擎了。

然后繼續(xù)往下跟:row_ins_step -> row_ins -> row_ins_index_entry_step -> row_ins_index_entry -> row_ins_clust_index_entry -> row_ins_clust_index_entry_low -> btr_cur_optimistic_insert -> btr_cur_ins_lock_and_undo -> lock_rec_insert_check_and_lock。

一路跟下來,都沒有發(fā)現(xiàn)插入意向鎖的蹤跡,直到 lock_rec_insert_check_and_lock 這里: 

  1. if (lock_rec_other_has_conflicting(  
  2.         static_cast<enum lock_mode> 
  3.             LOCK_X | LOCK_GAP | LOCK_insERT_INTENTION),  
  4.         block, next_rec_heap_no, trx)) {   
  5.     /* Note that we may get DB_SUCCESS also here! */  
  6.     trx_mutex_enter(trx);   
  7.     err = lock_rec_enqueue_waiting 
  8.         LOCK_X | LOCK_GAP | LOCK_insERT_INTENTION,  
  9.         block, next_rec_heap_no, index, thr);  
  10.     trx_mutex_exit(trx);  
  11. } else {  
  12.     err = DB_SUCCESS 

這里是檢查是否有和插入意向鎖沖突的其他鎖,如果有沖突,就將插入意向鎖加到鎖等待隊(duì)列中。這很顯然是先執(zhí)行 select ... lock in share mode 語句再執(zhí)行 insert 語句時(shí)的情景,插入意向鎖和 GAP 沖突。但這不是我們要找的點(diǎn),于是繼續(xù)探索,但是可惜的是,直到 insert 執(zhí)行結(jié)束,我都沒有找到加插入意向鎖的地方。

跟代碼非常辛苦,我擔(dān)心是因?yàn)槲腋鷣G了某塊的邏輯導(dǎo)致沒看到加鎖,于是我看了看加其他鎖的地方,發(fā)現(xiàn)在 InnoDb 里行鎖都是通過調(diào) lock_rec_add_to_queue(沒有鎖沖突) 或者 lock_rec_enqueue_waiting(有鎖沖突,需要等待其他事務(wù)釋放鎖) 來實(shí)現(xiàn)的,于是在這兩個(gè)函數(shù)上下斷點(diǎn),執(zhí)行一條 insert 語句,依然沒有斷下來,說明 insert 語句沒有加任何鎖!

到這里我突然想起之前做過的 insert 加鎖的實(shí)驗(yàn),執(zhí)行 insert 之后,如果沒有任何沖突,在 show engine innodb status 命令中是看不到任何鎖的,這是因?yàn)?insert 加的是隱式鎖。什么是隱式鎖?隱式鎖的意思就是沒有鎖!

所以,根本就不存在之前說的先加插入意向鎖,再加排他記錄鎖的說法,在執(zhí)行 insert 語句時(shí),什么鎖都不會(huì)加。這就有點(diǎn)意思了,如果 insert 什么鎖都不加,那么如果其他事務(wù)執(zhí)行 select ... lock in share mode,它是如何阻止其他事務(wù)加鎖的呢?

答案就在于隱式鎖的轉(zhuǎn)換。

InnoDb 在插入記錄時(shí),是不加鎖的。如果事務(wù) A 插入記錄且未提交,這時(shí)事務(wù) B 嘗試對(duì)這條記錄加鎖,事務(wù) B 會(huì)先去判斷記錄上保存的事務(wù) id 是否活躍,如果活躍的話,那么就幫助事務(wù) A 去建立一個(gè)鎖對(duì)象,然后自身進(jìn)入等待事務(wù) A 狀態(tài),這就是所謂的隱式鎖轉(zhuǎn)換為顯式鎖。

我們跟一下執(zhí)行 select 時(shí)的流程,如果 select 需要加鎖,則會(huì)走:sel_set_rec_lock -> lock_clust_rec_read_check_and_lock -> lock_rec_convert_impl_to_expl,lock_rec_convert_impl_to_expl 函數(shù)的核心代碼如下: 

  1. impl_trx = trx_rw_is_active(trx_id, NULL);  
  2.  if (impl_trx != NULL  
  3.     && !lock_rec_has_expl(LOCK_X | LOCK_REC_NOT_GAP, block,  
  4.               heap_no, impl_trx)) {  
  5.     ulint    type_mode = (LOCK_REC | LOCK_X  
  6.                  | LOCK_REC_NOT_GAP);   
  7.     lock_rec_add_to_queue(  
  8.         type_mode, block, heap_no, index,  
  9.         impl_trx, FALSE);  

首先判斷事務(wù)是否活躍,然后檢查是否已存在排他記錄鎖,如果事務(wù)活躍且不存在鎖,則為該事務(wù)加上排他記錄鎖。而本事務(wù)的鎖是通過 lock_rec_convert_impl_to_expl 之后的 lock_rec_lock 函數(shù)來加的。

Spring Boot 基礎(chǔ)就不介紹了,推薦下這個(gè)實(shí)戰(zhàn)教程:

https://www.javastack.cn/categories/Spring-Boot/

到這里,這個(gè)問題的脈絡(luò)已經(jīng)很清晰了:

  1.  執(zhí)行 insert 語句,判斷是否有和插入意向鎖沖突的鎖,如果有,加插入意向鎖,進(jìn)入鎖等待;如果沒有,直接寫數(shù)據(jù),不加任何鎖;
  2.  執(zhí)行 select ... lock in share mode 語句,判斷記錄上是否存在活躍的事務(wù),如果存在,則為 insert 事務(wù)創(chuàng)建一個(gè)排他記錄鎖,并將自己加入到鎖等待隊(duì)列;

所以不存在網(wǎng)友所說的幻讀問題。那么事情到此結(jié)束了么?并沒有。

細(xì)心的你會(huì)發(fā)現(xiàn),執(zhí)行 insert 語句時(shí),從判斷是否有鎖沖突,到寫數(shù)據(jù),這兩個(gè)操作之間還是有時(shí)間差的,如果在這之間執(zhí)行 select ... lock in share mode 語句,由于此時(shí)記錄還不存在,所以也不存在活躍事務(wù),不會(huì)觸發(fā)隱式鎖轉(zhuǎn)換,這條語句會(huì)返回 0 條記錄,并加上 GAP 鎖;而 insert 語句繼續(xù)寫數(shù)據(jù),不加任何鎖,在 insert 事務(wù)提交之后,select ... lock in share mode 就能查到 1 條記錄,這豈不是還有幻讀問題嗎?

為了徹底搞清楚這中間的細(xì)節(jié),我們?cè)?lock_rec_insert_check_and_lock 檢查完鎖沖突之后下個(gè)斷點(diǎn),然后在另一個(gè)事務(wù)中執(zhí)行 select ... lock in share mode,如果它能成功返回 0 條記錄,加上 GAP 鎖,說明就存在幻讀。不過事實(shí)上,這條 SQL 語句執(zhí)行的時(shí)候卡住了,并不會(huì)返回 0 條記錄。從 show engine innodb status 的 TRANSACTIONS 里我們看不到任何行鎖沖突的信息,但是我們從 RW-LATCH INFO 中卻可以看出一些端倪: 

  1. -------------  
  2. RW-LATCH INFO  
  3. -------------  
  4. RW-LOCK: 000002C97F62FC70  
  5. Locked: thread 10304 file D:\mysql-5.6.40\storage\innobase\btr\btr0cur.cc line 879  S-LOCK  
  6. RW-LOCK: 000002C976A3B998  
  7. Locked: thread 10304 file D:\mysql-5.6.40\storage\innobase\btr\btr0cur.cc line 256  S-LOCK  
  8. Locked: thread 10304 file d:\mysql-5.6.40\storage\innobase\include\btr0pcur.ic line 518  S-LOCK  
  9. Locked: thread 2820 file D:\mysql-5.6.40\storage\innobase\btr\btr0cur.cc line 256  S-LOCK  
  10. Locked: thread 2820 file D:\mysql-5.6.40\storage\innobase\row\row0ins.cc line 2339  S-LOCK  
  11. RW-LOCK: 000002C976A3B8A8  Waiters for the lock exist  
  12. Locked: thread 2820 file D:\mysql-5.6.40\storage\innobase\btr\btr0cur.cc line 256  X-LOCK  
  13. Total number of rw-locks 16434  
  14. OS WAIT ARRAY INFO: reservation count 10  
  15. --Thread 10304 has waited at btr0cur.cc line 256 for 26.00 seconds the semaphore:  
  16. S-lock on RW-latch at 000002C976A3B8A8 created in file buf0buf.cc line 1069  
  17. a writer (thread id 2820) has reserved it in mode  exclusive  
  18. number of readers 0, waiters flag 1, lock_word: 0  
  19. Last time read locked in file btr0cur.cc line 256  
  20. Last time write locked in file D:\mysql-5.6.40\storage\innobase\btr\btr0cur.cc line 256  
  21. OS WAIT ARRAY INFO: signal count 8  
  22. Mutex spin waits 44, rounds 336, OS waits 7  
  23. RW-shared spins 3, rounds 90, OS waits 3  
  24. RW-excl spins 0, rounds 0, OS waits 0  
  25. Spin rounds per wait: 7.64 mutex, 30.00 RW-shared, 0.00 RW-excl 

這里列出了 3 個(gè) RW-LOCK:000002C97F62FC70、000002C976A3B998、000002C976A3B8A8。其中可以看到最后一個(gè) RW-LOCK 有其他線程在等待其釋放(Waiters for the lock exist)。下面列出了所有等待該鎖的線程,Thread 10304 has waited at btr0cur.cc line 256 for 26.00 seconds the semaphore,這里的 Thread 10304 就是我們正在執(zhí)行 select 語句的線程,它卡在了 btr0cur.cc 的 256 行,我們查看 Thread 10304 的堆棧:

btr0cur.cc 的 256 行位于 btr_cur_latch_leaves 函數(shù),如下所示,通過 btr_block_get 來加鎖,看起來像是在訪問 InnoDb B+ 樹的葉子節(jié)點(diǎn)時(shí)卡住了: 

  1. case BTR_MODIFY_LEAF:  
  2.     mode = latch_mode == BTR_SEARCH_LEAF ? RW_S_LATCH : RW_X_LATCH;  
  3.     get_block = btr_block_get 
  4.         space, zip_size, page_no, mode, cursor->index, mtr); 

這里的 latch_mode == BTR_SEARCH_LEAF,所以加鎖的 mode 為 RW_S_LATCH。

這里要介紹一個(gè)新的概念,叫做 Latch,一般也把它翻譯成 “鎖”,但它和我們之前接觸的行鎖表鎖(Lock)是有區(qū)別的。這是一種輕量級(jí)的鎖,鎖定時(shí)間一般非常短,它是用來保證并發(fā)線程可以安全的操作臨界資源,通常沒有死鎖檢測機(jī)制。Latch 可以分為兩種:MUTEX(互斥量)和 RW-LOCK(讀寫鎖),很顯然,這里我們看到的是 RW-LOCK。

我們回溯一下 select 語句的調(diào)用堆棧:ha_innobase::index_read -> row_search_for_mysql -> btr_pcur_open_at_index_side -> btr_cur_latch_leaves,從調(diào)用堆??梢钥闯?select ... lock in share mode 語句在訪問索引,那么為什么訪問索引會(huì)被卡住呢?

接下來我們看看這個(gè) RW-LOCK 是在哪里加上的?從日志里可以看到 Locked: thread 2820 file D:\mysql-5.6.40\storage\innobase\btr\btr0cur.cc line 256 X-LOCK,所以這個(gè)鎖是線程 2820 加上的,加鎖的位置也在 btr0cur.cc 的 256 行,查看函數(shù)引用,很快我們就查到這個(gè)鎖是在執(zhí)行 insert 時(shí)加上的,函數(shù)堆棧為:row_ins_clust_index_entry_low -> btr_cur_search_to_nth_level -> btr_cur_latch_leaves。

我們看這里的 row_ins_clust_index_entry_low 函數(shù)(無關(guān)代碼已省略): 

  1. UNIV_INTERN  
  2. dberr_t  
  3. row_ins_clust_index_entry_low(  
  4. /*==========================*/  
  5.     ulint        flags,    /*!< in: undo logging and locking flags */  
  6.     ulint        mode,    /*!< in: BTR_MODIFY_LEAF or BTR_MODIFY_TREE,  
  7.                 depending on whether we wish optimistic or  
  8.                 pessimistic descent down the index tree */  
  9.     dict_index_t*    index,    /*!< in: clustered index */  
  10.     ulint        n_uniq,    /*!< in: 0 or index->n_uniq */  
  11.     dtuple_t*    entry,    /*!< in/out: index entry to insert */  
  12.     ulint        n_ext,    /*!< in: number of externally stored columns */  
  13.     que_thr_t*    thr)    /*!< in: query thread */  
  14.     /* 開啟一個(gè) mini-transaction */  
  15.     mtr_start(&mtr);   
  16.      /* 調(diào)用 btr_cur_latch_leaves -> btr_block_get 加 RW_X_LATCH */  
  17.     btr_cur_search_to_nth_level(index, 0, entry, PAGE_CUR_LE, mode,  
  18.                     &cursor, 0, __FILE__, __LINE__, &mtr);     
  19.      if (mode != BTR_MODIFY_TREE) {  
  20.         /* 不需要修改 BTR_TREE,樂觀插入 */
  21.         err = btr_cur_optimistic_insert 
  22.             flags, &cursor, &offsets, &offsets_heap,  
  23.             entry, &insert_rec, &big_rec,  
  24.             n_ext, thr, &mtr);  
  25.     } else {  
  26.         /* 需要修改 BTR_TREE,先樂觀插入,樂觀插入失敗則進(jìn)行悲觀插入 */  
  27.         err = btr_cur_optimistic_insert 
  28.             flags, &cursor,  
  29.             &offsets, &offsets_heap,  
  30.             entry, &insert_rec, &big_rec,  
  31.             n_ext, thr, &mtr);  
  32.         if (err == DB_FAIL) {  
  33.             err = btr_cur_pessimistic_insert 
  34.                 flags, &cursor,  
  35.                 &offsets, &offsets_heap,  
  36.                 entry, &insert_rec, &big_rec,  
  37.                 n_ext, thr, &mtr);  
  38.         }  
  39.     }    
  40.      /* 提交 mini-transaction */  
  41.     mtr_commit(&mtr);  

這里是執(zhí)行 insert 語句的關(guān)鍵,可以發(fā)現(xiàn)執(zhí)行插入操作的前后分別有一行代碼:mtr_start() 和 mtr_commit()。這被稱為 迷你事務(wù)(mini-transaction),既然叫做事務(wù),那這個(gè)函數(shù)的操作肯定是原子性的,事實(shí)上確實(shí)如此,insert 會(huì)在檢查鎖沖突和寫數(shù)據(jù)之前,會(huì)對(duì)記錄所在的頁加一個(gè) RW-X-LATCH 鎖,執(zhí)行完寫數(shù)據(jù)之后再釋放該鎖(實(shí)際上寫數(shù)據(jù)的操作就是寫 redo log(重做日志),將臟頁加入 flush list,這個(gè)后面有時(shí)間再深入分析了)。

這個(gè)鎖的釋放非???,但是這個(gè)鎖足以保證在插入數(shù)據(jù)的過程中其他事務(wù)無法訪問記錄所在的頁。mini-transaction 也可以包含子事務(wù),實(shí)際上在 insert 的執(zhí)行過程中就會(huì)加多個(gè) mini-transaction。

另外,關(guān)注公眾號(hào)Java技術(shù)棧,在后臺(tái)回復(fù):面試,可以獲取我整理的 Java/ MySQL 系列面試題和答案,非常齊全。

每個(gè) mini-transaction 會(huì)遵守下面的幾個(gè)規(guī)則:

  •  修改一個(gè)頁需要獲得該頁的 X-LATCH;
  •  訪問一個(gè)頁需要獲得該頁的 S-LATCH 或 X-LATCH;
  •  持有該頁的 LATCH 直到修改或者訪問該頁的操作完成。

所以,最后的最后,真相只有一個(gè):insert 和 select ... lock in share mode 不會(huì)發(fā)生幻讀。整個(gè)流程如下:

  •  執(zhí)行 insert 語句,對(duì)要操作的頁加 RW-X-LATCH,然后判斷是否有和插入意向鎖沖突的鎖,如果有,加插入意向鎖,進(jìn)入鎖等待;如果沒有,直接寫數(shù)據(jù),不加任何鎖,結(jié)束后釋放 RW-X-LATCH;
  •  執(zhí)行 select ... lock in share mode 語句,對(duì)要操作的頁加 RW-S-LATCH,如果頁面上存在 RW-X-LATCH 會(huì)被阻塞,沒有的話則判斷記錄上是否存在活躍的事務(wù),如果存在,則為 insert 事務(wù)創(chuàng)建一個(gè)排他記錄鎖,并將自己加入到鎖等待隊(duì)列,最后也會(huì)釋放 RW-S-LATCH。
責(zé)任編輯:龐桂玉 來源: Java技術(shù)棧
相關(guān)推薦

2024-03-06 08:18:22

語句GreatSQL

2010-10-08 14:23:08

MySQL中INSER

2011-07-22 16:59:30

MySQL數(shù)據(jù)庫嵌套查詢

2010-05-27 14:47:14

MySQL INSER

2017-08-30 18:15:54

MySql

2023-10-26 14:30:05

MySQLInnoDB

2010-09-07 13:50:41

SQL語句

2024-03-15 08:06:58

MySQLJOIN命令

2017-05-15 18:00:43

MySQ加鎖處理

2024-12-16 17:02:58

MySQLInnoDB數(shù)據(jù)庫

2018-06-12 15:30:07

數(shù)據(jù)庫MySQLinsert

2023-03-27 17:58:34

MySQL加鎖間隙鎖

2011-03-11 09:53:46

FacebookMySQL

2020-06-04 07:51:30

MySQL死鎖加鎖

2010-08-31 15:08:14

DB2INSERT優(yōu)化

2024-01-15 08:08:27

2021-06-04 11:10:04

JavaScript開發(fā)代碼

2021-07-26 10:32:54

MySQL數(shù)據(jù)庫存儲(chǔ)

2021-08-06 06:49:19

王者榮耀項(xiàng)目IDEA

2020-12-14 12:17:47

MySQL記錄語句
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)