【PostgreSQL】PostgreSQL的dblink扩展模块详解（史上最全） ...

西河刘卡车医  金牌会员 | 2024-6-19 11:56:45 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 871|帖子 871|积分 2613

一、PostgreSQL的dblink扩展模块简介



  • PostgreSQL的dblink是一个支持在一个数据库会话中连接到其他PostgreSQL数据库的扩展模块。可以实现在差别的数据库之间进行通信和交互。它可以让你在一个数据库中访问另一个数据库的表格和函数，甚至可以在差别的服务器之间进行数据交互。
二、dblink利用方法

下面是dblink的利用方法：
2.1、安装dblink扩展

2.1.1、安装dblink扩展

在利用dblink之前，需要确保已经安装了dblink扩展。可以利用以下下令进行安装：
  1. CREATE EXTENSION dblink;
复制代码
2.1.2、查询已安装的dblink扩展情况

2.1.2.1、已安装的扩展

  1. select * from pg_extension;
复制代码
2.1.2.1、所有扩展

  1. select * from pg_available_extensions where name like '%dblink%';
复制代码
2.2、创建连接

利用dblink连接到另一个数据库，需要指定连接参数，例如主机名、端口号、用户名和密码等。可以利用以下语法创建连接：
  1. SELECT dblink_connect('dblink_name', 'dbname=mydb host=localhost port=5432 user=myuser password=mypassword');
复制代码
其中，dblink_name是本身起的dblink的名字，也可以是连接字符串。
dbname是要连接的数据库名称，host是要连接的主机名，port是要连接的端口号，user是要连接的用户名，password是要连接的密码。
2.3、查询数据

连接成功后，可以利用dblink执行SQL查询语句。例如，可以利用以下语法在另一个数据库中查询数据：
  1. SELECT * FROM dblink('dblink_name', 'SELECT * FROM mytable') AS t(id int, name text);
复制代码
其中，第一个参数是dblink名字，也可以是连接字符串。
第二个参数是要执行的SQL查询语句。AS子句用于指定返回结果的列名和数据类型。
例如下面的示例SQL：
  1. select * from dblink('dblink_name','select log_id, log_name from tzq.tzq_log_t') as t (log_id int8, log_name varchar(150));
复制代码
2.4、执行函数

除了查询数据，还可以利用dblink在另一个数据库中执行函数。例如，可以利用以下语法在另一个数据库中执行一个函数：
  1. SELECT dblink('dblink_name', 'SELECT myfunction()');
复制代码
其中，第一个参数是dblink名字，也可以是连接字符串。
第二个参数是要执行的函数调用语句。
例如下面的示例SQL：
  1. select * from dblink('dblink_name','
  2. select plan.get_all_table_ddl(''tzq'')') as t (get_all_table_ddl text);
复制代码
2.5、关闭连接

完成操纵后，需要关闭连接以释放资源。可以利用以下语法关闭连接：
  1. SELECT dblink_disconnect('dblink_name');
复制代码
其中，参数是dblink名字，也可以是连接字符串。
2.6、查看 dblink 连接

  1. SELECT dblink_get_connections();
复制代码
三、dblink涉及的所有函数详解

3.1、dblink_connect 打开一个到远程数据库的持久连接

   dblink_connect 打开一个到远程数据库的持久连接
  

  • 大纲
  1. dblink_connect(text connstr) 返回 text
  2. dblink_connect(text connname, text connstr) 返回 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。详见第33.1.1节。此外，还可以是一个外部服务器的名字。

  • 返回值

    • 返回状态，它总是OK（由于任何错误会导致该函数抛出一个错误而不是返回）。

  • 注解

    • 如果不可信用户可以或许访问一个没有采用安全方案利用模式的数据库，应该在开始每个会话时从search_path中移除公共可写的方案。例如，可以把options=-csearch_path=增加到connstr。这种思量不是特别针对dblink，它适用于每一种执行恣意SQL下令的接口。
    • 只有超等用户可以或许利用dblink_connect来创建无口令认证连接。如果非超等用户需要这种能力，利用dblink_connect_u。
    • 选择包罗等号的连接名是不明智的，由于这会产生与在其他dblink函数中的连接信息串混淆的风险。

  • 例子
  1. SELECT dblink_connect('dbname=postgres options=-csearch_path=');
  2. dblink_connect
  3. ----------------
  4. OK
  5. (1 row)
  7. SELECT dblink_connect('myconn', 'dbname=postgres options=-csearch_path=');
  8. dblink_connect
  9. ----------------
  10. OK
  11. (1 row)
  13. -- FOREIGN DATA WRAPPER functionality
  14. -- Note: local connection must require password authentication for this to work properly
  15. --       Otherwise, you will receive the following error from dblink_connect():
  16. --       ERROR:  password is required
  17. --       DETAIL:  Non-superuser cannot connect if the server does not request a password.
  18. --       HINT:  Target server's authentication method must be changed.
  20. CREATE SERVER fdtest FOREIGN DATA WRAPPER dblink_fdw OPTIONS (hostaddr '127.0.0.1', dbname 'contrib_regression');
  22. CREATE USER regress_dblink_user WITH PASSWORD 'secret';
  23. CREATE USER MAPPING FOR regress_dblink_user SERVER fdtest OPTIONS (user 'regress_dblink_user', password 'secret');
  24. GRANT USAGE ON FOREIGN SERVER fdtest TO regress_dblink_user;
  25. GRANT SELECT ON TABLE foo TO regress_dblink_user;
  27. \set ORIGINAL_USER :USER
  28. \c - regress_dblink_user
  29. SELECT dblink_connect('myconn', 'fdtest');
  30. dblink_connect
  31. ----------------
  32. OK
  33. (1 row)
  35. SELECT * FROM dblink('myconn', 'SELECT * FROM foo') AS t(a int, b text, c text[]);
  36. a  | b |       c
  37. ----+---+---------------
  38.   0 | a | {a0,b0,c0}
  39.   1 | b | {a1,b1,c1}
  40.   2 | c | {a2,b2,c2}
  41.   3 | d | {a3,b3,c3}
  42.   4 | e | {a4,b4,c4}
  43.   5 | f | {a5,b5,c5}
  44.   6 | g | {a6,b6,c6}
  45.   7 | h | {a7,b7,c7}
  46.   8 | i | {a8,b8,c8}
  47.   9 | j | {a9,b9,c9}
  48. 10 | k | {a10,b10,c10}
  49. (11 rows)
  51. \c - :ORIGINAL_USER
  52. REVOKE USAGE ON FOREIGN SERVER fdtest FROM regress_dblink_user;
  53. REVOKE SELECT ON TABLE foo FROM regress_dblink_user;
  54. DROP USER MAPPING FOR regress_dblink_user SERVER fdtest;
  55. DROP USER regress_dblink_user;
  56. DROP SERVER fdtest;
复制代码
3.2、dblink_connect_u 不安全地打开一个到远程数据库的持久连接

dblink_connect_u 不安全地打开一个到远程数据库的持久连接


  • 大纲
  1. dblink_connect_u(text connstr) 返回 text
  2. dblink_connect_u(text connname, text connstr) 返回 text
复制代码


  • 描述

    • dblink_connect_u()和dblink_connect()一样，不外它将允许非超等用户利用恣意认证方式来连接。
    • 如果远程服务器选择了一种不涉及口令的认证方式，那么大概发生模拟以及后续的扩大权限，由于该会话看起来像由运行PostgreSQL的用户发起的。此外，即使远程服务器不要求一个口令，也大概从服务器情况提供该口令，例如一个属于服务器用户的~/.pgpass文件。这带来的不但是模拟的风险，而且还有将口令暴露给不可信的远程服务器的风险。因此，dblink_connect_u()最初是用所有从PUBLIC撤销的特权安装的，这让它只能被超等用户调用。在某些情况中，为dblink_connect_u()授予EXECUTE权限给可信的指定用户是合适的，但是必须鉴戒。我们也保举任何属于服务器用户的~/.pgpass文件不能包罗任何指定了一个通配符主机名的记载。

详见dblink_connect()。
3.3、dblink_disconnect 关闭一个到远程数据库的持久连接

dblink_disconnect 关闭一个到远程数据库的持久连接


  • 大纲
  1. dblink_disconnect() 返回 text
  2. dblink_disconnect(text connname) 返回 text
复制代码


  • 描述

    • dblink_disconnect()关闭一个之前被dblink_connect()打开的连接。不带参数的情势关闭一个未命名连接。

  • 参数

    • connname
      要被关闭的命名连接的名字。

  • 返回值
    它总是OK（由于任何错误会导致该函数抛出一个错误而不是返回）。
  • 例子
  1. SELECT dblink_disconnect();
  2. dblink_disconnect
  3. -------------------
  4. OK
  5. (1 row)
  7. SELECT dblink_disconnect('myconn');
  8. dblink_disconnect
  9. -------------------
  10. OK
  11. (1 row)
复制代码
3.4、dblink 在一个远程数据库中执行一个查询

dblink 在一个远程数据库中执行一个查询


  • 大纲
  1. dblink(text connname, text sql [, bool fail_on_error]) 返回记录集
  2. dblink(text connstr, text sql [, bool fail_on_error]) 返回记录集
  3. dblink(text sql [, bool fail_on_error]) 返回记录集
复制代码


  • 描述
dblink在一个远程数据库中执行一个查询（通常是一个SELECT，但是也可以是恣意返回行的 SQL 语句）。
当给定两个text参数时，第一个被首先作为一个持久连接的名称进行查找；如果找到，该下令会在该连接上被执行。如果没有找到，第一个参数被视作一个用于dblink_connect的连接信息字符串，并且被指出的连接只是在这个下令的持续期间被创建。


  • 参数

    • connname
      要利用的连接名。忽略这个参数将利用未命名连接。
    • connstr
      如之前为dblink_connect所描述的一个连接信息字符串。
    • sql
      你盼望在远程数据库中执行的 SQL 查询，例如select * from foo。
    • fail_on_error
      如果为真（忽略时的默认值），那么在连接的远端抛出的一个错误也会导致当地抛出一个错误。如果为假，远程错误只在当地被报告为一个 NOTICE，并且该函数不反回行。

  • 返回值
该函数返回查询产生的行。由于dblink能与任何查询一起利用，它被声明为返回record，而不是指定恣意特定的列集合。这意味着你必须指定在调用的查询中所期待的列集合 否则PostgreSQL将不知道会得到什么。这里是一个例子：
  1. SELECT *
  2.     FROM dblink('dbname=mydb options=-csearch_path=',
  3.                 'select proname, prosrc from pg_proc')
  4.       AS t1(proname name, prosrc text)
  5.     WHERE proname LIKE 'bytea%';
复制代码
FROM子句的“alias”部分必须指定函数将返回的列名及类型（在一个别名中指定列名实际上是标准 SQL 语法，但是指定列类型是一种PostgreSQL扩展）。这允许系统在尝试执行该函数之前就理解*将展开成什么，以及WHERE子句中的proname指的什么。在运行时，如果来自远程数据库的实际查询结果和FROM子句中显示的列数差别，将会抛出一个错误。不外，列名不需要匹配，并且dblink并不坚持精确地匹配类型。只要被返回的数据字符串是FROM子句中声明的列类型的合法输入，它就将会成功。


  • 注解
    一种将预定义查询用于dblink的方便方法是创建一个视图。这允许列类型信息被埋藏在该视图中，而不是在每一个查询中都拼写出来。例如：
  1. CREATE VIEW myremote_pg_proc AS
  2.   SELECT *
  3.     FROM dblink('dbname=postgres options=-csearch_path=',
  4.                 'select proname, prosrc from pg_proc')
  5.     AS t1(proname name, prosrc text);
  7. SELECT * FROM myremote_pg_proc WHERE proname LIKE 'bytea%';
复制代码


  • 例子
  2. SELECT * FROM dblink('dbname=postgres options=-csearch_path=',
  3.                      'select proname, prosrc from pg_proc')
  4.   AS t1(proname name, prosrc text) WHERE proname LIKE 'bytea%';
  5.   proname   |   prosrc
  6. ------------+------------
  7. byteacat   | byteacat
  8. byteaeq    | byteaeq
  9. bytealt    | bytealt
  10. byteale    | byteale
  11. byteagt    | byteagt
  12. byteage    | byteage
  13. byteane    | byteane
  14. byteacmp   | byteacmp
  15. bytealike  | bytealike
  16. byteanlike | byteanlike
  17. byteain    | byteain
  18. byteaout   | byteaout
  19. (12 rows)
  21. SELECT dblink_connect('dbname=postgres options=-csearch_path=');
  22. dblink_connect
  23. ----------------
  24. OK
  25. (1 row)
  27. SELECT * FROM dblink('select proname, prosrc from pg_proc')
  28.   AS t1(proname name, prosrc text) WHERE proname LIKE 'bytea%';
  29.   proname   |   prosrc
  30. ------------+------------
  31. byteacat   | byteacat
  32. byteaeq    | byteaeq
  33. bytealt    | bytealt
  34. byteale    | byteale
  35. byteagt    | byteagt
  36. byteage    | byteage
  37. byteane    | byteane
  38. byteacmp   | byteacmp
  39. bytealike  | bytealike
  40. byteanlike | byteanlike
  41. byteain    | byteain
  42. byteaout   | byteaout
  43. (12 rows)
  45. SELECT dblink_connect('myconn', 'dbname=regression options=-csearch_path=');
  46. dblink_connect
  47. ----------------
  48. OK
  49. (1 row)
  51. SELECT * FROM dblink('myconn', 'select proname, prosrc from pg_proc')
  52.   AS t1(proname name, prosrc text) WHERE proname LIKE 'bytea%';
  53.   proname   |   prosrc
  54. ------------+------------
  55. bytearecv  | bytearecv
  56. byteasend  | byteasend
  57. byteale    | byteale
  58. byteagt    | byteagt
  59. byteage    | byteage
  60. byteane    | byteane
  61. byteacmp   | byteacmp
  62. bytealike  | bytealike
  63. byteanlike | byteanlike
  64. byteacat   | byteacat
  65. byteaeq    | byteaeq
  66. bytealt    | bytealt
  67. byteain    | byteain
  68. byteaout   | byteaout
  69. (14 rows)
复制代码
3.5、dblink_exec 在一个远程数据库中执行一个下令

dblink_exec 在一个远程数据库中执行一个下令


  • 大纲
  1. dblink_exec(text connname, text sql [, bool fail_on_error]) returns text
  2. dblink_exec(text connstr, text sql [, bool fail_on_error]) returns text
  3. dblink_exec(text sql [, bool fail_on_error]) returns text
复制代码


  • 描述
dblink_exec在一个远程数据库中执行一个下令（也就是，任何不返回行的 SQL 语句）。
当给定两个text参数时，第一个被首先作为一个持久连接的名称进行查找；如果找到，该下令会在该连接上被执行。如果没有找到，第一个参数被视作一个用于dblink_connect的连接信息字符串，并且被指出的连接只是在这个下令的持续期间被创建。


  • 参数

    • connname
      要利用的连接名。忽略这个参数将利用未命名连接。
    • connstr
      如之前为dblink_connect所描述的一个连接信息字符串。
    • sql
      你盼望在远程数据库中执行的 SQL 下令，例如insert into foo values(0, ‘a’, ‘{“a0”,“b0”,“c0”}’)。
    • fail_on_error
      如果为真（忽略时的默认值），那么在连接的远端抛出的一个错误也会导致当地抛出一个错误。如果为假，远程错误只在当地被报告为一个 NOTICE，并且该函数的返回值被设置为ERROR。

  • 返回值
    返回状态，大概是下令的状态字符串或ERROR。
  • 例子
  1. SELECT dblink_connect('dbname=dblink_test_standby');
  2. dblink_connect
  3. ----------------
  4. OK
  5. (1 row)
  7. SELECT dblink_exec('insert into foo values(21, ''z'', ''{"a0","b0","c0"}'');');
  8.    dblink_exec
  9. -----------------
  10. INSERT 943366 1
  11. (1 row)
  13. SELECT dblink_connect('myconn', 'dbname=regression');
  14. dblink_connect
  15. ----------------
  16. OK
  17. (1 row)
  19. SELECT dblink_exec('myconn', 'insert into foo values(21, ''z'', ''{"a0","b0","c0"}'');');
  20.    dblink_exec
  21. ------------------
  22. INSERT 6432584 1
  23. (1 row)
  25. SELECT dblink_exec('myconn', 'insert into pg_class values (''foo'')',false);
  26. NOTICE:  sql error
  27. DETAIL:  ERROR:  null value in column "relnamespace" violates not-null constraint
  29. dblink_exec
  30. -------------
  31. ERROR
  32. (1 row)
复制代码
3.6、dblink_open 在一个远程数据库中打开一个游标

dblink_open 在一个远程数据库中打开一个游标


  • 大纲
  1. dblink_open(text cursorname, text sql [, bool fail_on_error]) 返回 text
  2. dblink_open(text connname, text cursorname, text sql [, bool fail_on_error]) 返回 text
复制代码


  • 描述
    dblink_open()在一个远程数据库中打开一个游标。该游标可以或许随后利用dblink_fetch()和dblink_close()进行操纵。
  • 参数

    • connname
      要利用的连接名。忽略这个参数将利用未命名连接。
    • cursorname
      要赋予给这个游标的名称。
    • sql
      你盼望在远程数据库中执行的SELECT语句，例如select * from pg_class。
    • fail_on_error
      如果为真（忽略时的默认值），那么在连接的远端抛出的一个错误也会导致当地抛出一个错误。如果为假，远程错误只在当地被报告为一个 NOTICE，并且该函数的返回值被设置为ERROR。

  • 返回值
    返回状态，OK或者ERROR。
3.7、dblink_fetch 从一个远程数据库中的打开的游标返回行

dblink_fetch 从一个远程数据库中的打开的游标返回行


  • 大纲
  1. dblink_fetch(text cursorname, int howmany [, bool fail_on_error]) 返回 record 集合
  2. dblink_fetch(text connname, text cursorname, int howmany [, bool fail_on_error]) 返回 record 集合
复制代码


  • 描述
    dblink_fetch从一个之前由dblink_open创建的游标中取得行。
  • 参数

    • connname
      要利用的连接名。忽略这个参数将利用未命名连接。
    • cursorname
      要从中取数据的游标名。
    • howmany
      要检索的最大行数。从当前游标位置向前的接下来howmany个行会被取出。一旦该游标已经到达了它的末了，将不会产生更多行。
    • fail_on_error
      如果为真（忽略时的默认值），那么在连接的远端抛出的一个错误也会导致当地抛出一个错误。如果为假，远程错误只在当地被报告为一个 NOTICE，并且该函数不反回行。

  • 返回值
    该函数返回从游标中取出的行。要利用这个函数，你将需要指定想要的列集合，如前面dblink中所讨论的。
3.8、dblink_close 关闭一个远程数据库中的游标

dblink_close 关闭一个远程数据库中的游标


  • 大纲
  1. dblink_close(text cursorname [, bool fail_on_error]) 返回 text
  2. dblink_close(text connname, text cursorname [, bool fail_on_error]) 返回 text
复制代码


  • 描述
    dblink_close关闭一个之前由dblink_open打开的游标。
  • 参数

    • connname
      要利用的连接名。忽略这个参数将利用未命名连接。
    • cursorname
      要关闭的游标名。
    • fail_on_error
      如果为真（忽略时的默认值），那么在连接的远端抛出的一个错误也会导致当地抛出一个错误。如果为假，远程错误只在当地被报告为一个 NOTICE，并且该函数的返回值被设置为ERROR。

  • 返回值
    返回状态，OK或者ERROR。
  • 注解
    如果dblink_open开始了一个显式事件块，并且这是这个连接中最后一个保持打开的游标，dblink_close将发出匹配的COMMIT。
  • 例子
  1. SELECT dblink_connect('dbname=postgres options=-csearch_path=');
  2. dblink_connect
  3. ----------------
  4. OK
  5. (1 row)
  7. SELECT dblink_open('foo', 'select proname, prosrc from pg_proc');
  8. dblink_open
  9. -------------
  10. OK
  11. (1 row)
  13. SELECT dblink_close('foo');
  14. dblink_close
  15. --------------
  16. OK
  17. (1 row)
复制代码
3.9、dblink_get_connections 返回所有打开的命名 dblink 连接的名称

dblink_get_connections 返回所有打开的命名 dblink 连接的名称


  • 大纲
  1. dblink_get_connections() 返回 text[]
复制代码


  • 描述
    dblink_get_connections返回一个数组，其中是所有打开的命名dblink连接的名称。
  • 返回值
    返回一个连接名称的文本数组，如果没有则为 NULL。
  • 例子
  1. SELECT dblink_get_connections();
复制代码
3.10、dblink_error_message 得到在命名连接上的最后一个错误消息

dblink_error_message 得到在命名连接上的最后一个错误消息


  • 大纲
  1. dblink_error_message(text connname) 返回 text
复制代码


  • 描述
    dblink_error_message为一个给定连接取得最近的远程错误消息。
  • 参数

    • connname
      要利用的连接名。

  • 返回值
    返回最后一个错误消息，如果在这个连接上没有错误则返回一个OK。
  • 注释
    当异步查询由dblink_send_query启动时， 与连接相关的错误消息大概不会得到更新，直到服务器的相应消息被用掉。 这通常意味着dblink_is_busy或dblink_get_result应在dblink_error_message之前被调用，以使得异步查询产生的任何错误都是可见的。
例子
  1. SELECT dblink_error_message('dtest1');
复制代码
3.11、dblink_send_query 发送一个异步查询到远程数据库

dblink_send_query 发送一个异步查询到远程数据库


  • 大纲
  1. dblink_send_query(text connname, text sql) 返回 int
复制代码


  • 描述
dblink_send_query发送一个要被异步执行的查询，也就是不需要立刻等候结果。在该连接上不能有还在处理中的异步查询。
在成功地派送一个异步查询后，可以用dblink_is_busy查抄完成状态，并且结果最终由dblink_get_result收集。也可以利用dblink_cancel_query尝试取消一个活动中的异步查询。


  • 参数

    • connname
      要利用的连接名。
    • sql
      你盼望在远程数据库中执行的 SQL 语句，例如select * from pg_class。

  • 返回值
    如果查询被成功地派送返回 1，否则返回 0。
例子
  1. SELECT dblink_send_query('dtest1', 'SELECT * FROM foo WHERE f1 < 3');
复制代码
3.12、dblink_is_busy 查抄连接是否正在忙于一个异步查询

dblink_is_busy 查抄连接是否正在忙于一个异步查询


  • 大纲
  1. dblink_is_busy(text connname) 返回 int
复制代码


  • 描述
    dblink_is_busy测试是否一个异步查询正在进行中。
  • 参数

    • connname
      要查抄的连接名。

  • 返回值
    如果连接正忙则返回 1，如果不忙则返回 0。如果这个函数返回 0，dblink_get_result将被保证不会阻塞。
例子
  1. SELECT dblink_is_busy('dtest1');
复制代码
3.13、dblink_get_notify 在一个连接上检索异步通知

dblink_get_notify 在一个连接上检索异步通知
大纲
  1. dblink_get_notify() 返回 (notify_name text, be_pid int, extra text) 集合
  2. dblink_get_notify(text connname) 返回 (notify_name text, be_pid int, extra text) 集合
复制代码
描述


  • dblink_get_notify在一个未命名连接或者一个指定的命名连接上检索通知。要通过 dblink 接收通知，首先必须利用dblink_exec发出LISTEN。详见LISTEN和NOTIFY。
参数


  • connname
    要在其上得到通知的命名连接的名称。
返回值


  • 返回 (notify_name text, be_pid int, extra text) 集合，或者一个空集。
例子
  1. SELECT dblink_exec('LISTEN virtual');
  2. dblink_exec
  3. -------------
  4. LISTEN
  5. (1 row)
  7. SELECT * FROM dblink_get_notify();
  8. notify_name | be_pid | extra
  9. -------------+--------+-------
  10. (0 rows)
  12. NOTIFY virtual;
  13. NOTIFY
  15. SELECT * FROM dblink_get_notify();
  16. notify_name | be_pid | extra
  17. -------------+--------+-------
  18. virtual     |   1229 |
  19. (1 row)
复制代码
3.14、dblink_get_result 得到一个异步查询结果

dblink_get_result 得到一个异步查询结果
大纲
  1. dblink_get_result(text connname [, bool fail_on_error]) 返回 record 集合
复制代码
描述


  • dblink_get_result收集之前dblink_send_query发送的一个异步查询的结果。如果该查询还没有完成，dblink_get_result将等候直到它完成。
参数


  • connname
    要利用的连接名。
  • fail_on_error
    如果为真（忽略时的默认值），那么在连接的远端抛出的一个错误也会导致当地抛出一个错误。如果为假，远程错误只在当地被报告为一个 NOTICE，并且该函数不返回行。
返回值


  • 对于一个异步查询（也就是一个返回行的 SQL 语句），该函数返回查询产生的行。要利用这个函数，你将需要指定所期待的列集合，如前面为dblink所讨论的那样。
  • 对于一个异步下令（也就是一个不返回行的 SQL 语句），该函数返回一个只有单个文本列的单行，其中包罗了该下令的状态字符串。仍必须在调用的FROM子句中指定结果将具有一个单一文本行。
注解


  • 如果dblink_send_query返回 1，这个函数就必须被调用。对每一个已发送的查询都必须调用一次这个函数，并且在连接再次可用之前还要多调用一次来得到一个空结果集。
  • 当利用dblink_send_query和dblink_get_result时，在将结果会合的任何一行返回给当地查询处理器之前，dblink将取得整个远程查询结果。如果该查询返回大量的行，这大概会导致当地会话中短暂的内存膨胀。最好将这样的一个查询用dblink_open打开成一个游标并且接着每次取得数量可管理的行。也可以利用简单的dblink()，它会避免缓冲大型结果集到磁盘上导致的内存膨胀。
例子
  1. contrib_regression=# SELECT dblink_connect('dtest1', 'dbname=contrib_regression');
  2. dblink_connect
  3. ----------------
  4. OK
  5. (1 row)
  7. contrib_regression=# SELECT * FROM
  8. contrib_regression-# dblink_send_query('dtest1', 'select * from foo where f1 < 3') AS t1;
  9. t1
  10. ----
  11.   1
  12. (1 row)
  14. contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]);
  15. f1 | f2 |     f3
  16. ----+----+------------
  17.   0 | a  | {a0,b0,c0}
  18.   1 | b  | {a1,b1,c1}
  19.   2 | c  | {a2,b2,c2}
  20. (3 rows)
  22. contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]);
  23. f1 | f2 | f3
  24. ----+----+----
  25. (0 rows)
  27. contrib_regression=# SELECT * FROM
  28. contrib_regression-# dblink_send_query('dtest1', 'select * from foo where f1 < 3; select * from foo where f1 > 6') AS t1;
  29. t1
  30. ----
  31.   1
  32. (1 row)
  34. contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]);
  35. f1 | f2 |     f3
  36. ----+----+------------
  37.   0 | a  | {a0,b0,c0}
  38.   1 | b  | {a1,b1,c1}
  39.   2 | c  | {a2,b2,c2}
  40. (3 rows)
  42. contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]);
  43. f1 | f2 |      f3
  44. ----+----+---------------
  45.   7 | h  | {a7,b7,c7}
  46.   8 | i  | {a8,b8,c8}
  47.   9 | j  | {a9,b9,c9}
  48. 10 | k  | {a10,b10,c10}
  49. (4 rows)
  51. contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]);
  52. f1 | f2 | f3
  53. ----+----+----
  54. (0 rows)
复制代码
3.15、dblink_cancel_query 在命名连接上取消任何活动查询

dblink_cancel_query 在命名连接上取消任何活动查询
大纲
  1. dblink_cancel_query(text connname) 返回 text
复制代码
描述


  • dblink_cancel_query尝试命名连接上正在进行的任何查询。注意这不一定会成功（例如，远程查询大概已经竣事）。一个取消哀求仅仅提高了该查询将很快失败的几率。你仍必须完成通常的查询协议，例如通过调用dblink_get_result。
参数


  • connname
    要利用的连接名。
返回值


  • 如果取消哀求已经被发送，则返回OK；如果失败，则返回一个错误消息的文本。
例子
  1. SELECT dblink_cancel_query('dtest1');
复制代码
3.16、dblink_get_pkey 返回一个关系的主键域的位置和域名称

dblink_get_pkey 返回一个关系的主键域的位置和域名称
大纲
  1. dblink_get_pkey(text relname) 返回 dblink_pkey_results 集合
复制代码
描述


  • dblink_get_pkey提供有关于当地数据库中一个关系的主键的信息。这有时间有助于天生要被发送到远程数据库的查询。
参数


  • relname
    一个当地关系的名称，例如foo或者myschema.mytab。如果该名称是巨细写混淆的或包罗特殊字符，要包括双引号，例如"FooBar"；如果没有引号，字符串将被折叠到小写情势。
返回值


  • 为每一个主键域返回一行，如果该关系没有主键则不返回行。结果行类型被定义为：
  1. CREATE TYPE dblink_pkey_results AS (position int, colname text);
复制代码


  • position列值可以从 1 到 N，它是该域在主键中的编号，而不是在表列中的编号。
例子
  1. CREATE TABLE foobar (
  2.     f1 int,
  3.     f2 int,
  4.     f3 int,
  5.     PRIMARY KEY (f1, f2, f3)
  6. );
  7. CREATE TABLE
  9. SELECT * FROM dblink_get_pkey('foobar');
  10. position | colname
  11. ----------+---------
  12.         1 | f1
  13.         2 | f2
  14.         3 | f3
  15. (3 rows)
复制代码
3.17、dblink_build_sql_insert 利用一个当地元组构建一个 INSERT 语句，将主键域值更换为提供的值

dblink_build_sql_insert 利用一个当地元组构建一个 INSERT 语句，将主键域值更换为提供的值
大纲
  1. dblink_build_sql_insert(text relname,
  2.                         int2vector primary_key_attnums,
  3.                         integer num_primary_key_atts,
  4.                         text[] src_pk_att_vals_array,
  5.                         text[] tgt_pk_att_vals_array) 返回 text
复制代码
描述


  • dblink_build_sql_insert在选择性地将一个当地表复制到一个远程数据库时很有用。它基于主键从当地表选择一行，并且接着构建一个复制该行的INSERT下令，但是其中主键值被更换为最后一个参数中的值（要创建该行的一个准确拷贝，只要为最后两个参数指定雷同的值）。
参数


  • relname
    一个当地关系的名称，例如foo或者myschema.mytab。如果该名称是巨细写混淆的或包罗特殊字符，要包括双引号，例如"FooBar"；如果没有引号，字符串将被折叠到小写情势。
  • primary_key_attnums
    主键域的属性号（从 1 开始），例如1 2。
  • num_primary_key_atts
    主键域的数量。
  • src_pk_att_vals_array
    要被用来查找当地元组的主键域值。每一个域都被表示为文本情势。如果没有行具有这些主键值，则抛出一个错误。
  • tgt_pk_att_vals_array
    要被更换到结果INSERT下令中的主键域值。每一个域被表示为文本情势。
返回值


  • 将要求的 SQL 语句返回为文本。
注解


  • 自PostgreSQL 9.0 开始，primary_key_attnums中的属性号被表明为逻辑列号，对应于列在SELECT * FROM relname中的位置。之前的版本将属性号表明为物理列位置。如果指示出的列的左边有恣意列在该表的生存期内被删除，这两种表明就有区别。
例子
  1. SELECT dblink_build_sql_insert('foo', '1 2', 2, '{"1", "a"}', '{"1", "b''a"}');
  2.              dblink_build_sql_insert
  3. --------------------------------------------------
  4. INSERT INTO foo(f1,f2,f3) VALUES('1','b''a','1')
  5. (1 row)
复制代码
3.18、dblink_build_sql_delete 利用所提供的主键域值构建一个 DELETE 语句

dblink_build_sql_delete 利用所提供的主键域值构建一个 DELETE 语句
大纲
  1. dblink_build_sql_delete(text relname,
  2.                         int2vector primary_key_attnums,
  3.                         integer num_primary_key_atts,
  4.                         text[] tgt_pk_att_vals_array) 返回 text
复制代码
描述


  • dblink_build_sql_delete在选择性地将一个当地表复制到一个远程数据库时很有用。它构建一个 SQL DELETE下令用来删除具有给定主键值的行。
参数


  • relname
    一个当地关系的名称，例如foo或者myschema.mytab。如果该名称是巨细写混淆的或包罗特殊字符，要包括双引号，例如"FooBar"；如果没有引号，字符串将被折叠到小写情势。
  • primary_key_attnums
    主键域的属性号（从 1 开始），例如1 2。
  • num_primary_key_atts
    主键域的数量。
  • tgt_pk_att_vals_array
    要用在结果DELETE下令中的主键域值。每一个域都被表示为文本情势。
返回值


  • 将要求的 SQL 语句返回为文本。
注解


  • 自PostgreSQL 9.0 开始，primary_key_attnums中的属性号被表明为逻辑列号，对应于列在SELECT * FROM relname中的位置。之前的版本将属性号表明为物理列位置。如果指示出的列的左边有恣意列在该表的生存期内被删除，这两种表明就有区别。
例子
  1. SELECT dblink_build_sql_delete('"MyFoo"', '1 2', 2, '{"1", "b"}');
  2.            dblink_build_sql_delete
  3. ---------------------------------------------
  4. DELETE FROM "MyFoo" WHERE f1='1' AND f2='b'
  5. (1 row)
复制代码
3.19、dblink_build_sql_update 利用一个当地元组构建一个 UPDATE 语句，将主键域值更换为提供的值

dblink_build_sql_update 利用一个当地元组构建一个 UPDATE 语句，将主键域值更换为提供的值
大纲
  1. dblink_build_sql_update(text relname,
  2.                         int2vector primary_key_attnums,
  3.                         integer num_primary_key_atts,
  4.                         text[] src_pk_att_vals_array,
  5.                         text[] tgt_pk_att_vals_array) 返回 text
复制代码
描述


  • dblink_build_sql_update在选择性地将一个当地表复制到一个远程数据库时很有用。它从当地表基于主键选择一行，并且接着构建一个 SQL UPDATE下令来复制该行，但是其中的主键值被更换为最后一个参数中的值（要创建该行的一个准确拷贝，只要为最后两个参数指定雷同的值）。UPDATE下令总是为该行的所有域赋值 这个函数与dblink_build_sql_insert之间的主要区别是它假定目标行已经存在于远程表中。
参数


  • relname
    一个当地关系的名称，例如foo或者myschema.mytab。如果该名称是巨细写混淆的或包罗特殊字符，要包括双引号，例如"FooBar"；如果没有引号，字符串将被折叠到小写情势。
  • primary_key_attnums
    主键域的属性号（从 1 开始），例如1 2。
  • num_primary_key_atts
    主键域的数量。
  • src_pk_att_vals_array
    要被用来查找当地元组的主键域值。每一个域都被表示为文本情势。如果没有行具有这些主键值，则抛出一个错误。
  • tgt_pk_att_vals_array
    要用在结果UPDATE下令中的主键域值。每一个域都被表示为文本情势。
返回值


  • 将要求的 SQL 语句返回为文本。
注解


  • 自PostgreSQL 9.0 开始，primary_key_attnums中的属性号被表明为逻辑列号，对应于列在SELECT * FROM relname中的位置。之前的版本将属性号表明为物理列位置。如果指示出的列的左边有恣意列在该表的生存期内被删除，这两种表明就有区别。
例子
  1. SELECT dblink_build_sql_update('foo', '1 2', 2, '{"1", "a"}', '{"1", "b"}');
  2.                    dblink_build_sql_update
  3. -------------------------------------------------------------
  4. UPDATE foo SET f1='1',f2='b',f3='1' WHERE f1='1' AND f2='b'
  5. (1 row)
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

西河刘卡车医

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表