MYSQL實(shí)例
  create table t1 (a int primary key, b int)engine=innodb;
  insert into t1 values (1,1),(2,2),(3,3),(4,4);

MYSQL實(shí)例
  alter table t1 add index idx_t1_b(b);

MYSQL實(shí)例
  sql_table.cc::mysql_alter_table();
    // 判斷當(dāng)前操作是否可以進(jìn)行Inplace實(shí)現(xiàn),不可進(jìn)行Inplace Alter的包含：
    // 1. Auto Increment字段修改；
    // 2. 列重命名；
    // 3. 行存儲(chǔ)格式修改；等
    mysql_compare_tables() -> ha_innobase::check_if_incompatible_data();
    // Inplace創(chuàng)建索引第一階段(主要階段)
    handler0alter.cc::add_index();
      …
      // 創(chuàng)建索引數(shù)據(jù)字典
      row0merge.c::row_merge_create_index();
        index = dict_mem_index_create();
        // 每個(gè)索引數(shù)據(jù)字典上,有一個(gè)trx_id,記錄創(chuàng)建此索引的事務(wù)
        // 此trx_id有何功能,接著往下看
        index->trx_id = trx_id;
         // 讀取聚簇索引,構(gòu)造新索引的項(xiàng),排序并插入新索引
         row0merge.c::row_merge_build_indexes();
            // 讀取聚簇索引,注意：只讀取其中的非刪除項(xiàng)
            // 跳過所有刪除項(xiàng),為什么可以這么做?往下看
            row_merge_read_clustered_index();
            // 文件排序
            row_merge_sort();
            // 順序讀取排序文件中的索引項(xiàng),逐個(gè)插入新建索引中
            row_merge_insert_index_tuples();
    // 等待打開當(dāng)前表的所有只讀事務(wù)提交
    sql_base.cc::wait_while_table_is_used();
    // 創(chuàng)建索引結(jié)束,做最后的清理工作
    handler0alter.cc::final_add_index();
    // Inplace add Index完畢

MYSQL實(shí)例
session 1:                               session 2:
// 此時(shí)創(chuàng)建Global ReadView
select * from t2;
                                       delete from t1 where b = 1;
                                       // idx_t1_b索引上,沒有b = 1的項(xiàng)
                                       alter table t1 add index idx_t1_b(b);
// 由于ReadView在delete之前獲取
// 因此b = 1這一項(xiàng)應(yīng)該被讀取到
select * from t1 where b = 1;

MYSQL實(shí)例
…
ha_innobase::index_init();
  change_active_index();
    // 判斷session 1事務(wù)的ReadView是否可以看到session 2創(chuàng)建索引的事務(wù)
    // 此處,session 2事務(wù)當(dāng)然不可見,那么prebuilt->index_usable = false
    prebuilt->index_usable = row_merge_is_index_usable(readview, index->trx_id);
…
ha_innobase::index_read();
  // 判斷index_usable屬性,此時(shí)為false,返回上層表定義修改,查詢失敗
  if (!prebuilt->index_usable)
    return HA_ERR_TABLE_DEF_CHANGED;

MYSQL實(shí)例
mysql> select * from t1 where b = 1;

MYSQL實(shí)例
ERROR 1412 (HY000): Table definition has changed, please retry transaction

MYSQL實(shí)例
  create table t1 (a int primary key, b int)engine=innodb;
  insert into t1 values (1,1),(2,2),(3,3),(4,4);

MYSQL實(shí)例
  alter table t1 add index idx_t1_b(b);

MYSQL實(shí)例
  sql_table.cc::mysql_alter_table();
    // 1. 判斷當(dāng)前DDL操作是否可以Inplace進(jìn)行
    check_if_supported_inplace_alter();
      …
    // 2. 開始進(jìn)行Online創(chuàng)建的前期準(zhǔn)備工作
    prepare_inplace_alter_table();
      …
      // 修改表的數(shù)據(jù)字典信息
      prepare_inplace_alter_table_dict();
        …
        // 等待InnoDB所有的后臺(tái)線程,停止操作此表
        dict_stats_wait_bg_to_stop_using_tables();
        …
        // Online Add Index區(qū)別與Inplace Add Index的關(guān)鍵
        // 在Online操作時(shí),原表同時(shí)可以讀寫,因此需要
        // 將此過程中的修改操作記錄到row log之中
        row0log.cc::row_log_allocate();
          row_log_t* log = (row_log_t*)&buf[2 * srv_sort_buf_size];
          // 標(biāo)識(shí)當(dāng)前索引狀態(tài)為Online創(chuàng)建,那么此索引上的
          // DML操作會(huì)被寫入Row Log,而不在索引上進(jìn)行更新
          dict_index_set_online_status(index, ONLINE_INDEX_CREATION);
      …
    // 3. 開始進(jìn)行真正的Online Add Index的操作(最重要的流程)
    inplace_alter_table();
      // 此函數(shù)的操作,前部分與Inplace Add Index基本一致
      // 讀取聚簇索引、排序、并插入到新建索引中
      // 最大的不同在于,當(dāng)插入完成之后,Online Add Index
      // 還需要將row log中的記錄變化,更新到新建索引中
      row0merge.cc::row_merge_build_index();
        …
        // 在聚簇索引讀取、排序、插入新建索引的操作結(jié)束之后
        // 進(jìn)入Online與Inplace真正的不同之處,也是Online操作
        // 的精髓部分――將這個(gè)過程中產(chǎn)生的Row Log重用
        row0log.cc::row_log_apply();
          // 暫時(shí)將新建索引整個(gè)索引樹完全鎖住
          // 注意：只是暫時(shí)性鎖住,并不是在整個(gè)重用Row Log的
          // 過程中一直加鎖(防止加鎖時(shí)間過長(zhǎng)的優(yōu)化,如何優(yōu)化?)
          rw_lock_x_lock(dict_index_get_lock(new_index));
            …
          // InnoDB Online操作最重要的處理流程
          // 將Online Copy Table中,記錄的Row Log重放到新建索引上
          // 重放Row Log的算法如下：
          // 1. Row Log中記錄的是Online創(chuàng)建索引期間,原表上的DML操作
          //  這些操作包括：ROW_OP_INSERT；ROW_OP_DELETE_MARK; …
          // 2. Row Log以Block的方式存儲(chǔ),若DML較多,那么Row Logs可能
          //   會(huì)占用多個(gè)Blocks.row_log_t結(jié)構(gòu)中包括兩個(gè)指針：head與tail
          //   head指針用于讀取Row Log,tail指針用于追加寫新的Row Log；
          // 3.在重用Row Log時(shí),算法遵循一個(gè)原則：盡量減少索引樹加鎖
          //  的時(shí)間(索引樹加X鎖,也意味著表上禁止了新的DML操作)
          //   索引樹需要加鎖的場(chǎng)景：
          //  (一) 在重用Row Log跨越新的Block時(shí),需要短暫加鎖；
          //   (二) 若應(yīng)用的Row Log Block是最后一個(gè)Block,那么一直加鎖
          //     應(yīng)用最后一個(gè)Block,由于禁止了新的DML操作,因此此
          //     Block應(yīng)用完畢,新索引記錄與聚簇索引達(dá)到一致狀態(tài),
          //     重用階段結(jié)束；
          //  (三) 在應(yīng)用中間Row Log Block上的row log時(shí),無需加鎖,新的
          //     DML操作仍舊可以進(jìn)行,產(chǎn)生的row log記錄到最后一個(gè)
          //     Row Log Block之上；
          // 4. 如果是創(chuàng)建Unique索引,那么在應(yīng)用Row Log時(shí),可能會(huì)出現(xiàn)
          //   違反唯一性約束的情況,這些情況會(huì)被記錄到
          //   row_merge_dup_t結(jié)構(gòu)之中
          row_log_apply_ops(trx, index, &dup);
            row_log_apply_op();
              row_log_apply_op_low();
                …
          // 將New Index的Online row log設(shè)置為NULL,
          // 標(biāo)識(shí)New Index的數(shù)據(jù)已經(jīng)與聚簇索引完全一致
          // 在此之后,新的DML操作,無需記錄Row Log
          dict_index_set_online_status();
            index->online_status = ONLINE_INDEX_COMPLETE;
          index->online_log = NULL;
          rw_lock_x_unlock(dict_index_get_block(new_index));
          row_log_free();
      …
    // 4. Online Add Index的最后步驟,做一些后續(xù)收尾工作
    commit_inplace_alter_table();
      …

MYSQL實(shí)例
create table t1 (a int primary key, b int, c char(250))engine=innodb;
insert into t1(b,c) values (1,'aaaaaaa');
// 保證數(shù)據(jù)量夠多
insert into t1(b,c) select b,c from t1;
insert into t1(b,c) select b,c from t1;
insert into t1(b,c) select b,c from t1;
…
// max(a) = 196591
select max(a) from t1;
// b中同樣沒有相同項(xiàng)
update t1 set b = a;
session 1                                   session 2
alter table t1 add unique index idx_t1_b(b);
                                           insert into t1(b,c) values (196592,'b');
                                           // 此update,會(huì)產(chǎn)生b=196589的重復(fù)項(xiàng)
                                           update t1 set b=196589 where a=196582;
                                           delete from t1 where a = 262127;

MYSQL實(shí)例
mysql> show create table t1;

MYSQL實(shí)例
+――-+――――――――――――――――C
| Table | Create Table
+――-+――――――――――――――――C
| t1 | CREATE TABLE `t1` (
`a` int(11) NOT NULL AUTO_INCREMENT,
`b` int(11) DEFAULT NULL,
`c` char(250) DEFAULT NULL,
PRIMARY KEY (`a`),
UNIQUE KEY `idx_t1_b` (`b`)
) ENGINE=InnoDB AUTO_INCREMENT=262129 DEFAULT CHARSET=gbk |
+――-+――――――――――――――――C
mysql> select * from t1 where a in (196582,196589);
+――C+――C+―――+
| a | b | c |
+――C+――C+―――+
| 196582 | 196589
| aaaaaaa |
| 196589 | 196589
| aaaaaaa |
+――C+――C+―――+
2 rows in set (0.04 sec)