dblink的使用 pg的跨库查询工具
select dblink_connect('host=localhost port=5432 user=sqluser dbname=tm_samples password=****');
select dblink_disconnect();
1、安装
在安装包的目录下
[postgres@localhost postgresql-9.1.1]$ find /postgresql-9.1.1/ -name dblink
/postgresql-9.1.1/contrib/dblink
使用postgres用户安装即可
[postgres@localhost dblink]$ make && make install
在实际安装目录的lib下多了一个dblink.so
/pg/lib/postgresql
-rwxr-xr-x 1 postgres postgres 49174 Jul 22 23:22 dblink.so
进入psql，创建扩展dblink
postgres=# \c liodb lio
You are now connected to database "liodb" as user "lio".
liodb=# create extension dblink;
CREATE EXTENSION
也可以使用命令：psql -f dblink.sql -d 数据库 -U 用户名
2、使用
select dblink_connect('hostaddr=192.168.10.173 port=5432 dbname=tina user=postgres password=tina');
--这个函数用来建立到远程数据库的连接。
liodb=# select dblink_connect('hostaddr=192.168.10.173 port=5432 dbname=tina user=postgres password=tina');
dblink_connect
----------------
OK
(1 row)
liodb=# select * from father; ---这个表在lio中是不存在的
ERROR: relation "father" does not exist at character 15
STATEMENT: select * from father;
ERROR: relation "father" does not exist
LINE 1: select * from father;
#重点在于as 后的重命名表，需要定义表结构，表中的类型需要和select返回的类型保持一致。 ^
liodb=# select * from dblink('select name from father') as t_1(name text);
name
-----------
Las vegas
Mariposa
madison
(3 rows)
这样就可以查询到tina库中的father表的内容
--向远程数据库插入一条记录
select dblink_exec('insert into father values(/'moxige/',/'3.54/',/'899/')');
查询：select * from dblink('select * from father')as fa(name text,population float,altutude text);
3、操作完成,断开连接
select dblink_diconnect();