上面的注释就是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); } 行版本可见性:由上面的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{ // 可见，然后返回 } 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记录就又是一个复杂的过程了，由于篇幅原因，在此略过不表。 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; }