继续上一篇文章：mysql 8.0 一条insert语句的具体执行流程分析(一)_一缕阳光的博客-CSDN博客

由于最近换工作一直在试用期内，在拼命的学习、总结中，因此没有时间写文章，今天转正了腾出来时间继续写下一篇文章。mysql 8.0 一条insert语句的具体执行流程分析写完了write_record部分，下面将会运行到engine层，主要存储引擎的接口

代码版本：mysql 8.0.22

编程语言：c++ && c++11 && c++14 && c++17

这里使用MySQL InnoDB存储引擎，存储引擎接口涉及多个文件，由于内容过多，分下面几个部分进行分开描述，代码是按下面的章节顺序执行的。

| > handler::ha_write_row
| | > ha_innobase::write_row
| | | > row_insert_for_mysql
| | | | > row_insert_for_mysql_using_ins_graph
| | | | | > trx_start_if_not_started_xa> trx_start_if_not_started_xa_low> trx_start_low                 
| | | | | > row_mysql_convert_row_to_innobase
| | | | | > row_ins_step     

(1)、ha_write_row : 用于插入一条记录

int handler::ha_write_row(uchar *buf) {......// 主要是调用这个ha_innobase::write_rowMYSQL_TABLE_IO_WAIT(PSI_TABLE_WRITE_ROW, MAX_KEY, error,{ error = write_row(buf); })return 0;
}

(2)、write_row : 在InnoDB database中存储一行数据，针对这张表对应的handle

int ha_innobase::write_row(uchar *record) {......update_auto_increment();  // 更新自增建.../* Execute insert graph that will result in actual insert. */error = row_insert_for_mysql((byte *)record, m_prebuilt);}

其中里面会更新自增键，如果建表语句中有自增列。

(3)、row_insert_for_mysql : 执行insert操作

这个函数比较简单，直接透传到下面的函数中了

/** Does an insert for MySQL.
@param[in]	mysql_rec	row in the MySQL format
@param[in,out]	prebuilt	prebuilt struct in MySQL handle
@return error code or DB_SUCCESS*/
dberr_t row_insert_for_mysql(const byte *mysql_rec, row_prebuilt_t *prebuilt) {/* For intrinsic tables there a lot of restrictions that can berelaxed including locking of table, transaction handling, etc.Use direct cursor interface for inserting to intrinsic tables. */if (prebuilt->table->is_intrinsic()) {return (row_insert_for_mysql_using_cursor(mysql_rec, prebuilt));} else {return (row_insert_for_mysql_using_ins_graph(mysql_rec, prebuilt));}
}

(4)、row_insert_for_mysql_using_ins_graph : 使用graph结构存储insert的信息

static dberr_t row_insert_for_mysql_using_ins_graph(const byte *mysql_rec,row_prebuilt_t *prebuilt) { ......row_mysql_convert_row_to_innobase(node->row, prebuilt, mysql_rec, &blob_heap);run_again:thr->run_node = node;thr->prev_node = node;row_ins_step(thr); // 向一个table中插入一行...
}

(5)、trx_start_if_not_started_xa : 这部分是开启XA事务

(6)、row_mysql_convert_row_to_innobase : 将一行数据从MySQL格式转换为innodb格式

(7)、row_ins_step : 向一个table中插入一行

| > row_ins_step
| | > row_ins
| | | > row_ins_index_entry_step
| | | | > row_ins_index_entry> row_ins_clust_index_entry> row_ins_sec_index_multi_value_entry      > row_ins_sec_index_entry   

(8)、row_ins_step : 向表中插入一行，会调用下面的row_ins

/** Inserts a row to a table. This is a high-level function used in SQLexecution graphs.@return query thread to run next or NULL */
que_thr_t *row_ins_step(que_thr_t *thr) /*!< in: query thread */
{...err = row_ins(node, thr);...return (thr);
}

(9)、row_ins : 向表中插入一行

(10)、row_ins_index_entry_step : 向表中插入index

(11)、row_ins_index_entry :

    (1)、row_ins_clust_index_entry : 聚集索引执行这个分支

    (2)、row_ins_sec_index_multi_value_entry : 使用二级索引多个value值时，执行这个分支

    (3)、row_ins_sec_index_entry : 二级索引执行这个分支

本篇文章先写到这里，下一篇文章主要讲述使用二级索引时的执行流程。

题外话：跟公司签了3年合同，试用期6个月，是不是试用期太长了，国家规定的也是6个月吗？如果比较清楚这个事，请告知我(zgaoq@163.com)，谢谢