Mysql源代码分析系列(4): 主要调用流程(续)

时间：2009-02-24 来源：li.liu

Mysql源代码分析系列(4): 主要调用流程(续)

在上一篇文章中我们讲到了的mysql_execute_command，这个函数根据解析出来的SQL命令分别调用不同的函数做进一步处理。我们这里先看"INSERT"命令的处理流程。其对应的处理函数是mysql_insert，在sql/sql_insert.cc中，还是很长，大概300多行。

bool mysql_insert(THD *thd,

TABLE_LIST *table_list, // 该命令要用到的表

List<Item> &fields, // 使用的域

List<List_item> &values_list,

List<Item> &update_fields,

List<Item> &update_values,

enum_duplicates duplic,

bool ignored) {

open_and_lock_tables(thd, table_list);

mysql_prepare_insert(...);

foreach value in values_list {

write_record(...);

}

其实里面还有很多处理trigger，错误，view之类的，我们暂时都忽略。

// 写数据记录

int write_record(THD *thd, TABLE *table,COPY_INFO *info) {

if (info->handle_duplicates == DUP_REPLACE || info->handle_duplicates == DUP_UPDATE) {

table->file->ha_write_row(table->record[0]);

table->file->ha_update_row(table->record[1], table->record[0]));

} else {

table->file->ha_write_row(table->record[0]);

}

不用说，这里我们还是省略了好多东西，要注意的是这里调用的table->file->ha_write_row和table->file->ha_update_row。在sql/table.h可以看到table的定义，其中file被定义成handler *file; 那handler是什么？对了，这就是我们前面提到的数据存储抽象层，所有的存储引擎都必须事先这里定义的接口，才能被mysql使用。在这里使用的具体的接口操作是ha_write_row和ha_update_row。这两个函数可以在sql/handler.cc中看到。比如ha_write_row:

int handler::ha_write_row(uchar *buf) {

write_row(buf); // 调用具体的实现

binlog_log_row(table, 0, buf, log_func)); // 写binlog

}

下面我们看看在myisam中是怎么实现的文件操作，代码在storage/myisam/ha_myisam.cc中。先看write_row:

723 int ha_myisam::write_row(uchar *buf)

724 {

725 ha_statistic_increment(&SSV::ha_write_count);

726

727 /* If we have a timestamp column, update it to the current time */

728 if (table->timestamp_field_type & TIMESTAMP_AUTO_SET_ON_INSERT) // 如果有timestamp域，写入当前时间。

729 table->timestamp_field->set_time();