0%

insert

流程

我们看一个例子, mysql_insert (在sql/sql_insert.cc),精简代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
bool mysql_insert(THD *thd,
TABLE_LIST *table_list, // 该INSERT要用到的表
List<Item> &fields, // 使用的项
....) {

open_and_lock_tables(thd, table_list); // 这里的锁只是防止表结构修改

mysql_prepare_insert(...);

foreach value in values_list {
write_record(...);

}
} //里面还有很多处理trigger,错误,view之类的杂七杂八的东西,我们都忽略。

insert_record

我们接着看真正写数据的函数write_record (在sql/sql_insert.cc),精简代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
int write_record(THD thd, TABLE table,COPY_INFO *info) {  // 写数据记录
if (info->handle_duplicates == DUP_REPLACE || info->handle_duplicates == DUP_UPDATE) { //如果是REPLACE或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]);
}
}

int handler::ha_write_row(uchar *buf) { //这是啥? Handler API !
write_row(buf); // 调用具体的实现
binlog_log_row(table, 0, buf, log_func)); // 写binlog
}