ThinkChat2.0新版上线,更智能更精彩,支持会话、画图、阅读、搜索等,送10W Token,即刻开启你的AI之旅 广告
# dblink_connect ## Name dblink_connect -- 打开到远程数据库的持久连接 ## Synopsis ``` dblink_connect(text connstr) returns text dblink_connect(text connname, text connstr) returns text ``` ## 描述 `dblink_connect()`建立了远程PostgreSQL数据库的连接。 连接的服务器和数据库是通过标准libpq连接字符串被标识。 随意的,给连接分配名字。可以一次打开多个命名的连接,但是每次仅仅允许一个未命名连接。 连接将持续直到关闭或者数据库会话结束为止。 连接字符串也可能是已存在外服务器的名字。当定义外服务器时,推荐使用外数据包`dblink_fdw`。 请看下面的例子,以及[CREATE SERVER](#calibre_link-6)和[CREATE USER MAPPING](#calibre_link-68)。 ## 参数 `conname` 用于连接的名称;如果忽略,那么打开一个未命名的连接, 替换任何已存在未命名连接。 `connstr` libpq-形式连接信息字符串,比如`hostaddr=127.0.0.1 port=5432 dbname=mydb user=postgres password=mypasswd`。 更多详情请参阅[Section 31.1.1](#calibre_link-458)。 另外,外服务器名称。 ## 返回值 返回状态总是`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; ```