dblink_connect

dblink_connect —打开与远程数据库的持久连接

Synopsis

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

Description

dblink_connect()构建与远程 PostgreSQL 数据库的连接。通过标准的 libpq 连接字符串标识要联系的服务器和数据库。 (可选)可以为连接分配名称。可以一次打开多个命名的连接，但是一次只允许一个未命名的连接。连接将一直持续到关闭或数据库会话结束为止。

连接字符串也可以是现有外部服务器的名称。定义外部服务器时，建议使用外部数据包装器dblink_fdw。请参见下面的示例以及CREATE SERVER和创建用户 Map。

Arguments

• connname

  • 用于此连接的名称；如果省略，将打开一个未命名的连接，替换任何现有的未命名的连接。

• connstr

  • libpq 样式的连接信息字符串，例如hostaddr=127.0.0.1 port=5432 dbname=mydb user=postgres password=mypasswd options=-csearch_path=。有关详细信息，请参见Section 33.1.1。或者，外部服务器的名称。

Return Value

返回状态，该状态始终为OK(因为任何错误都会导致函数抛出错误而不是返回)。

Notes

如果不受信任的用户可以访问未采用安全模式使用模式的数据库，请通过从search_path删除可公开写模式来开始每个会话。例如，可以将options=-csearch_path=添加到* connstr *。这种考虑并非特定于dblink；它适用于执行任意 SQL 命令的每个接口。

仅超级用户可以使用dblink_connect创建未经密码验证的连接。如果非超级用户需要此功能，请改用dblink_connect_u。

选择包含等号的连接名称是不明智的，因为这会带来混淆其他dblink函数中的连接信息字符串的风险。

Examples

SELECT dblink_connect('dbname=postgres options=-csearch_path=');
 dblink_connect
----------------
 OK
(1 row)

SELECT dblink_connect('myconn', 'dbname=postgres options=-csearch_path=');
 dblink_connect
----------------
 OK
(1 row)

-- FOREIGN DATA WRAPPER functionality
-- Note: local connection must require password authentication for this to work properly
--       Otherwise, you will receive the following error from dblink_connect():
--       ----------------------------------------------------------------------
--       ERROR:  password is required
--       DETAIL:  Non-superuser cannot connect if the server does not request a password.
--       HINT:  Target server's authentication method must be changed.

CREATE SERVER fdtest FOREIGN DATA WRAPPER dblink_fdw OPTIONS (hostaddr '127.0.0.1', dbname 'contrib_regression');

CREATE USER regress_dblink_user WITH PASSWORD 'secret';
CREATE USER MAPPING FOR regress_dblink_user SERVER fdtest OPTIONS (user 'regress_dblink_user', password 'secret');
GRANT USAGE ON FOREIGN SERVER fdtest TO regress_dblink_user;
GRANT SELECT ON TABLE foo TO regress_dblink_user;

\set ORIGINAL_USER :USER
\c - regress_dblink_user
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 regress_dblink_user;
REVOKE SELECT ON TABLE foo FROM regress_dblink_user;
DROP USER MAPPING FOR regress_dblink_user SERVER fdtest;
DROP USER regress_dblink_user;
DROP SERVER fdtest;