Postgres访问其他PostgresQL数据库的功能DBLINK

雨点打透心脏的1/2处 2022-07-12 10:51 200阅读 0赞

转自：[http://blog.csdn.net/hantiannan/article/details/7553108][http_blog.csdn.net_hantiannan_article_details_7553108]

有时候的业务需要参照其他[数据库][Link 1]的数据。

我们可以在程序中分别从两个数据库中取值然后处理。但这样开发效率和性能都不是很好。

如果两个数据库都是PostgreSQL的话，用扩展的DBLINK功能非常简单。

比如一个数据db1，db2。首先需要把db1加入dblink扩展。

示例1：取得db2的用户表的用户名

**\[sql\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain]

1.  SELECT \* FROM dblink('hostaddr=192.168.0.222 port=5432 dbname=db2 user=postgres password=postgres',  
2.                       'SELECT user\_name From people') AS t(user\_name text);

![save_snippets_01.png][]

SELECT * FROM dblink('hostaddr=192.168.0.222 port=5432 dbname=db2 user=postgres password=postgres',
                         'SELECT user_name From people') AS t(user_name text);

如果认为每次查询都要写dblink的一堆信息很麻烦的话，可以在db1中建一个view来解决。

**\[sql\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain]

1.  CREATE VIEW remote\_people\_user\_name AS   
2.  SELECT \* FROM dblink('hostaddr=192.168.0.222 port=5432 dbname=db2 user=postgres password=postgres',  
3.                       'SELECT user\_name From people') AS t(user\_name text);

![save_snippets.png][]

CREATE VIEW remote_people_user_name AS 
    SELECT * FROM dblink('hostaddr=192.168.0.222 port=5432 dbname=db2 user=postgres password=postgres',
                         'SELECT user_name From people') AS t(user_name text);

然后就可以从这个view中查询数据了。

**\[sql\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain]

1.  SELECT \* FROM remote\_people\_user\_name;

![save_snippets_01.png][]

SELECT * FROM remote_people_user_name;

如果不只是查询数据，而是需要修改db2的数据的情况下怎么弄呢？

**1. 先执行dblink\_connect保持连接**

**\[sql\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain]

1.  SELECT dblink\_connect('connection','hostaddr=192.168.0.222 port=5432 dbname=db2 user=postgres password=postgres');

![save_snippets_01.png][]

SELECT dblink_connect('connection','hostaddr=192.168.0.222 port=5432 dbname=db2 user=postgres password=postgres');

**2. 执行BEGIN命令**

SELECT dblink_exec('connection', 'BEGIN');

**3. 执行数据操作（update，insert，create等命令）**

SELECT dblink_exec('connection', 'insert 。。。数据操作');

**4. 执行事务提交**

SELECT dblink_exec('connection', 'COMMIT');

**5. 解除连接**

SELECT dblink_disconnect('connection');

[http_blog.csdn.net_hantiannan_article_details_7553108]: http://blog.csdn.net/hantiannan/article/details/7553108
[Link 1]: http://lib.csdn.net/base/14
[view plain]: http://blog.csdn.net/hantiannan/article/details/7553108#
[save_snippets_01.png]: /images/20220710/82b3348ba9ba413db9482c294e4af079.png
[save_snippets.png]: /images/20220710/f5ce478a9b7543628d582ebade39bf32.png