dblink_get_result · PostgreSQL 中文文檔 9.3

# dblink_get_result ## Name dblink_get_result?--?獲得異步查詢結果 ## Synopsis ``` dblink_get_result(text connname [, bool fail_on_error]) returns setof record ``` ## 描述 `dblink_get_result`收集先前使用`dblink_send_query`發送的異步查詢結果。如果還沒完成查詢，那么`dblink_get_result`將等待它。 ## 參數 `conname` 要使用的連接名字。 `fail_on_error` 如果真（忽略時缺省）那么在連接的遠程端拋出的錯誤也會導致本地拋出錯誤，如果假，那么遠程錯誤在本地作為NOTICE被報告，并且函數沒有返回行。 ## 返回值一個異步查詢（也就是說，返回行的SQL語句），該函數返回通過查詢產生的行。要使用該函數，你將需要指定預期的字段集，正如前面討論的`dblink`。一個異步命令（也就是說，沒有返回行的SQL語句），該函數返回帶有該命令的狀態字符串的單文本列的單一行。聲明結果將在調用`FROM`子句中有單一文本列。 ## 注意如果`dblink_send_query`返回1，那么_必須_調用該函數。它必須被每一個查詢調用，并且一個額外時間來獲取空集結果，連接之前可以再次使用。當在返回它到本地查詢處理器之前使用`dblink_send_query`和 `dblink_get_result`, dblink抓取整個遠程查詢結果。如果查詢返回大量行，那么這可以導致本地會話短暫內存膨脹。它可以更好的打開這個查詢比如使用`dblink_open`的游標，然后抓取每次可管理的行數。另外，使用普通的`dblink()`通過多任務緩沖處理大量結果集到磁盤避免內存膨脹。 ## 例子 ``` contrib_regression=# SELECT dblink_connect('dtest1', 'dbname=contrib_regression'); dblink_connect ---------------- OK (1 row) contrib_regression=# SELECT * FROM contrib_regression-# dblink_send_query('dtest1', 'select * from foo where f1 < 3') AS t1; t1 ---- 1 (1 row) contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]); f1 | f2 | f3 ----+----+------------ 0 | a | {a0,b0,c0} 1 | b | {a1,b1,c1} 2 | c | {a2,b2,c2} (3 rows) contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]); f1 | f2 | f3 ----+----+---- (0 rows) contrib_regression=# SELECT * FROM contrib_regression-# dblink_send_query('dtest1', 'select * from foo where f1 < 3; select * from foo where f1 > 6') AS t1; t1 ---- 1 (1 row) contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]); f1 | f2 | f3 ----+----+------------ 0 | a | {a0,b0,c0} 1 | b | {a1,b1,c1} 2 | c | {a2,b2,c2} (3 rows) contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]); f1 | f2 | f3 ----+----+--------------- 7 | h | {a7,b7,c7} 8 | i | {a8,b8,c8} 9 | j | {a9,b9,c9} 10 | k | {a10,b10,c10} (4 rows) contrib_regression=# SELECT * FROM dblink_get_result('dtest1') AS t1(f1 int, f2 text, f3 text[]); f1 | f2 | f3 ----+----+---- (0 rows) ```