PostgreSQL中使用dblink实现跨库查询的方法
最近一个sql语句涉及到跨库的表之间的联合查询，故研究学习下。
一开始研究知道了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)做跨库查询：
查看连接：
select dblink_get_connections()
断开所有连接：
select dblink_disconnect()
断开指定名称的连接：
select dblink_disconnect('test')
如之前建立过名为‘test'的连接：
select dblink_connect('test','host=localhost dbname=cbe_sta user=postgres password=lifc126820');
则会提示断开成功。
4.最后，我自己需要的sql语句也ok了，在同一个服务器上的两个数据库3张表的联合查询，先建立连接再做查询：
select dblink_connect('host=localhost dbname=cbe_userdata user=postgres password=lifc126820');
select A.id,A.code as poicode,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.cname as colname,D.ifdata,D.sort from tb_test_poi A inner join ((select * from dblink('select poicode,code,data,value from tb_test_data_poi') as T1(poicode character varying(50),code character varying(50),data double precision,value character varying(500))) B inner join (select * from dblink('select cname,code as code1,ifdata,sort from tb_test_index_poi') as T2(cname character varying(200),code1 character varying(50),ifdata character varying(5),sort character varying(50))) C on B.code=C.code1) D on A.code=D.poicode;
如果做成视图也行，这里就需要用dblink(text,text)，如果直接用上面的sql语句会报错说无法建立连接：
CREATE OR REPLACE VIEW vw_test_poi AS
SELECT a.id, a.code AS poicode, 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.cname AS colname,
d.ifdata, d.sort
FROM tb_test_poi a
JOIN (( SELECT t1.poicode, t1.code, t1.data, t1.value
FROM dblink('host=localhost dbname=cbe_userdata user=postgres password=lifc126820'::text, 'select poicode,code,data,value from tb_test_data_poi'::text) t1(poicode character varying(50), code character varying(50), data double precision, value character varying(500))) b
JOIN ( SELECT t2.cname, t2.code1, t2.ifdata, t2.sort
FROM dblink('host=localhost dbname=cbe_userdata user=postgres password=lifc126820'::text, 'select cname,code as code1,ifdata,sort from tb_test_index_poi'::text) t2(cname character varying(200), code1 character varying(50), ifdata character varying(5), sort character varying(50))) c ON b.code::text = c.code1::text) d ON a.code::text = d.poicode::text;
我发觉执行效率有点慢啊，查出来的数据是1万多条，用了2秒多。目前我的程序里并没有用dblink来做，因为输入参数可以先单独查一张表即可，然后给另外两张表的信息关联查询上ok了，所以我分两步来做了，解决了这个问题。具体效率未深入对比，如果后期需要调整，可以考虑用dblink来做，这样毕竟程序里代码会简单很多。
相关文章
在 PostgreSQL 中,恢复数据库后,使用 DBeaver 等工具可以看到数据库和表名,但无法查询到表中数据,可能有很多原因,本文给大家分析了PostgreSQL无法查看表中数据问题的原因和解决方法,需要的朋友可以参考下2025-04-04
Postgresql 跨库同步表及postgres_fdw的用法说明
这篇文章主要介绍了Postgresql 跨库同步表及postgres_fdw的用法说明，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-01-01
这篇文章主要介绍了初识PostgreSQL存储过程,本文讲解了PostgreSQL中存储过程的语法,并给出了一个操作实例,需要的朋友可以参考下2015-01-01
这篇文章主要介绍了浅谈Postgresql默认端口5432你所不知道的一点，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-01-01
这篇文章主要介绍了PostgreSQL备份工具 pgBackRest使用详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-02-02
PostgreSQL 流复制是 9.0 提供的一种新的 WAL 传递方法，使用流复制时，每当 Primary 节点 WAL 产生，就会马上传递到 Standby 节点，流复制提供异步和同步两种模式，同步模式可以保障数据 0 丢失，这篇文章主要介绍了PostgreSQL 流复制搭建,需要的朋友可以参考下2023-09-09
PostgreSQL 提供了多种不同的复制表的方法，它们的差异在于是否需要复制表结构或者数据，这篇文章主要介绍了PostgreSQL 复制表的 5 种方式,需要的朋友可以参考下2023-01-01
PostgreSQL是一个强大的开源对象-关系型数据库管理系统,以其高可扩展性和标准化而著称,这篇文章主要介绍了docker安装Postgresql数据库及基本操作的相关资料,需要的朋友可以参考下2025-03-03
详解如何在Ubuntu 18.04上安装和使用PostgreSQL
关系数据库管理系统是许多网站和应用程序的关键组件,它们提供了一种结构化的方式来存储、组织和访问信息,本文演示了如何在 Ubuntu 18.04 VPS 实例上安装 Postgres,并提供了基本数据库管理的说明,需要的朋友可以参考下2024-07-07
关于向PostgreSQL数据库插入Date类型数据报错问题解决方案
本文给大家介绍在将数据库从Oracle改为PostgreSQL时遇到的日期类型插入错误,通过使用PostgreSQL的特定语法和更改动态SQL语句解决了问题,本文给大家介绍的非常详细,需要的朋友参考下吧2024-12-12
最新评论