dblink_connect

描述

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;