注意事项

PostgreSQL 11云盘版的dblink和postgres_fdw插件进行跨库操作的注意事项如下：

• 相同VPC内的ECS/RDS PostgreSQL实例可以直接跨库操作。
• RDS PostgreSQL实例可以通过本VPC内的ECS实例进行端口跳转，实现跨库操作。
• 自建PostgreSQL实例可以通过oracle_fdw或mysql_fdw连接VPC外部的oracle实例或mysql实例。

使用dblink

1. 新建dblink插件。

   create extension dblink;

2. 创建dblink连接。

   postgres=> select dblink_connect('<连接名称>', 'host=<同一VPC下的另一RDS的内网域名> port=<同一VPC下的另一RDS的内网监听端口> user=<远程数据库用户名> password=<密码> dbname=<库名>');
   
   postgres=> SELECT * FROM dblink('<连接名称>', '<SQL命令>') as <表名>(<列名> <列类型>); 

   示例

   postgres=> select dblink_connect('a', 'host=pgm-bpxxxxx.pg.rds.aliyuncs.com port=3433 user=testuser2 password=passwd1234 dbname=postgres'); 
   
   
   postgres=> select * from dblink('a','select * from products') as T(id int,name text,price numeric);  //查询远端表
   
   						

   

更多详情请参见dblink。

使用postgres_fdw

1. 新建一个数据库。

   postgres=> create database <数据库名>;  //创建数据库
   
   postgres=> \c <数据库名>  //切换数据库

   示例

   postgres=> create database db1;  
   CREATE DATABASE  
   
   postgres=> \c db1  

2. 新建postgres_fdw插件。

   db1=> create extension postgres_fdw;

3. 新建远程数据库服务器。

   db1=> CREATE SERVER <server名称>                                                              
           FOREIGN DATA WRAPPER postgres_fdw  
           OPTIONS (host '<同一VPC下的另一RDS的内网域名>,port '<同一VPC下的另一RDS的内网监听端口>', dbname '<同一VPC下的另一RDS的库名>');  
   
   db1=> CREATE USER MAPPING FOR <本地数据库用户名>      
           SERVER <server名称> 
           OPTIONS (user '<远程数据库用户名>', password '<远程数据库密码>');  

   示例

   db1=> CREATE SERVER foreign_server1                                                              
           FOREIGN DATA WRAPPER postgres_fdw  
           OPTIONS (host 'pgm-bpxxxxx.pg.rds.aliyuncs.com', port '3433', dbname 'postgres');  
   CREATE SERVER  
   
   db1=> CREATE USER MAPPING FOR testuser      
           SERVER foreign_server1  
           OPTIONS (user 'testuser2', password 'passwd1234');  
   CREATE USER MAPPING  

4. 导入外部表。

   db1=> import foreign schema public from server foreign_server1 into <SCHEMA名称>;  //导入外部表
   
   db1=> select * from <SCHEMA名称>.<表名>      //查询远端表

   示例

   db1=> import foreign schema public from server foreign_server1 into ft;  
   IMPORT FOREIGN SCHEMA  
   
   db1=> select * from ft.products;  

   

更多详情请参见postgres_fdw。