2019獨角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

有時候的業(yè)務(wù)需要參照其他數(shù)據(jù)庫的數(shù)據(jù)。

我們可以在程序中分別從兩個數(shù)據(jù)庫中取值然后處理。但這樣開發(fā)效率和性能都不是很好。

如果兩個數(shù)據(jù)庫都是PostgreSQL的話，用擴展的DBLINK功能非常簡單。

比如一個數(shù)據(jù)db1，db2。首先需要把db1加入dblink擴展。

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

?
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);

如果認(rèn)為每次查詢都要寫dblink的一堆信息很麻煩的話，可以在db1中建一個view來解決。
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中查詢數(shù)據(jù)了。 ?

SELECT * FROM remote_people_user_name;

如果不只是查詢數(shù)據(jù)，而是需要修改db2的數(shù)據(jù)的情況下怎么弄呢？

1. 先執(zhí)行dblink_connect保持連接

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

2. 執(zhí)行BEGIN命令 SELECT dblink_exec('connection', 'BEGIN');

3. 執(zhí)行數(shù)據(jù)操作（update，insert，create等命令）

SELECT dblink_exec('connection', 'insert 。。。數(shù)據(jù)操作');

4. 執(zhí)行事務(wù)提交

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

5. 解除連接

SELECT dblink_disconnect('connection');

轉(zhuǎn)載于:https://my.oschina.net/u/201125/blog/75344

總結(jié)

以上是生活随笔為你收集整理的Postgres访问其他PostgresQL数据库的功能DBLINK的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。