dblink_fetch — 从远程数据库中的打开游标返回行
dblink_fetch(text cursorname, int howmany [, bool fail_on_error]) returns setof record dblink_fetch(text connname, text cursorname, int howmany [, bool fail_on_error]) returns setof record
dblink_fetch
会获取先前由 dblink_open
建立的游标的行。
connname
要使用的连接的名称;省略此参数会使用未命名的连接。
cursorname
要获取的游标的名称。
howmany
要检索的最大行数。将获取下一行howmany
行,它从当前光标位置开始,向前移动。一旦光标到达其末尾,将不再生成更多行。
fail_on_error
如果为 true(省略时为默认值),那么在连接的远程端抛出的错误也会导致本地抛出一个错误。如果为 false,则远程错误将被本地报告为 NOTICE,并且该函数不会返回任何行。
该函数返回从光标获取的行。要使用此函数,你需要指定期望的列集,如前面针对dblink
所讨论过的。
如果FROM
子句中指定的返回列数与远程光标返回的实际列数不匹配,则会抛出一个错误。在这种情况下,远程光标仍将推进与未发生错误时一样多的行。在远程FETCH
执行后,在本地查询中发生的任何其他错误也是如此。
SELECT dblink_connect('dbname=postgres options=-csearch_path='); dblink_connect ---------------- OK (1 row) SELECT dblink_open('foo', 'select proname, prosrc from pg_proc where proname like ''bytea%'''); dblink_open ------------- OK (1 row) SELECT * FROM dblink_fetch('foo', 5) AS (funcname name, source text); funcname | source ----------+---------- byteacat | byteacat byteacmp | byteacmp byteaeq | byteaeq byteage | byteage byteagt | byteagt (5 rows) SELECT * FROM dblink_fetch('foo', 5) AS (funcname name, source text); funcname | source -----------+----------- byteain | byteain byteale | byteale bytealike | bytealike bytealt | bytealt byteane | byteane (5 rows) SELECT * FROM dblink_fetch('foo', 5) AS (funcname name, source text); funcname | source ------------+------------ byteanlike | byteanlike byteaout | byteaout (2 rows) SELECT * FROM dblink_fetch('foo', 5) AS (funcname name, source text); funcname | source ----------+-------- (0 rows)