PG&GP · 特性分析 · 外部数据导入接口实现分析

社区 postgresql 和 greenplum 都提供了读写外部数据源的方法，它们都提供了一套编程接口，用户可以在这上面做二次开发，建立外部数据源和数据库间的数据通道。

本文介绍 postgresql 和 greenplum 这部分编程接口的实现和编程方法。结合 rds 开发的 oss_ext 接口。展示外部数据源接口的能力。

fdw 的全称是 foreign-data wrapper，是一套读写外部数据源的编程接口。它提供了多个回调函数编程接口，开发者可以逐一实现这些接口，封装成动态库，然后加载到内核中使用。

下面逐一介绍下这套编程接口

getforeignrelsize_function getforeignrelsize;

返回给数据库对应数据源的规模信息

getforeignpaths_function getforeignpaths;

优化器接口，提供对应数据源的查询路径。

getforeignplan_function getforeignplan;

优化器接口，提供对应数据源的查询计划。

beginforeignscan_function beginforeignscan;

执行器接口，外部表扫描开始的准备工作。

iterateforeignscan_function iterateforeignscan;

执行器接口，外部表扫描实现，一次返回一个 tuple slot。

rescanforeignscan_function rescanforeignscan;

执行器接口，外部表扫描节点重新开始，重置所有状态参数和内存结构。

endforeignscan_function endforeignscan;

执行器接口，外部表扫描节点结束，释放资源。

addforeignupdatetargets_function addforeignupdatetargets;

构造要更新的外部数据源的目标列信息

planforeignmodify_function planforeignmodify;

构造外部数据源修改的（包括insert update delete的）的数据结构

beginforeignmodify_function beginforeignmodify;

执行器接口，数据更新节点的数据准备

execforeigninsert_function execforeigninsert;

执行器接口，insert 一行数据

execforeignupdate_function execforeignupdate;

执行器接口，update 一行数据

execforeigndelete_function execforeigndelete;

执行器接口，delete 一行数据

endforeignmodify_function endforeignmodify;

执行器接口，修改结束，释放相关资源

isforeignrelupdatable_function isforeignrelupdatable;

explainforeignscan_function explainforeignscan;

展示扫描节点的相关信息

explainforeignmodify_function explainforeignmodify;

展示修改数据节点的相关信息

analyzeforeigntable_function analyzeforeigntable;

分析外部数据的数据分布状况接口

用户可以根据需求实现他们，如只需要读取数据，则不用实现第二部分；

除了支持读取数据相关接口，还支持了对统计信息的接入。这样，postgresql 真正的把外部数据源当作了“表”。考虑到了数据的规模，使得优化器合理的规划了外部表的执行路径。和执行阶段执行器深度结合。整套接口设计清晰分工明确；

greenplum external table 在实现上和 postgresql fdw 完全不同，有自己的特点：

greenplum 只提供了两个对外的接口 readfunc 和 writefunc；

greenplum external table 接口和内核交互的的内容是数据块，而 postgresql fdw 是 tuple slot。

也就是说，通过 postgresql fdw 需要把外部数据源做完整的行列解析，而 greenplum external table 则不同；

最大的不同 greenplum external table 执行过程中是驱动 segment 工作，可以通过这个接口让所有 segment 同时并行工作并行读写数据，大大提高了整个集群的性能；

greenplum external table 没有像 postgresql fdw 那样的读取统计信息，并提供给优化器的接口，在复杂查询场景下使用 greenplum external table 可能查询计划不是最优的；

readfunc

按数据块读取数据

writefunc

按数据块写数据

基于上述编程接口，我们开发了一套用于从 oss 导入数据到 greenplum 和 postgresql 的插件，性能杠杠的。帮助云上用户更好的使用 rds 数据库产品。

<a href="https://yq.aliyun.com/articles/31632" target="_blank">从 oss 导入数据到 greenplum</a>