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。
connname
用于此连接的名称;如果省略,则打开一个未命名的连接,替换任何现有的未命名连接。
connstr
libpq 样式的连接信息字符串,例如 hostaddr=127.0.0.1 port=5432 dbname=mydb user=postgres password=mypasswd options=-csearch_path=
。有关详细信息,请参见 第 34.1.1 节。或者,外部服务器的名称。
返回状态,始终为 OK
(因为任何错误都会导致函数引发错误,而不是返回)。
如果不受信任的用户有权访问尚未采用 安全架构使用模式 的数据库,请在每个会话开始时从 search_path
中移除可公开写入的架构。例如,可以将 options=-csearch_path=
添加到 connstr
。此注意事项不特定于 dblink
;它适用于执行任意 SQL 命令的每个界面。
只有超级用户才能使用 dblink_connect
创建非密码认证和非 GSSAPI 认证的连接。如果非超级用户需要此功能,请改用 dblink_connect_u
。
最好不要选择包含等号的连接名称,因为这会带来与其他 dblink
函数中的连接信息字符串混淆的风险。
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;