dblink_connect

名称

大纲

dblink_connect(text connstr) returns text
dblink_connect(text connname, text connstr) returns text

描述

dblink_connect()建立了远程PostgreSQL数据库的连接。 连接的服务器和数据库是通过标准libpq连接字符串被标识。 随意的,给连接分配名字。可以一次打开多个命名的连接,但是每次仅仅允许一个未命名连接。 连接将持续直到关闭或者数据库会话结束为止。

连接字符串也可能是已存在外服务器的名字。当定义外服务器时,推荐使用外部数据封装器dblink_fdw。 请看下面的例子,以及CREATE SERVER和CREATE USER MAPPING。

参数

返回值

返回状态总是OK(因为任何错误导致函数抛出错误而不是返回)。

注意

只有超级用户可能使用dblink_connect创建非口令认证连接。如果 非超级用户需要这个能力,使用dblink_connect_u。

选择包含等号的连接名是不明智的,正如这在其他dblink函数中打开 与连接信息字符串混淆的风险。

例子

SELECT dblink_connect('dbname=postgres');
 dblink_connect
----------------
 OK
(1 row)
SELECT dblink_connect('myconn', 'dbname=postgres');
 dblink_connect
----------------
 OK
(1 row)
-- 外数据封装功能
-- 注意: 本地连接必须要求密码认证工作正常
-- 否则,你将接收到来自dblink_connect()的下面的错误:
-- ----------------------------------------------------------------------
-- ERROR: 需要密码
-- DETAIL: 如果服务器不需要密码,那么非超级用户无法连接。
-- HINT: 必须改变目标服务器的身份验证方法。
CREATE SERVER fdtest FOREIGN DATA WRAPPER dblink_fdw OPTIONS (hostaddr '127.0.0.1', dbname 'contrib_regression');
CREATE USER dblink_regression_test WITH PASSWORD 'secret';
CREATE USER MAPPING FOR dblink_regression_test SERVER fdtest OPTIONS (user 'dblink_regression_test', password 'secret');
GRANT USAGE ON FOREIGN SERVER fdtest TO dblink_regression_test;
GRANT SELECT ON TABLE foo TO dblink_regression_test;
\set ORIGINAL_USER :USER
\c - dblink_regression_test
SELECT dblink_connect('myconn', 'fdtest');
 dblink_connect 
----------------
 OK
(1 row)
SELECT * FROM dblink('myconn','SELECT * FROM foo') AS t(a int, b text, c text[]);
 a | b | c 
----+---+---------------
 0 | a | {a0,b0,c0}
 1 | b | {a1,b1,c1}
 2 | c | {a2,b2,c2}
 3 | d | {a3,b3,c3}
 4 | e | {a4,b4,c4}
 5 | f | {a5,b5,c5}
 6 | g | {a6,b6,c6}
 7 | h | {a7,b7,c7}
 8 | i | {a8,b8,c8}
 9 | j | {a9,b9,c9}
 10 | k | {a10,b10,c10}
(11 rows)
\c - :ORIGINAL_USER
REVOKE USAGE ON FOREIGN SERVER fdtest FROM dblink_regression_test;
REVOKE SELECT ON TABLE foo FROM dblink_regression_test;
DROP USER MAPPING FOR dblink_regression_test SERVER fdtest;
DROP USER dblink_regression_test;
DROP SERVER fdtest;