join操作由于半连接不满足交换律的规则连接操作必须遵循语句中定义的顺序执行从而限制了优化器根据参与连接的表的实际数据量来灵活选择优化策略的能力。

为此OceanBase中制定了半连接转内连接规则该规则允许在满足特定条件的情况下将半连接操作转换为内连接为优化器进的一步优化提供了基础。

考虑如下情况

这里可能存在一个问题即当连接条件的右表部分如t2.c1不唯一时在内连接执行时可能会造成左表记录被复制多份即一条左表记录对应多条右表记录从而违背原来的语义。

因此仅当上述右表满足唯一条件时才可以进行改写。

半连接转内连接规则代码解析

半连接转内连接规则的入口为ObTransformSemiToInner::transform_one_stmt该函数最终调用transform_semi_to_inner函数执行改写。

由于这项改写并不一定能够带来更好的执行开销因此需要在改写完成后调用accept_transform函数判断是否接受改写结果。

transform_semi_to_inner函数首先会调用check_basic_validity函数判断查询语句是否满足改写条件如果满足则调用do_transform函数执行改写。

check_basic_validity函数负责判断指定的半连接是否可以被改写为内连接能够被转换的半连接需要满足如下条件

半连接的连接条件均为equal表达式。

满足以下两个条件中的一个半连接条件的右表表达式对应唯一结果或可以通过视图查询转换为唯一结果半连接位于某个exist/no_exist/any/all子查询中此时由于转内连接造成的数据重复可以被忽略。

该函数首先调用check_semi_join_condition函数提取半连接条件的左右表达式集合并判断是否所有条件都是equal条件然后按照如下流程判断是否满足改写条件

调用check_right_table_output_one_row函数判断右表是否为视图查询且添加了limit

1表达式此时右表至多输出一行记录。

调用check_right_exprs_unique函数判断右表表达式是否对应唯一结果。

调用check_stmt_is_non_sens_dul_vals函数判断半连接语句是否位于某个exist/no_exist/any/all子查询中。

调用check_can_add_distinct函数判断是否可以通过将右表转化为视图表然后在视图查询中添加distinct的方式保证结果唯一。

如果可以则调用check_join_condition_match_index函数进一步检查左表条件是否与某个索引匹配这里应该是性能上的考量。

do_transform函数负责执行实际的改写操作该函数执行逻辑较为简单。

如果右表满足上述123项中的任意一项则将右表添加到查询语句中的from部分即可相当于隐式的inner

join如果满足第4项则将右表转换为视图查询然后将查询语句设置为distinct。

OceanBase

云数据库现已支持免费试用现在申请体验分布式数据库带来全新体验吧