概要
查询优化是数据库系统里面特别关键的一个组件, 曾经有一个老外，我也不知道是谁说过:
Query optimizer is where the power of a database lies. （查询优化器是数据库的强大之处。）
可见查询优化的重要性，查询优化在 Presto 里面主要是由 IterativeOptimizer 完成的，今天我们来分析下 IterativeOptimizer。
PlanOptimizer
在介绍 IterativeOptimizer 之前我们先来介绍一下 PlanOptimizer。在 PlanOptimizer 里面只有一个接口，给你一个输入 PlanNode 以及一些辅助的参数，你给出一个优化后的 PlanNode:
public interface PlanOptimizer {
PlanNode optimize(PlanNode plan,
Session session,
TypeProvider types,
SymbolAllocator symbolAllocator,
PlanNodeIdAllocator idAllocator);
}
这个接口实现一般都要实现一个 SimplePlanRewriter 这个使用了 Visitor 设计模式的类, 找到你要处理的节点进行 visit 。用起来其实蛮复杂的，关键是它把多个优化策略揉到一个类里面去做了，比如 LimitPushDown 这个实现，它是要找 LimitNode 进行优化，它里面实现了很多规则:
- 如果 LimitNode 的上游还有一个 LimitNode 那么把这两个 LimitNode 进行合并。如果合并之后要 LimitNode 的 count 是 0，那么直接把这个 LimitNode 节点换成一个空的 Values 节点。
- 如果 LimitNode 的上游有一个 TopN 节点，那么把 Limit 和 TopN 节点进行合并。
- 如果碰到 Union 节点，那么把 Limit 节点推到 Union 下面去。
- 等等。
可以看出来一个优化实现里面糅杂了很多条规则。
不管出于什么理由，把很多不那么相关的逻辑揉在一起都是不好的。
IterativeOptimizer
PlanOptimizer 的缺点正是 IterativeOptimizer 改进的地方，IterativeOptimizer 在 PlanOptimizer 上面又包装了一层，IterativeOptimizer 把每条优化规则抽象出单独的类: Rule。让我们做查询优化的时候只需要去编写 Rule 而不需要去 Optimizer， 不需要去实现 Visitor 模式，真的是太棒了。
Rule 的主要的接口是这样的:
public interface Rule<T>{
/**
* 你要优化的Plan的模式是怎么样的?
*/
Pattern<T> getPattern();
/**
* 匹配你模式的PlanNode找到你，你去优化吧。
*/
Result apply(T node, Captures captures, Context context);
}
首先它让你指定你要优化的 Plan 的结构是怎么样的。比如:
找到两个相邻 LimitNode 节点的结构。
这个在 presto-matching 库的帮助下很好实现(presto-matching库我们在上一篇文章《Presto源码分析之模式匹配》专门分析过。):
private static final Capture<LimitNode> CHILD = newCapture();
private static final Pattern<LimitNode> PATTERN =
limit().with(source().matching(limit().capturedAs(CHILD)));
@Override
public Pattern<LimitNode> getPattern() {
return PATTERN;
}
找到之后我们在 apply 方法里面来实现 LimitNode 合并的操作，也非常的简单。
@Override
public Result apply(LimitNode parent, Captures captures, Context context) {
// 这个 child 是那个上游的 LimitNode
LimitNode child = captures.get(CHILD);
return Result.ofPlanNode(
new LimitNode(
parent.getId(),
child.getSource(),
// 合并成一个 LimitNode 取比较小的那个 count
Math.min(parent.getCount(), child.getCount()),
parent.isPartial()));
}
不知道大家是什么感觉，反正我在阅读 Presto Optimizer 代码之前没有想到进行查询优化的逻辑可以写得这么简单。这就是优秀框架的力量啊。
可变的执行计划: Memo
在 IterativeOptimizer 对 PlanNode 进行改写的过程中还有一个很重要的类: Memo。我们知道 Presto 源代码里面有一点做得很好，就是对象都是能不可变(immutable)就不可变，这让程序更可预期，潜在的 bug 也会少很多，同时也有一些缺点: 不可变导致要改变一个Plan结构的一部分变得很复杂，你必须重新构造整个 Plan ，因此为了执行计划优化的方便性以及性能的考虑，在对PlanNode进行优化前会把 PlanNode 转化成一个可变的对象: Memo, 下面我们来详细分析下Memo这个类。
说实话 Memo 这个类名我觉得起的特别不好，光看类名完全跟可变的PlanNode联系不上，如果让我起名字的话，我觉得还不如叫 MuttablePlanNode 来的直观。
在 Memo 里面，所有的 PlanNode 被一个新的类 GroupReference 包装一层，一个原始的计划:
原始的PlanNode结构
会被包成下面的结构:
包装过后的PlanNode结构
这里 GroupReference 仍然是不可变的，但是 Group 是可变的，PlanNode 优化的过程其实就是通过遍历 GroupReference 树，不断修改对应的 Group 里面的 PlanNode 的过程。值得注意的是，这个树的结构也可能会被修改，比如上面我们提到过的那个优化策略：
如果有两个相邻的 LimitNode 节点，那么把他们合并成一个 LimitNode 节点，取比较小的那个LimitNode的值作为最终的 LimitNode。
因此存在着一开始存在的 Group 随着优化过程对整个 PlanNode 结构的修改，最后不再被任何其它 Group 引用，因而需要删除掉的情况，因此 Memo 里面有个小小的垃圾回收的策略: 每个 Group对象上除了记录它的原始的 PlanNode 之外，还会有一个引用它的 Group 的记录:
private Multiset<Integer> incomingReferences = HashMultiset.create();
它每次操作一个节点的时候会对相关的节点做个引用计数 + 垃圾回收的维护:
// 增加新节点(node)的引用计数
incrementReferenceCounts(node, group);
// 更新节点
getGroup(group).membership = node;
// 减少旧节点(old)相关节点的引用计数，如果引用计数为0，则把对应的Group删掉
decrementReferenceCounts(old, group);
感想
刚学习设计模式的时候动不动就想把设计模式用到代码里面去，这样代码会显得高大上一点。当然，在代码里面用设计模式没错，它可以有效地隔离变化，让代码更具有可维护性、可扩展性。但是就像写文章一样，堆满华丽辞藻的文章绝不是什么好文章，堆满设计模式的代码也绝不是什么好的代码。
写代码又像武侠小说里面的侠客学习武功一样，一开始你什么招式也不会，谁也打不过，后来你学了很多招式，能打过很多人了，但是仍然不是绝顶高手，所谓的绝顶高手是要在把所有招式都学过之后，再把所有的招式都忘记掉，真正要用的时候随心所至信手拈来。
设计模式就相当于武功里面的招式，真正的高手应该是学过之后忘掉它，在真正需要的的时候信手拈来用到合适的地方去，这个合适的地方就是框架，让普通开发看不到，这样普通开发同学就可以集中精力写真正的业务代码了, 我们每天要花大量时间去写的应该是业务代码。
在 Presto 查询优化的模块里面，框架代码指的是 PlanOptimizer、IterativeOptimizer, 这里面该用 Visitor 模式就用 Visitor 模式，一旦有了这个框架之后，我们真正业务是调优查询性能，这时候只需要去写 Rule 就好了，而 Rule 的实现都是平铺直叙的逻辑，没有什么复杂的模式，用户用起来会觉得很方便好用。
再引申一点，一个好的 API 一定是平铺直叙的，不需要让用户使用什么设计模式的。
网友评论