操作场景

当GaussDB 200需要访问远端MPPDB数据库数据时或者需要数据互操作时，可以通过配置"对接MPPDB"使用该功能。

 说明：

GaussDB 200支持两种方式访问远端MPPDB数据库集群，包括通过FusionInsight Manager配置方式和创建Foreign Table的方式，Foreign Table的方式请参见配置访问远端MPPDB（Foreign Table方式）。

约束限制

支持最多可配置20组远端MPPDB配置。

前提条件

• MPPDB数据库和GaussDB 200集群状态正常。
• MPPDB数据库物理节点和GaussDB 200集群之间可以互相通信。
• 配置远端MPPDB集群监听参数，请参考Linux下配置数据源章节中的步骤6。

操作步骤

1. 登录FusionInsight Manager。
2. 选择“集群 > 待操作的集群名称 > 服务 > MPPDB > 对接 > 对接MPPDB”，单击“创建”，填写配置组名称，单击“确定”。
3. 填写配置参数，配置参数参见表1。

   表1 GaussDB 200跨集群访问MPPDB的配置

   参数	描述	建议填写值
   remote_connect_mppdb_database	MPPDB数据库的名称。	-
   remote_connect_mppdb_driver	mppdb odbc driver名称，用户可以根据实际情况自定义名称，以mppdb_开头，只允许由字母数字下划线组成，不能超过64个字符。 注意： “remote_connect_mppdb_driver”值作为配置标示，保存配置后将不能修改，请用户慎重填写。 不同MPPDB配置组中的“remote_connect_mppdb_driver”参数值不能相同。	mppdb_Driver
   remote_connect_mppdb_dsn	该组配置的DSN标识，以mppdb_开头，只允许由字母数字下划线组成，不能超过64个字符。 注意： “remote_connect_mppdb_dsn”值作为配置标示，保存配置后将不能修改，请用户慎重填写。 不同MPPDB配置组中的“remote_connect_mppdb_dsn”参数值不能相同。	mppdb_DSN
   remote_connect_mppdb_fetch	使用服务器游标时，每次从远端拿到的数据量。 注意： “remote_connect_mppdb_fetch”值的设置范围为1-1000000。 如果远端CN内存较小，可以适当设置较小的值。	10000
   remote_connect_mppdb_host	MPPDB数据库的主机IP地址。	-
   remote_connect_mppdb_port	MPPDB数据库的端口号。	25308
   remote_connect_mppdb_sslmode	开启SSL模式。	allow

4. 单击“保存”。等待保存配置成功，单击“完成”。
5. 选择“更多 > 重启”，执行相应操作重启服务。
6. 创建Data Source对象。
   1. 连接数据库。
   2. 创建Data Source对象。比如创建对应远端MPPDB数据库的Data Source对象ds_mppdb
      复制

      postgres=# CREATE DATA SOURCE ds_mppdb type 'MPPDB' OPTIONS (DSN 'mppdb_DSN', USERNAME 'mppdb_user', PASSWORD 'mppdb_pwd', ENCODING 'UTF8');

7. 连接远端MPPDB数据库。

   假设Data Source对象ds_mppdb已经创建好，使用exec_on_extension函数进行连接，比如查询远端MPPDB数据库中一张表a (c1 int)：

   postgres=# SELECT * FROM exec_on_extension('ds_mppdb', 'select * from a;') AS (c1 int);

   示例
   

-- 创建Data Source
postgres=# CREATE DATA SOURCE ds_mppdb OPTIONS (dsn 'mppdb_DSN', username 'mppdb_user', password 'mppdb_pwd',ENCODING 'UTF8');
-- 建远程表、插入数据
postgres=# SELECT * FROM exec_on_extension('ds_mppdb', 'create table a (c1 int);') AS (c1 text);
 c1 
----
( rows)
postgres=# SELECT * FROM exec_on_extension('ds_mppdb', 'insert into a values (911);') AS (c1 text);
 c1 
----
( rows)
-- 执行计划，如果计划在目标库是多列显示则此处需要以对应的列数返回
-- 此处远端MPPDB数据库中参数 explain_perf_mode=normal
postgres=# SELECT * FROM exec_on_extension('ds_mppdb', 'explain select * from a;') AS (c1 text);
                    QUERY PLAN                    
--------------------------------------------------
 Data Node Scan  (cost=.00..0.00 rows= width=)
   Node/s: All datanodes
(2 rows)
postgres=# SELECT * FROM exec_on_extension('ds_mppdb', 'select * from a;') AS (c1 int);
 c1  
-----
 911
(1 row)
-- 此处发送的SQL语句返回两列，但函数exec_on_extension只返回一列，注意靠前匹配原则
postgres=# SELECT * FROM exec_on_extension('ds_mppdb', 'select * from a a1 inner join a a2 on a1.c1=a2.c1;') AS (c1 int);
 c1  
-----
 911
 911
(2 rows)
-- 与本地表关联
postgres=# CREATE TABLE b AS SELECT * FROM exec_on_extension('ds_mppdb', 'select * from a;') AS (c1 int);
NOTICE:  The 'DISTRIBUTE BY' clause is not specified. Using 'c1' as the distribution column by default.
HINT:  Please use 'DISTRIBUTE BY' clause to specify suitable data distribution column.
INSERT  1
postgres=# INSERT INTO b SELECT * FROM exec_on_extension('ds_mppdb', 'select * from a;') AS (c1 int);
INSERT  1
postgres=# SELECT * FROM b WHERE b.c1 in (SELECT * FROM exec_on_extension('ds_mppdb', 'select * from a;') AS (c1 int));
 c1  
-----
 911
 911
(2 rows)