diff options
| author | Robert Haas | 2016-09-23 21:34:03 +0000 |
|---|---|---|
| committer | Robert Haas | 2016-09-23 21:36:25 +0000 |
| commit | 51ca0665e81a92b72b398b5ac1182c1231129ef4 (patch) | |
| tree | 191be101a559ea50b1d95a8eacc54f1888aa7473 /contrib/postgres_fdw/postgres_fdw.h | |
| parent | f07555cd8ebca78dec856c73a9518dfbbbdc631f (diff) | |
beginnings of true async attempt, but doesn't workasync2
ERROR: another command is already in progress
CONTEXT: Remote SQL command: DECLARE c2 CURSOR FOR
SELECT a, b FROM t.foo2
STATEMENT: select * from foo;
and if we got past that we can't configure a wait
and there are various other problems
Diffstat (limited to 'contrib/postgres_fdw/postgres_fdw.h')
| -rw-r--r-- | contrib/postgres_fdw/postgres_fdw.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/contrib/postgres_fdw/postgres_fdw.h b/contrib/postgres_fdw/postgres_fdw.h index 67126bc421..9c193ff86b 100644 --- a/contrib/postgres_fdw/postgres_fdw.h +++ b/contrib/postgres_fdw/postgres_fdw.h @@ -20,6 +20,9 @@ #include "libpq-fe.h" +struct PgFdwAsyncQuery; +typedef struct PgFdwAsyncQuery PgFdwAsyncQuery; + /* * FDW-specific planner information kept in RelOptInfo.fdw_private for a * foreign table. This information is collected by postgresGetForeignRelSize. @@ -107,6 +110,8 @@ extern PGresult *pgfdw_get_result(PGconn *conn, const char *query); extern PGresult *pgfdw_exec_query(PGconn *conn, const char *query); extern void pgfdw_report_error(int elevel, PGresult *res, PGconn *conn, bool clear, const char *sql); +extern PgFdwAsyncQuery *pgfdw_begin_query(PGconn *conn, const char *query); +extern bool pgfdw_finish_query(PgFdwAsyncQuery *aq, PGresult **result); /* in option.c */ extern int ExtractConnectionOptions(List *defelems, |