这期内容当中小编将会给大家带来有关PostgreSQL中怎么利用dblink实现跨库查询，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。

一开始研究知道了sql语句的写法，但是执行通过不了，需要先安装dblink扩展。这些博文里都没说清楚，感谢网友指点，在windows下只需要在相应的数据库下执行sql语句“create extension dblink”就ok了。而以上的博文基本上说的都是linux下的操作方法，也因此我走了弯路。

2.下载了PostgreSQL的源代码，却不知道语句在哪执行，貌似是在linux下的shell里执行的，我却在psql和cmd里都试过，都是走过的弯路啊。也尝试过直接拷贝dblink.sql里的语句运行，却通不过报错。

3.windows下很简单，一句sql就搞定了“create extension dblink”.

在扩展里可以看到多了一个dblink：

函数里也相应的有了dblink开头的一些函数：

这句sql语句貌似只调用运行了dblink.control文件：

3.写sql语句测试下，是否ok。

跨库查询，先要建立数据库连接，才能查询否则会报错。

如图是提示的connection named"unnamed",因为有其他的连接，如果没有任何连接，则会提示connection not available：

使用dblink(text,text)，***个参数是连接串，第二个参数是sql语句。执行成功：

或者使用dblink_connect(text)先建立连接，再用dblink(text)做跨库查询：

查看连接：

selectdblink_get_connections()

断开所有连接：

selectdblink_disconnect()

断开指定名称的连接：

selectdblink_disconnect('test')

如之前建立过名为‘test'的连接：

selectdblink_connect('test','host=localhostdbname=cbe_stauser=postgrespassword=lifc126820');

则会提示断开成功。

4.***，我自己需要的sql语句也ok了，在同一个服务器上的两个数据库3张表的联合查询，先建立连接再做查询：

selectdblink_connect('host=localhostdbname=cbe_userdatauser=postgrespassword=lifc126820');selectA.id,A.codeaspoicode,A.cname,A.geo,A.x,A.y,A.s01,A.s02,A.s03,A.updatetime,A.tbcode,D.code,D.data,D.value,D.cnameascolname,D.ifdata,D.sortfromtb_test_poiAinnerjoin((select*fromdblink('selectpoicode,code,data,valuefromtb_test_data_poi')asT1(poicodecharactervarying(50),codecharactervarying(50),datadoubleprecision,valuecharactervarying(500)))Binnerjoin(select*fromdblink('selectcname,codeascode1,ifdata,sortfromtb_test_index_poi')asT2(cnamecharactervarying(200),code1charactervarying(50),ifdatacharactervarying(5),sortcharactervarying(50)))ConB.code=C.code1)DonA.code=D.poicode;

如果做成视图也行，这里就需要用dblink(text,text)，如果直接用上面的sql语句会报错说无法建立连接：

CREATEORREPLACEVIEWvw_test_poiASSELECTa.id,a.codeASpoicode,a.cname,a.geo,a.x,a.y,a.s01,a.s02,a.s03,a.updatetime,a.tbcode,d.code,d.data,d.value,d.cnameAScolname,d.ifdata,d.sortFROMtb_test_poiaJOIN((SELECTt1.poicode,t1.code,t1.data,t1.valueFROMdblink('host=localhostdbname=cbe_userdatauser=postgrespassword=lifc126820'::text,'selectpoicode,code,data,valuefromtb_test_data_poi'::text)t1(poicodecharactervarying(50),codecharactervarying(50),datadoubleprecision,valuecharactervarying(500)))bJOIN(SELECTt2.cname,t2.code1,t2.ifdata,t2.sortFROMdblink('host=localhostdbname=cbe_userdatauser=postgrespassword=lifc126820'::text,'selectcname,codeascode1,ifdata,sortfromtb_test_index_poi'::text)t2(cnamecharactervarying(200),code1charactervarying(50),ifdatacharactervarying(5),sortcharactervarying(50)))cONb.code::text=c.code1::text)dONa.code::text=d.poicode::text

上述就是小编为大家分享的PostgreSQL中怎么利用dblink实现跨库查询了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注亿速云行业资讯频道。