dblink_connect

PostgreSQL 9.4.4 中文手册
上一页 | 上一级 |  | 下一页

# dblink_connect

## 名称

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。

## 参数

`conname`

  用于连接的名称；如果忽略，那么打开一个未命名的连接， 替换任何已存在未命名连接。

`connstr`

  libpq-形式连接信息字符串，比如`hostaddr=127.0.0.1 port=5432 dbname=mydb user=postgres password=mypasswd`。 更多详情请参阅第 31.1.1 节。 另外，外服务器名称。

## 返回值

返回状态总是`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;

上一页 | 起始页 | 下一页
dblink | 上一级 | dblink_connect_u