浅析MySQL的Table_cache实现

struct TABLE{  TABLE_SHARE   *s; //TABLE_SHARE对象指针  handler   *file; //存储引擎句柄 对存储引擎的操作通过该对象指针操作  TABLE *next, *prev; //TABLE对象前后节点指针private:  TABLE *cache_next, **cache_prev;//用于table_cache中的list链表节点指针friend class Table_cache_element; //用于访问cache_next和cache_prev两个成员public:  THD   *in_use;            //thread 对象指针  Field **field;            //表的列的存储对象 同TABLE_SHARE中的列  uchar *record[2];         //记录数据的存储地址  uchar *write_row_record;     //THE::write_row中优化使用  uchar *insert_values;        //用于INSERT ... UPDATE  ....  KEY  *key_info;           //表定义的KEY信息 同TABLE_SHARE  ....};

class Table_cache_element{// 缓存一个表名的所有TABLE对象 一个element对象只缓存一个表名的所有TABLEprivate:  typedef I_P_List <TABLE,                    I_P_List_adapter<TABLE,                                     &TABLE::cache_next,                                     &TABLE::cache_prev> > TABLE_list;  TABLE_list used_tables; // 正在使用的TABLE对象  TABLE_list free_tables; // 可以直接使用的TABLE 对象  TABLE_SHARE *share; // TABLE_SHARE 缓存对象  }  class Table_cache {// 缓存TABLE对象 一个Table_cache包含N个不同表名的TABLE对象 HASH m_cache; // The hash of Table_cache_element objects,Table_cache_element::share::table_cache_ke作为hash的key TABLE *m_unused_tables; // 所有unused的TABLE对象};
class Table_cache_manager{  Table_cache m_table_cache[MAX_TABLE_CACHES]; // table_cache对象数组}extern Table_cache_manager table_cache_manager; // table_cache全局管理对象
HASH table_def_cache // 缓存TABLE_SHARE的hash表

el= table->s->cache_element[table_cache_manager.cache_index(thd->id)];

open_table|->get_table_def_key //库名.表名  得到对应的key|->retry_share：|->Table_cache *tc = table_cache_manager::get_cache(thd) |     //首先根据thd的m_thread_id%table_cache_instances 获取table_cache_manager.m_table_cache[i] |->table = tc->get_table(thd, key, key_length, &share)|  |->el_it = tc->m_cache.find(key_str) //一个key对应一个el 一个el对应一个TABLE_SHARE* N个TABLE*|  |->if(el_it == m_cache.end()) return NULL|  |->*share = el->share|  |->if((table = el->free_tables.front()))//从el的free_tables链表获取TABLE*对象|  |   |->el->free_tables.remove(table)|  |   |->el->used_tables.push_front(table) //close_thread时候会将table从el的used_tables移除,加入free_tables|  |->return table|->get_table_share_with_discover|   |->get_table_share|      |->my_hash_search_using_hash_value从table_def_cache中HASH查找TABLE_SHARE|      |->alloc_table_share 新建share变量赋值share的frm路径信息|      |->my_hash_insert //share插入hash表table_def_cache中|      |->open_table_def |      |  |->open_binary_frm //读取.frm文件赋值engine类型、KEY、FIELD信息|      |     |->legacy_db_type= (enum legacy_db_type) (uint) *(head+3);//获得engine类型|      |     |->share->db_plugin= ha_lock_engine //根据engine类型获得plugin对象 初始化在innobase_init中完成|      |->// 若table_def_cache记录超过table_def_size 则从hash删除oldest_unused_share|->share_found:|->if (!(flags & MYSQL_OPEN_IGNORE_FLUSH))|   |->if (share->has_old_version())|      |->release_table_share(share) // 如果TABLE_SHARE没有引用 则从table_def_cache中删除|      |->tdc_wAIt_for_old_version(lock_wait_timeout)|      |  |->TABLE_SHARE::wait_for_old_version|      |     |->m_flush_tickets.push_front(&ticket)// 增加ticket到SHARE的m_flush_tickets链表中|      |     |->thd->mdl_context->m_wait.timed_wait(thd,wait) // MDL_wait::timed_wait等待其他线程唤醒|      |->goto retry_share // 唤醒之后再次获取TABLE_SHARE|->open_table_from_share|   |->outparam->file=get_new_handler(share->db_type())|   |  |->file= db_type->create(db_type, share, alloc) |   |      |-> file->table_share=share file->ht=db_type //innobase_create_handler创建handler对象|   |  |->file->init() //handler::init()|   |->//copy share中的key、column信息赋值到TABLE中|   |->outparam->file->ha_open(TABLE,table_name,mode)|   |   |-> file->table=outparam //handler::ha_open|           |->ha_innobase::open(table_name)|              |->ib_table=open_dict_table(table_name,...,)//根据name加载innodb的系统表中的表的元数据|              |->m_prebuilt=row_create_prebuilt(ib_table,TABLE->S->reclength)//创建prebuit对象在查询数据时的元组结构|->Table_cache::add_used_table //将TABLE对象加入Table_cache中|  |->el=table->s->cache_element[this->idx] // 获取该表名在该table_cache中的el|  |->if(!el) // 如果不存在|  |  |->el= new Table_cache_element(table->s) // 创建el对象|  |  |->my_hash_insert(&m_cache, (uchar*)el) // 加入当前table_cache的el的hash链表|  |  |->table->s->cache_element[this->idx]=el // 存到TABLE_SHARE对应的el位置 其他线程访问当前table_cache使用|  |->el->used_tables.push_front(table) // TABLE对象加入el的used链表|  |->m_table_count++ |->table_found:|->thd->set_open_tables(table)|->table->init(thd, table_list)

mysql_execute_command|->close_thread_tables|  |->while (thd->open_tables)|     |->close_open_tables(thd, &thd->open_tables)|        |->close_thread_table|           |->if(!table->needs_reopen())ha_innobase::reset()//reset某些成员变量|           |->tc->lock();|           |->if(table->s->has_old_version()||table->needs_reopen())|           |  |->tc->remove_table(table) //TABLE* 从tc缓存中删除|           |  |->intern_close_table(table) //close TABLE->file 释放file对应的内存对象同时free_table_share释放share内存对象|           |->else|           |  |->tc->release_table(thd, table)//不close TABLE->file|           |     |->table->in_use = nullptr  |           |     |->//将TABLE* 指针对象从el->used_tables移除加入el->free_tables链表同时加入tc->m_unused_tables|           |->tc->unlock()|->MDL_context::release_transactional_locks //释放所有的MDL锁
intern_close_table(TABLE *table)|->closefrm(table, free_share=1)   |->table->file->ha_close()   |->release_table_share(table->s)      |->if(!--share->ref_count)//使用share open TABLE才会+1         |->if(share->has_old_version())            |->my_hash_delete(&table_def_cache, (uchar*) share)               |->table_def_free_entry(share)                  |->free_table_share(share)                     |->while(ticket=share->m_flush_tickets)                        |->ticket->get_ctx()->m_wait.set_status(MDL_wait::GRANTED) // 唤醒其他等待old_version的thread