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来做,这样毕竟程序里代码会简单很多。
- scala 学习笔记(04) OOP(上)主从构造器/私有属性/伴生对象(单例静态类)/apply方法/嵌套类
- 使用jQuery封装实用函数
- scala 学习笔记(05) OOP(中)灵活的trait
- Web Fundamentsals学习1-Multiple-Screen-Site
- Vagrant使用
- java 中的异步回调
- 澳大利亚域名管理机构多年敲竹杠?
- ASP.NET中使用HttpWebRequest调用WCF
- scala 学习笔记(06) OOP(下)多重继承 及 AOP
- Angular企业级开发(4)-ngResource和REST介绍
- CSS魔法堂:"那不是bug,是你不懂我!" by inline-block
- scala 学习笔记(03) 参数缺省值、不定个数参数、类的属性(Property)、泛型初步
- Cmd Markdown编辑器简明语法手册
- 如何让spring mvc web应用启动时就执行特定处理
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- DFS最难也就这样了
- 浅谈二分查找的变种
- BFS(广度优先算法)也就这么回事
- 从零钱兑换再看动态规划的套路
- Azure认知服务之使用墨迹识别功能识别手写汉字
- 基于 TypeScript 的 Weex 优化实践
- R语言数据库中如何多条件排序
- 用好 Java 中的枚举,真的没有那么简单!
- ABAP整型类型的几种位操作 - OR, AND, XOR的
- 【机器学习】算法原理详细推导与实现(七):决策树算法
- 如何使用代码修改SAP CRM One Order CUMULAT_H对象的值
- Caffeine Cache~高性能 Java 本地缓存之王
- 用Python的Pandas和Matplotlib绘制股票唐奇安通道,布林带通道和鳄鱼组线
- Java的Covariance设计原理和SAP ABAP的模拟实现
- ABAP和Java的tag(marker) interface