MySQL源码之两阶段提交
在双1的情况下，两阶段提交的过程
环境准备：mysql 5.5.18, innodb 1.1
version
配置:
sync_binlog=1
innodb_flush_log_at_trx_commit=1
autocommit=0
设置断点:
sql_parse.cc::dispatch_command
--命令跳转入口
sql_parse.cc::mysql_parse
sql_parse.cc::mysql_execute_command
sql_parse.cc::trans_commit_stmt
--语句commit入口
handler.cc::ha_commit_trans
--commit入口
log.cc::binlog_prepare --binlog
prepare入口
Ha_innodb.cc::innobase_xa_prepare --innodb prepare入口
log.cc::binlog_commit --binlog
commit入口
Ha_innodb.cc::innobase_commit --innodb commit入口
实验步骤
步骤1：
1 use test; 2 create table xpchild(id int auto_increment primary key, name varchar(100)); 3 insert into xpchild(1,‘xpchild‘);
步骤1过程：
1. dispatch_command:
command =
COM_QUERY
inc_thread_running():增加thread
running
statistic_increment:增加计数
switch (command):跳转命令
2.
mysql_execute_command:
解析命令为：SQLCOM_INSERT
3.
mysql_insert:
跳转到真正的insert
bool log_on= (thd->variables.option_bits
& OPTION_BIN_LOG):判断是否打开了binlog
open_and_lock_tables(thd, table_list,
TRUE, 0)：打开table并锁表
4. trans_commit_stmt:
语句级别的提交
if
(thd->transaction.stmt.ha_list)
res= ha_commit_trans(thd,
FALSE);
针对语句所有参与的引擎进行提交,
但这里all的参数是false，说明是语句的提交动作，而非真正的事务commit。
５.
ha_commit_trans:
这里trans=all ? &thd->transaction.all :
&thd->transaction.stmt，说明是stmt的transaction。
ha_check_and_coalesce_trx_read_only：判断事务是否需要两阶段提交
for (Ha_trx_info *hi= ha_info; hi; hi=
hi->next())
一共有两个引擎参与：binlog&&innodb
进入prepare阶段：
5.1. binlog_prepare:
直接返回什么也没有做
5.2.
innobase_xa_prepare：
all参数是false，innodb认为是语句级别的提交，就只做如下的事情：
row_unlock_table_autoinc_for_mysql(trx);释放语句hold的auto_increment锁
trx_mark_sql_stat_end(trx);记录本语句的undo信息，以便语句级的回滚
进入提交阶段：
commit_one_phase_low(thd, all, trans, is_real_trans);
5.3. binlog_commit
只是cache了statement的binlog，没有做flush操作
5.4.
innobase_commit
row_unlock_table_autoinc_for_mysql(trx);释放了自增锁
trx_mark_sql_stat_end(trx);记录本语句的undo信息
这个地方做的事情和prepare阶段一样，多做虽然没有坏处，但也没有看到有什么意义
srv_active_wake_master_thread：给主线程发信号唤醒，就结束
6.
close_thread_tables(thd)
在mysql_execute_command中close
table，然后这次命令就结束了。
步骤2：
commit
1. 前面的步骤都相似：
mysql_execute_command函数中跳转到trans_commit进行真正的提交。
2.
ha_commit_trans
进入commit函数，传入参数all=true，为真正的提交动作。
检查rw_ha_count=
ha_check_and_coalesce_trx_read_only(thd, ha_info, all)
rw_ha_count=2
代表binlog引擎和innodb引擎
is_real_trans=true
进入两阶段提交过程：
3. binlog_prepare：
直接return 0；
4.
innobase_xa_prepare：
trx_prepare_off_kernel：
mutex_enter(&(rseg->mutex));锁住undo
segment的mutex
trx_undo_set_state_at_prepare;设置这个insert语句所对应的undo的状态从TRX_UNDO_ACTIVE-》TRX_UNDO_PREPARED。
mutex_exit(&(rseg->mutex));释放mutex
mtr_commit(&mtr):
对于本次的内存更改，因为非原子操作，所以也对应一个提交动作
lsn =
mtr.end_lsn：或者最后的lsn后，flush的时候要保证大于或者等于lsn。
if
flush_log_at_trx_commit=1
log_write_up_to(lsn, LOG_WAIT_ONE_GROUP, TRUE);
参数flush_to_disk=true表示flush log到disk中。
5.
tc_log->log_and_order:这里做了大部分的commit的工作，包括：
binlog_commit_flush_trx_cache：刷新binlog到disk
TC_LOG::run_commit_ordered：
对binlog进行group
commit操作
innodb::innobase_commit_ordered：
trx_commit_off_kernel：
标记事务为TRX_COMMITTED_IN_MEMORY，
如果是insert
undo，直接purge掉。
trx->flush_log_later=true，所以这里并不进行flush，只是记录了commit的lsn，flush的动作放在了提交阶段。
trx_roll_free_all_savepoints：释放所有的save_point.
事务的标记最终为：
trx->conc_state = TRX_NOT_STARTED
进入最终提交阶段：
commit_one_phase_low(thd, all, trans,
is_real_trans)：
binlog_commit：这里貌似什么都没有做，直接进入
if
(cache_mngr->trx_cache.empty())
cache_mngr->reset_cache(&cache_mngr->trx_cache)
所以binlog
commit并不是真正flush
log的地方，而是在ha_commit_trans函数中，完成prepare过程后，commit提交前做了：
cookie=
tc_log->log_and_order(thd, xid, all,
need_commit_ordered);
所以，其实binlog已经提交了，只不过位置不在这里,不过，不妨碍一致性，因为都是在一阶段完成后。
innobase_commit：
trx_commit_complete_for_mysql：
log_write_up_to(lsn,
LOG_WAIT_ONE_GROUP, TRUE);刷新log到disk中，这里的lsn是commit_lsn.
到这里commit完整结束。