国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數據庫 > PostgreSQL > 正文

PostgreSQL中使用dblink實現跨庫查詢的方法

2020-03-12 23:52:05
字體:
來源:轉載
供稿:網友

最近一個sql語句涉及到跨庫的表之間的聯合查詢,故研究學習下。

一開始研究知道了sql語句的寫法,但是執行通過不了,需要先安裝dblink擴展。這些博文里都沒說清楚,感謝網友指點,在windows下只需要在相應的數據庫下執行sql語句“create extension dblink”就ok了。而以上的博文基本上說的都是linux下的操作方法,也因此我走了彎路。

2.下載了PostgreSQL的源代碼,卻不知道語句在哪執行,貌似是在linux下的shell里執行的,我卻在psql和cmd里都試過,都是走過的彎路啊。也嘗試過直接拷貝dblink.sql里的語句運行,卻通不過報錯。

PostgreSQL,跨庫查詢

3.windows下很簡單,一句sql就搞定了“create extension dblink”.
在擴展里可以看到多了一個dblink:

PostgreSQL,跨庫查詢

函數里也相應的有了dblink開頭的一些函數:

PostgreSQL,跨庫查詢

這句sql語句貌似只調用運行了dblink.control文件:

PostgreSQL,跨庫查詢

3.寫sql語句測試下,是否ok。

跨庫查詢,先要建立數據庫連接,才能查詢否則會報錯。

如圖是提示的connection named"unnamed",因為有其他的連接,如果沒有任何連接,則會提示connection not available:

PostgreSQL,跨庫查詢

使用dblink(text,text),第一個參數是連接串,第二個參數是sql語句。執行成功:

PostgreSQL,跨庫查詢

或者使用dblink_connect(text)先建立連接,再用dblink(text)做跨庫查詢:

PostgreSQL,跨庫查詢

查看連接:

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頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 内丘县| 新平| 荔波县| 虎林市| 郓城县| 罗定市| 平顺县| 安国市| 犍为县| 西贡区| 仲巴县| 新龙县| 饶河县| 新巴尔虎右旗| 固安县| 日土县| 定西市| 山西省| 龙南县| 安福县| 苍梧县| 嘉鱼县| 兴文县| 会昌县| 北辰区| 三原县| 化州市| 冀州市| 宜兴市| 宜君县| 五大连池市| 鸡东县| 临沂市| 阳朔县| 九寨沟县| 桑植县| 山东| 嘉鱼县| 桑日县| 公主岭市| 普兰店市|