47.6. 执行器

执行器接收规划器/优化器创建的查询规划然后递归地处理它， 抽取所需要的行集合。它实际上是一个需求-拉动（demand-pull ）的流水线机制。每次调用一个规划节点， 它都必须传递至少一行，否则报告它已经完成了行的传递。

举一个具体的例子，假设顶端节点是一个MergeJoin节点。 在做任何归并之前，首先要获取两行(每个子规划一行)。 因此执行器递归地调用自己来处理子规划(它从附着在lefttree上的子规划开始)。 假设新的顶端节点(左子规划的顶端节点)是一个Sort节点， 然后还是需要递归地获取一个输入行。Sort节点的子节点可能是一个SeqScan 节点，代表对一个表的实际读取动作。这个节点的执行导致执行器从表中抓取一行然后把它返回给调用的节点。 Sort将不断调用它的子节点以获取需要排序的所有行。 处理完所有输入之后(由子节点返回一个 NULL 而不是一行表示)，由Sort代码执行排序， 然后就可以返回它的第一个输出行，也就是按照排序顺序输出的第一行，它仍然保持剩下的行的排序状态， 这样在随后有需求的时候，它就可以按照排序顺序返回这些行。

MergeJoin节点也会类似地要求从它的右边子规划获取第一行。 然后它比较这两行看它们是否能连接；如果能，则给它的调用者返回一个连接行。 在下一次调用的时候，或者无法连接当前两行的时候， 抓取其中一个表的下一行(抓取哪个表取决于比较结果如何)，然后再检查看看两个表是否匹配。 最后，其中一个子规划的所有行都被处理完，此时MergeJoin返回 NULL ， 表明无法继续生成更多的连接行。

复杂的查询可能包含许多层的规划节点，但是一般的过程都是一样的： 每个节点在每次被调用的时候都计算并返回它的下一个输出行。 每个节点同样负责应用任何规划器赋予它的选择或者投影表达式。

执行器机制是用于计算所有四种基本 SQL 查询类型的：SELECT，INSERT， UPDATE和DELETE。对于SELECT而言， 顶层的执行器代码只是需要发送查询规划树返回的每一行给客户端。对于INSERT， 返回的每一行都插入到INSERT声明的目标表中。也就是在一个名为ModifyTable 的特殊的顶级规划节点执行。（一个简单的INSERT ... VALUES命令创建一个简单的规划树， 包含一个Result节点，它只得出一个结果行，由ModifyTable执行插入操作。 但INSERT ... SELECT可能需要执行器的全部操作。）对于UPDATE， 规划器安排每个计算出来的行都包括所有更新的字段，加上原来的目标行的TID(元组ID或行ID)； 这些数据输入到一个ModifyTable节点，这个节点使用这些信息创建一个新的更新过的行， 并且将旧行标记删除。对于DELETE，规划器实际上返回的唯一的一个字段是 TID ， 然后ModifyTable节点简单地使用这个 TID 访问每个目标行，并且把它们标记为已删除。