JOIN 的类型主要包括内联接(INNER JOIN)、外联接(OUTER JOIN)和半联接(SEMI/ANTI JOIN)三种。

OceanBase 数据库支持的 JOIN 算子主要有 NESTED LOOP JOIN (NLJ)、MERGE JOIN (MJ) 和 HASH JOIN (HJ)。

如下示例中,Q1 和 Q2 查询使用 HINT 指定了查询使用 NLJ。其中,0 号算子是一个 NLJ 算子。这个算子存在两个子节点,分别是 1 号算子和 2 号算子,它的执行逻辑为:

  1. 从 1 号算子读取一行。

  2. 打开 2 号算子,读取所有的行。

  3. 联接接 1和 2 号算子的输出结果,并执行过滤条件,输出结果。

  4. 重复第一步,直到 1 号算子迭代结束。

其中,MATERIAL 算子用于物化下层算子输出的数据,详细信息请参见 。

  1. obclient>EXPLAIN SELECT /*+USE_NL(t1, t2)*/ t1.c2 + t2.d2 FROM t1, t2
  2. WHERE c1 = d1\G;
  3. *************************** 1. row ***************************
  4. Query Plan:
  5. | ==========================================
  6. |ID|OPERATOR |NAME|EST. ROWS|COST |
  7. ------------------------------------------
  8. |0 |NESTED-LOOP JOIN| |990 |37346|
  9. |1 | TABLE SCAN |T1 |999 |669 |
  10. |2 | TABLE GET |T2 |1 |36 |
  11. ==========================================
  12. Outputs & filters:
  13. -------------------------------------
  14. 0 - output([T1.C2 + T2.D2]), filter(nil),
  15. conds(nil), nl_params_([T1.C1])
  16. 1 - output([T1.C1], [T1.C2]), filter(nil),
  17. 2 - output([T2.D2]), filter(nil),
  18. access([T2.D2]), partitions(p0)

上述示例中,执行计划展示中的 outputs & filters 详细展示了 NESTED LOOP JOIN 算子的具体输出信息如下:

如下示例中,Q3 查询中没有指定任何的联接条件,0 号算子展示成了一个 ,逻辑上它还是一个 NLJ 算子,代表一个没有任何联接条件的 NLJ。

如下示例中,Q4 查询使用 USE_MERGE 的 HINT 指定了查询使用 MJ。其中,0 号算子是一个 MJ 算子,它有两个子节点,分别是 1 和 3 号算子。该算子会对左右子节点的数据进行归并联接,因此,要求左右子节点的数据相对于联接列是有序的。

以 Q4 查询为例,联接条件为 t1.c2 = t2.d2,它要求 t1 的数据是按照 c2 排序的,t2 的数据是按照 d2 排序的。在 Q4 查询中,2 号算子的输出是无序的;4 号算子的输出是按照 d2 排序的,均不满足 MERGE JOIN 对序的要求,因此,分配了 1 和 3 号算子进行排序。

  1. Q4:
  2. obclient>EXPLAIN SELECT /*+USE_MERGE(t1, t2)*/ t1.c2 + t2.d2 FROM t1, t2
  3. WHERE c2 = d2 AND c1 + d1 > 10\G;
  4. *************************** 1. row ***************************
  5. Query Plan:
  6. | ======================================
  7. |ID|OPERATOR |NAME|EST. ROWS|COST |
  8. --------------------------------------
  9. |0 |MERGE JOIN | |3261 |14199|
  10. |1 | SORT | |999 |4505 |
  11. |2 | TABLE SCAN|T1 |999 |669 |
  12. |3 | SORT | |999 |4483 |
  13. |4 | TABLE SCAN|T2 |999 |647 |
  14. ======================================
  15. Outputs & filters:
  16. -------------------------------------
  17. 0 - output([T1.C2 + T2.D2]), filter(nil),
  18. equal_conds([T1.C2 = T2.D2]), other_conds([T1.C1 + T2.D1 > 10])
  19. 1 - output([T1.C2], [T1.C1]), filter(nil), sort_keys([T1.C2, ASC])
  20. 2 - output([T1.C2], [T1.C1]), filter(nil),
  21. access([T1.C2], [T1.C1]), partitions(p0)
  22. 4 - output([T2.D2], [T2.D1]), filter(nil),

如下示例中,Q5 查询中联接条件是 t1.c1 = t2.d1 ,它要求 t1 的数据是按照 c1 排序的,t2 的数据是按照 d1 排序的。在这个执行计划中,t2 选择了主表扫描,结果是按照 d1 有序的,因此不需要额外分配一个 SORT 算子。理想情况下,JOIN 的左右表选择了合适的索引,索引提供的数据顺序能够满足 MJ 的要求,此时不需要分配任何 SORT 算子。

上述示例中,执行计划展示的 outputs & filters 中详细展示了 MERGE JOIN 算子的具体输出信息如下:

如下示例中,Q6 查询使用 USE_HASH 的 HINT 指定了查询使用 HJ。其中,0 号算子是一个 HJ 算子,它有两个子节点,分别是 1 和 2 号算子。该算子的执行逻辑步骤如下:

  1. 读取左子节点的数据,根据联接列计算哈希值(例如 t1.c1),构建一张哈希表。

  2. 读取右子节点的数据,根据联接列计算哈希值(例如 t2.d1),尝试与对应哈希表中 t1 的数据进行联接。

  1. Q6:
  2. obclient>EXPLAIN SELECT /*+USE_HASH(t1, t2)*/ t1.c2 + t2.d2 FROM t1, t2
  3. WHERE c1 = d1 AND c2 + d2 > 1\G;
  4. *************************** 1. row ***************************
  5. Query Plan:
  6. | ====================================
  7. |ID|OPERATOR |NAME|EST. ROWS|COST|
  8. ------------------------------------
  9. |0 |HASH JOIN | |330 |4850|
  10. |1 | TABLE SCAN|T1 |999 |669 |
  11. |2 | TABLE SCAN|T2 |999 |647 |
  12. ====================================
  13. Outputs & filters:
  14. -------------------------------------
  15. 0 - output([T1.C2 + T2.D2]), filter(nil),
  16. equal_conds([T1.C1 = T2.D1]), other_conds([T1.C2 + T2.D2 > 1])
  17. 1 - output([T1.C1], [T1.C2]), filter(nil),
  18. access([T1.C1], [T1.C2]), partitions(p0)
  19. 2 - output([T2.D1], [T2.D2]), filter(nil),

上述示例中,执行计划展示中的 outputs & filters 详细展示了 HASH JOIN 算子的输出信息如下: