MySQL 結合バッファの原理

テーブル名 タイプ
t1範囲
t2参照
t3 すべて
結合は次のように実行されます。
 
- t1の行が範囲内に一致する間
 - 参照キーに従ってt2のすべての行を読み取ります
  - t1、t2の使用済みフィールドをキャッシュに保存する
  - キャッシュがいっぱいの場合
    - t3のすべての行を読み取ります
      - t3行をキャッシュ内のすべてのt1、t2の組み合わせと比較する
        - 行が結合条件を満たす場合は、クライアントに送信します
    - キャッシュを空にする
 
- t3のすべての行を読み取ります
 - t3行をキャッシュに保存されているすべてのt1、t2の組み合わせと比較する
   - 行が結合条件を満たす場合は、クライアントに送信します

静的整数
join_init_cache(THD *thd、JOIN_TAB *テーブル、uint テーブル数)
{
…
  (i=0; i < テーブル数; i++) の場合
  {
    bool have_bit_fields = FALSE;
    uint null_fields=0、used_fields;
    フィールド **f_ptr、*field;
    MY_BITMAP *read_set = tables[i].table->read_set;
    (f_ptr=tables[i].table->field、used_fields=tables[i].used_fields; の場合
 使用されるフィールド;
 f_ptr++)
    {
      フィールド = *f_ptr;
      bitmap_is_set(read_set, field->field_index) の場合
      {
使用されるフィールド--;
長さ+=フィールド->fill_cache_field(コピー);
…
      }
  }
 
  cache->length=長さ+blobs*sizeof(char*);
  キャッシュ->blobs=blobs;
  *blob_ptr=0; /* シーケンス終了 */
  サイズ=max(thd->variables.join_buff_size、cache->length);
  if (!(cache->buff=(uchar*) my_malloc(size,MYF(0))))
    DBUG_RETURN(1); /* キャッシュを使用しない */ /* purecov: 検査済み */
  cache->end=cache->buff+size;
  reset_cache_write(キャッシュ);
  0 を返します。
}

tsecer_select()
{
(r = 最初; r != 最後; r = 次)
{
if(sofartest())
{
次のテーブル.tsecer_select()
}
}
}

列挙型ネストループ状態
sub_select(JOIN *join,JOIN_TAB *join_tab,bool end_of_records)
{
…
    エラー= (*join_tab->read_first_record)(join_tab);
    rc = 評価_join_record(結合、join_tab、エラー);
…
  while (rc == NESTED_LOOP_OK)
  {
    エラー = info->read_record(info);
    rc = 評価_join_record(結合、join_tab、エラー);
  }
…
  rc を返します。
}
静的列挙型ネストループ状態
結合レコードを評価する(JOIN *結合、JOIN_TAB *結合タブ、
                     整数エラー)
{
…
  if (選択条件)
  {
    select_cond_result = テスト(select_cond->val_int());
 
    /* 条件を評価する際にエラーがないかチェックする */
    if (join->thd->is_error())
      NESTED_LOOP_ERROR を返します。
  }
…
    もし（見つかったら）
    {
      列挙型 enum_nested_loop_state rc;
      /* 現在の部分結合に対して join_tab からの一致が見つかりました。 */
      rc = (*join_tab->next_select)(join、join_tab+1、0);
      if (rc != NESTED_LOOP_OK && rc != NESTED_LOOP_NO_MORE_ROWS)
        rc を返します。
      (join->return_tab < join_tab) の場合
        NESTED_LOOP_OK を返します。
      /*
        これがSELECT DISTINCTクエリであるかどうかをテストします。
        フィールドリストにありませんでした。この場合、中止することができます
        結果に新しい行を追加できないため、行が見つかりました。
      */
      if (not_used_in_distinct && found_records != join->found_records)
        NESTED_LOOP_NO_MORE_ROWS を返します。
    }
…
}

列挙型ネストループ状態
sub_select_cache(JOIN *join、JOIN_TAB *join_tab、bool end_of_records)
{
  enum_nested_loop_state rc;
 
  (レコードの終了)
  {
    rc = flush_cached_records(join、join_tab、FALSE);
    (rc == NESTED_LOOP_OK || rc == NESTED_LOOP_NO_MORE_ROWS) の場合
      rc = サブセレクト(結合、結合タブ、レコードの終了);
    rc を返します。
  }
  if (join->thd->killed) // ユーザーによって中止された場合
  {
    join->thd->send_kill_message();
    return NESTED_LOOP_KILLED; /* purecov: 検査済み */
  }
  (join_tab->use_quick != 2 || test_if_quick_select(join_tab) <= 0) の場合
  {
    if (!store_record_in_cache(&join_tab->cache))
      return NESTED_LOOP_OK; // キャッシュにはまだ余裕があります
    flush_cached_records(join,join_tab,FALSE) を返します。
  }
  rc = flush_cached_records(join、join_tab、TRUE);
  (rc == NESTED_LOOP_OK || rc == NESTED_LOOP_NO_MORE_ROWS) の場合
    rc = サブセレクト(結合、結合タブ、レコードの終了);
  rc を返します。
}

    if (!store_record_in_cache(&join_tab->cache))
      return NESTED_LOOP_OK; // キャッシュにはまだ余裕があります
    flush_cached_records(join,join_tab,FALSE) を返します。

  - t1、t2の使用済みフィールドをキャッシュに保存する
  - キャッシュがいっぱいの場合

    - t3のすべての行を読み取ります
      - t3行をキャッシュ内のすべてのt1、t2の組み合わせと比較する
        - 行が結合条件を満たす場合は、クライアントに送信します
    - キャッシュを空にする

静的列挙型ネストループ状態
キャッシュされたレコードをフラッシュします(JOIN *join、JOIN_TAB *join_tab、bool skip_last)
{
…
  情報= &join_tab->read_record;
  する
  // テーブル t3 内のすべてのレコードを走査します...
        (i=(join_tab->cache.records- (skip_last ? 1 : 0)) ; i-- > 0 ;) の場合
        キャッシュ内のすべての t1 および t2 レコードの組み合わせを走査します read_cached_record(join_tab);
          skip_record = FALSE;
          if (select && select->skip_record(join->thd, &skip_record))
          ＃＃
            reset_cache_write(&join_tab->cache);
            NESTED_LOOP_ERROR を返します。
          }
          レコードをスキップする場合
          //プッシュダウンの where 条件を満たす//次のテーブルのトラバーサルを実行する rc= (join_tab->next_select)(join,join_tab+1,0);
            if (rc != NESTED_LOOP_OK && rc != NESTED_LOOP_NO_MORE_ROWS)
            {
              reset_cache_write(&join_tab->cache);
              rc を返します。
            }
          }
…
  } while (!(error=info->read_record(info)));

mysql> テーブル harry (x int) を作成します。
クエリは正常、影響を受けた行は 0 行 (0.03 秒)
 
mysql> ハリー値（1）、（2）、（3）、（4）、（5）を挿入します。
クエリは正常、5 行が影響を受けました (0.00 秒)
記録: 5 重複: 0 警告: 0
 
mysql> テーブル tsecer (y int) を作成します。                   
クエリは正常、影響を受けた行は 0 行 (0.01 秒)
 
mysql> tsecer値（1）、（2）、（3）、（4）、（5）を挿入します。     
クエリは正常、5 行が影響を受けました (0.00 秒)
記録: 5 重複: 0 警告: 0
 
mysql> explain select * from harry, tsecer where x * x + y * y = 5 * 5;
+----+-------------+--------+-------+---------------+-------+-------+------+--------------------------------+
| id | select_type | テーブル | タイプ | possible_keys | key | key_len | ref | 行 | 追加 |
+----+-------------+--------+-------+---------------+-------+-------+------+--------------------------------+
| 1 | シンプル | ハリー | すべて | NULL | NULL | NULL | NULL | 5 | |
| 1 | SIMPLE | tsecer | ALL | NULL | NULL | NULL | NULL | 5 | where の使用; 結合バッファの使用 |
+----+-------------+--------+-------+---------------+-------+-------+------+--------------------------------+
セット内の 2 行 (0.00 秒)
 
マイSQL>