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
}
|