校园春色亚洲色图_亚洲视频分类_中文字幕精品一区二区精品_麻豆一区区三区四区产品精品蜜桃

主頁 > 知識庫 > 詳解MySQL多版本并發控制機制(MVCC)源碼

詳解MySQL多版本并發控制機制(MVCC)源碼

熱門標簽:高清地圖標注道路 云南電商智能外呼系統價格 400電話可以辦理嗎 話務外呼系統怎么樣 拉卡拉外呼系統 外東北地圖標注 臨清電話機器人 智能外呼系統復位 大眾點評星級酒店地圖標注

一、前言

作為一個數據庫愛好者,自己動手寫過簡單的SQL解析器以及存儲引擎,但感覺還是不夠過癮。事務處理-概念與技術>>誠然講的非常透徹,但只能提綱挈領,不能讓你玩轉某個真正的數據庫。感謝cmake,能夠讓我在mac上用xcode去debug MySQL,從而能去領略它的各種實現細節。

(注:本文的MySQL采用的是MySQL-5.6.35版本)

二、MVCC(多版本并發控制機制)

隔離性也可以被稱作并發控制、可串行化等。談到并發控制首先想到的就是鎖,MySQL通過使用兩階段鎖的方式實現了更新的可串行化,同時為了加速查詢性能,采用了MVCC(Multi Version Concurrency Control)的機制,使得不用鎖也可以獲取一致性的版本。

2.1、Repeatable Read

MySQL的通過MVCC以及(Next-Key Lock)實現了可重復讀(Repeatable Read),其思想(MVCC)就是記錄數據的版本變遷,通過精巧的選擇不同數據的版本從而能夠對用戶呈現一致的結果。如下圖所示:

上圖中,(A=50|B=50)的初始版本為1。

1.事務t1在select A時候看到的版本為1,即A=50

2.事務t2對A和B的修改將版本升級為2,即A=0,B=100

3.事務t1再此select B的時候看到的版本還是1, 即B=50

這樣就隔離了版本的影響,A+B始終為100。

2.2、Read Commit

而如果不通過版本控制機制,而是讀到最近提交的結果的話,則隔離級別是read commit,如下圖所示:

在這種情況下,就需要使用鎖機制(例如select for update)將此A,B記錄鎖住,從而獲得正確的一致結果,如下圖所示:

2.3、MVCC的優勢

當我們要對一些數據做一些只讀操作來檢查一致性,例如檢查賬務是否對齊的操作時候,并不希望加上對性能損耗很大的鎖。這時候MVCC的一致性版本就有很大的優勢了。

三、MVCC(實現機制)

本節就開始談談MVCC的實現機制,注意MVCC僅僅在純select時有效(不包括select for update,lock in share mode等加鎖操作,以及update\insert等)。

3.1、select運行棧

首先我們追蹤一下一條普通的查詢sql在mysql源碼中的運行過程,sql為(select * from test);

其運行棧為:

handle_one_connection  MySQL的網絡模型是one request one thread

 |-do_handle_one_connection

|-do_command

|-dispatch_command

|-mysql_parse 解析SQL

|-mysql_execute_command

|-execute_sqlcom_select 執行select語句

|-handle_select

...一堆parse join 等的操作,當前并不關心

|-*tab->read_record.read_record 讀取記錄

由于mysql默認隔離級別是repeatable_read(RR),所以read_record重載為
rr_sequential(當前我們并不關心select通過index掃描出row之后再通過condition過濾的過程)。繼續追蹤:

read_record

 |-rr_sequential

|-ha_rnd_next

|-ha_innobase::rnd_next 這邊就已經到了innodb引擎了

|-general_fetch

|-row_search_for_mysql

|-lock_clust_rec_cons_read_sees 這邊就是判斷并選擇版本的地方

讓我們看下該函數內部:

bool lock_clust_rec_cons_read_sees(const rec_t* rec /*由innodb掃描出來的一行*/,....){
	...
	// 從當前掃描的行中獲取其最后修改的版本trx_id(事務id)
	trx_id = row_get_rec_trx_id(rec, index, offsets);
	// 通過參數(一致性快照視圖和事務id)決定看到的行快照
	return(read_view_sees_trx_id(view, trx_id));
}

3.2、read_view的創建過程

我們先關注一致性視圖的創建過程,我們先看下read_view結構:

struct read_view_t{
	// 由于是逆序排列,所以low/up有所顛倒
	// 能看到當前行版本的高水位標識,>= low_limit_id皆不能看見
	trx_id_t	low_limit_id;
	// 能看到當前行版本的低水位標識, up_limit_id皆能看見
	trx_id_t	up_limit_id;
	// 當前活躍事務(即未提交的事務)的數量
	ulint		n_trx_ids;
	// 以逆序排列的當前獲取活躍事務id的數組
	// 其up_limit_idtx_idlow_limit_id
	trx_id_t*	trx_ids;	
	// 創建當前視圖的事務id
	trx_id_t	creator_trx_id;
	// 事務系統中的一致性視圖鏈表
	UT_LIST_NODE_T(read_view_t) view_list;
};

然后通過debug,發現創建read_view結構也是在上述的rr_sequential中操作的,繼續跟蹤調用棧:

rr_sequential

 |-ha_rnd_next

  |-rnd_next

  |-index_first 在start_of_scan為true時候走當前分支index_first

  |-index_read

  |-row_search_for_mysql

  |-trx_assign_read_view

我們看下row_search_for_mysql里的一個分支:

row_search_for_mysql:
// 這邊只有select不加鎖模式的時候才會創建一致性視圖
else if (prebuilt->select_lock_type == LOCK_NONE) {		// 創建一致性視圖
		trx_assign_read_view(trx);
		prebuilt->sql_stat_start = FALSE;
}

上面的注釋就是select for update(in share model)不會走MVCC的原因。讓我們進一步分析trx_assign_read_view函數:

trx_assign_read_view

 |-read_view_open_now

  |-read_view_open_now_low

好了,終于到了創建read_view的主要階段,主要過程如下圖所示:

代碼過程為:

static read_view_t* read_view_open_now_low(trx_id_t	cr_trx_id,mem_heap_t*	heap)
{
	read_view_t*	view;
	// 當前事務系統中max_trx_id(即尚未被分配的trx_id)設置為low_limit_no
	view->low_limit_no = trx_sys->max_trx_id;
	view->low_limit_id = view->low_limit_no;
	// CreateView構造函數,會將非當前事務和已經在內存中提交的事務給剔除,即判斷條件為
	// trx->id != m_view->creator_trx_id !trx_state_eq(trx, TRX_STATE_COMMITTED_IN_MEMORY)的
	// 才加入當前視圖列表
	ut_list_map(trx_sys->rw_trx_list, trx_t::trx_list, CreateView(view));
	if (view->n_trx_ids > 0) {
		// 將當前事務系統中的最小id設置為up_limit_id,因為是逆序排列
		view->up_limit_id = view->trx_ids[view->n_trx_ids - 1];
	} else {
		// 如果當前沒有非當前事務之外的活躍事務,則設置為low_limit_id
		view->up_limit_id = view->low_limit_id;
	}
	// 忽略purge事務,purge時,當前事務id是0
	if (cr_trx_id > 0) {
		read_view_add(view);
	}
	// 返回一致性視圖
	return(view);
}

3.3、行版本可見性

由上面的lock_clust_rec_cons_read_sees可知,行版本可見性由read_view_sees_trx_id函數判斷:

/*********************************************************************//**
Checks if a read view sees the specified transaction.
@return	true if sees */
UNIV_INLINE
bool
read_view_sees_trx_id(
/*==================*/
	const read_view_t*	view,	/*! in: read view */
	trx_id_t		trx_id)	/*! in: trx id */
{
	if (trx_id  view->up_limit_id) {

		return(true);
	} else if (trx_id >= view->low_limit_id) {

		return(false);
	} else {
		ulint	lower = 0;
		ulint	upper = view->n_trx_ids - 1;

		ut_a(view->n_trx_ids > 0);

		do {
			ulint		mid	= (lower + upper) >> 1;
			trx_id_t	mid_id	= view->trx_ids[mid];

			if (mid_id == trx_id) {
				return(FALSE);
			} else if (mid_id  trx_id) {
				if (mid > 0) {
					upper = mid - 1;
				} else {
					break;
				}
			} else {
				lower = mid + 1;
			}
		} while (lower = upper);
	}

	return(true);
}

其實上述函數就是一個二分法,read_view其實保存的是當前活躍事務的所有事務id,如果當前行版本對應修改的事務id不在當前活躍事務里面的話,就返回true,表示當前版本可見,否則就是不可見,如下圖所示。

接上述lock_clust_rec_cons_read_sees的返回:

if (UNIV_LIKELY(srv_force_recovery  5)
			     !lock_clust_rec_cons_read_sees(
				    rec, index, offsets, trx->read_view)){
	// 當前處理的是當前版本不可見的情況
	// 通過undolog來返回到一致的可見版本
	err = row_sel_build_prev_vers_for_mysql(
					trx->read_view, clust_index,
					prebuilt, rec, offsets, heap,
					old_vers, mtr);			    
} else{
	// 可見,然后返回
}

3.4、undolog搜索可見版本的過程

我們現在考察一下row_sel_build_prev_vers_for_mysql函數:

row_sel_build_prev_vers_for_mysql

 |-row_vers_build_for_consistent_read

主要是調用了row_ver_build_for_consistent_read方法返回可見版本:

dberr_t row_vers_build_for_consistent_read(...)
{
	......
	for(;;){
		err = trx_undo_prev_version_build(rec, mtr,version,index,*offsets, heap,prev_version);
		......
		trx_id = row_get_rec_trx_id(prev_version, index, *offsets);
		// 如果當前row版本符合一致性視圖,則返回
		if (read_view_sees_trx_id(view, trx_id)) {
			......
			break;
		}
		// 如果當前row版本不符合,則繼續回溯上一個版本(回到for循環的地方)
		version = prev_version;
	}
	......
}

整個過程如下圖所示:

至于undolog怎么恢復出對應版本的row記錄就又是一個復雜的過程了,由于篇幅原因,在此略過不表。

3.5、read_view創建時機再討論

在創建一致性視圖的row_search_for_mysql的代碼中

// 只有非鎖模式的select才創建一致性視圖
else if (prebuilt->select_lock_type == LOCK_NONE) {		// 創建一致性視圖
		trx_assign_read_view(trx);
		prebuilt->sql_stat_start = FALSE;
}

trx_assign_read_view中由這么一段代碼

// 一致性視圖在一個事務只創建一次
if (!trx->read_view) {
		trx->read_view = read_view_open_now(
			trx->id, trx->global_read_view_heap);
		trx->global_read_view = trx->read_view;
	}

所以綜合這兩段代碼,即在一個事務中,只有第一次運行select(不加鎖)的時候才會創建一致性視圖,如下圖所示:

筆者構造了此種場景模擬過,確實如此。

四、MVCC和鎖的同時作用導致的一些現象

MySQL是通過MVCC和二階段鎖(2PL)來兼顧性能和一致性的,但是由于MySQL僅僅在select時候才創建一致性視圖,而在update等加鎖操作的時候并不做如此操作,所以就會產生一些詭異的現象。如下圖所示:

如果理解了update不走一致性視圖(read_view),而select走一致性視圖(read_view),就可以很好解釋這個現象。
如下圖所示:

五、總結

MySQL為了兼顧性能和ACID使用了大量復雜的機制,2PL(兩階段鎖)和MVCC就是其實現的典型。幸好可以通過xcode等IDE進行方便的debug,這樣就可以非常精確加便捷的追蹤其各種機制的實現。希望這篇文章能夠幫助到喜歡研究MySQL源碼的讀者們。

以上就是詳解MySQL多版本并發控制機制(MVCC)源碼的詳細內容,更多關于MySQL 并發控制機制 MVCC的資料請關注腳本之家其它相關文章!

您可能感興趣的文章:
  • MySQL系列之十 MySQL事務隔離實現并發控制
  • mysql的MVCC多版本并發控制的實現
  • MySQL高并發生成唯一訂單號的方法實現
  • MySQL 加鎖控制并發的方法
  • Mysql事務并發問題解決方案
  • MySQL 數據庫如何解決高并發問題
  • mysql并發控制原理知識點
  • mysql多版本并發控制MVCC的實現
  • MySQL并發更新數據時的處理方法
  • Tomcat+Mysql高并發配置優化講解
  • MySQL 到底是如何做到多版本并發的?

標簽:山西 阿里 福州 溫州 揚州 三明 無錫 定西

巨人網絡通訊聲明:本文標題《詳解MySQL多版本并發控制機制(MVCC)源碼》,本文關鍵詞  詳解,MySQL,多,版本,并發,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《詳解MySQL多版本并發控制機制(MVCC)源碼》相關的同類信息!
  • 本頁收集關于詳解MySQL多版本并發控制機制(MVCC)源碼的相關信息資訊供網民參考!
  • 推薦文章
    校园春色亚洲色图_亚洲视频分类_中文字幕精品一区二区精品_麻豆一区区三区四区产品精品蜜桃
    天堂成人免费av电影一区| 国产精品久久看| 亚洲电影视频在线| 成人h动漫精品一区二区| 欧美精品久久久久久久多人混战| 欧美国产国产综合| 久久精品国产99| 欧美人与禽zozo性伦| 国产精品传媒视频| 狠狠色综合色综合网络| 欧美在线三级电影| 国产精品福利av| 国产一区二区三区观看| 欧美日韩视频不卡| 一区二区三区中文字幕| 国产91精品在线观看| 日韩精品一区二区三区三区免费| 亚洲成人手机在线| 91高清视频免费看| 136国产福利精品导航| 高清成人免费视频| 久久亚区不卡日本| 国产综合色视频| 日韩一区二区三区在线观看| 亚洲成人www| 欧美午夜电影一区| 亚洲免费av观看| 99re这里都是精品| 成人欧美一区二区三区1314| 国产成人精品一区二区三区四区| 26uuu欧美| 精品亚洲aⅴ乱码一区二区三区| 欧美一区永久视频免费观看| 天天影视涩香欲综合网| 欧美日韩精品三区| 午夜婷婷国产麻豆精品| 欧美色综合网站| 亚洲国产精品影院| 欧美色窝79yyyycom| 亚洲伊人伊色伊影伊综合网| 91久久线看在观草草青青| 亚洲手机成人高清视频| 色婷婷综合久久久中文一区二区| 亚洲精品成人天堂一二三| 欧洲一区二区三区在线| 亚洲午夜精品在线| 欧美二区乱c少妇| 蜜桃一区二区三区在线| 欧美成人精品高清在线播放| 精一区二区三区| 久久亚洲影视婷婷| 国产成人免费视频精品含羞草妖精| 久久久电影一区二区三区| 国产ts人妖一区二区| 国产精品日韩成人| 成人avav影音| 一区二区三区四区在线播放| 欧美日韩在线亚洲一区蜜芽| 偷拍亚洲欧洲综合| 欧美一区二区大片| 国产老妇另类xxxxx| 中文字幕在线视频一区| 色先锋资源久久综合| 婷婷丁香久久五月婷婷| 欧美xxxxx牲另类人与| 国产酒店精品激情| 国产精品国产三级国产aⅴ入口 | 激情小说欧美图片| 久久久久9999亚洲精品| 99麻豆久久久国产精品免费优播| 亚洲欧美另类小说视频| 欧美二区乱c少妇| 国产精品自拍三区| 亚洲精品乱码久久久久久久久| 在线成人小视频| 国产露脸91国语对白| 亚洲免费看黄网站| 欧美一区二区网站| 国产+成+人+亚洲欧洲自线| 亚洲最大的成人av| 日韩午夜小视频| 不卡av电影在线播放| 亚洲图片欧美视频| 久久久综合九色合综国产精品| 97久久超碰国产精品| 青草国产精品久久久久久| 久久久噜噜噜久久人人看| 日本高清不卡视频| 久久疯狂做爰流白浆xx| 亚洲欧美日韩综合aⅴ视频| 日韩亚洲欧美中文三级| av日韩在线网站| 男女激情视频一区| 1区2区3区国产精品| 日韩一级视频免费观看在线| 成人激情小说网站| 日本91福利区| 自拍偷拍欧美激情| 精品国产一区二区在线观看| 不卡的av网站| 3d动漫精品啪啪1区2区免费| 国产高清无密码一区二区三区| 一区二区三区日韩在线观看| 久久综合视频网| 欧美日韩一区在线| 大陆成人av片| 奇米888四色在线精品| 亚洲女女做受ⅹxx高潮| 精品久久久久久无| 欧美唯美清纯偷拍| 国产白丝网站精品污在线入口| 日韩avvvv在线播放| 国产精品高潮呻吟久久| 精品国产露脸精彩对白| 欧美三级电影一区| 96av麻豆蜜桃一区二区| 韩国女主播一区| 午夜精品久久久久久久久久| 国产精品国模大尺度视频| 精品国精品国产| 5月丁香婷婷综合| 色天天综合久久久久综合片| 豆国产96在线|亚洲| 蜜臀久久99精品久久久久久9| 亚洲精选一二三| 国产精品乱码人人做人人爱 | 欧美私人免费视频| jlzzjlzz亚洲日本少妇| 国产美女娇喘av呻吟久久| 图片区小说区国产精品视频| 一区二区三区免费在线观看| 中文字幕一区二区在线播放| 国产色产综合产在线视频| 日韩欧美国产电影| 337p亚洲精品色噜噜狠狠| 欧美性受xxxx黑人xyx| 99精品偷自拍| 成人高清免费在线播放| 国产成人综合亚洲网站| 国产一区高清在线| 美国精品在线观看| 日本不卡视频在线| 秋霞午夜鲁丝一区二区老狼| 香蕉av福利精品导航| 亚洲午夜免费电影| 亚洲免费伊人电影| 亚洲欧洲综合另类| 一区精品在线播放| 国产精品精品国产色婷婷| 国产精品短视频| 国产精品成人免费在线| 国产精品久久久久永久免费观看| 中文字幕欧美日本乱码一线二线| 国产免费成人在线视频| 亚洲国产精品av| 国产精品无遮挡| 国产精品视频观看| 亚洲国产精品激情在线观看| 国产精品欧美极品| 中文字幕亚洲综合久久菠萝蜜| 国产精品麻豆久久久| 国产精品乱人伦中文| 最近日韩中文字幕| 一区二区三区日韩精品视频| 一区二区三区在线视频观看58 | 国产网站一区二区| 国产日韩欧美一区二区三区乱码| 久久久久久久电影| 中文文精品字幕一区二区| 国产精品久线在线观看| 亚洲女同ⅹxx女同tv| 曰韩精品一区二区| 婷婷夜色潮精品综合在线| 首页欧美精品中文字幕| 美国毛片一区二区| 国产精品亚洲午夜一区二区三区 | 国产成人在线视频网站| 成人福利视频在线| 日本精品免费观看高清观看| 精品视频在线免费看| 欧美电影免费观看高清完整版在线观看| 欧美α欧美αv大片| 欧美激情在线观看视频免费| 亚洲欧美电影院| 视频一区二区三区中文字幕| 久草这里只有精品视频| 国产成人av一区| 91一区一区三区| 欧美高清你懂得| 欧美精品一区二区高清在线观看| 国产欧美日韩激情| 尤物av一区二区| 日本女人一区二区三区| 国产精品99久久久久久似苏梦涵| 91免费版在线看| 日韩一区二区免费在线观看| 久久久精品tv| 亚洲综合在线免费观看| 久久99这里只有精品| fc2成人免费人成在线观看播放|