Non-blocking queries using libpq
От | Ewan Mellor |
---|---|
Тема | Non-blocking queries using libpq |
Дата | |
Msg-id | 35AC7414.12D680B@nexus.co.uk обсуждение исходный текст |
Список | pgsql-interfaces |
I am having trouble using libpq to query my database in a non-blocking manner. My test program looks like this: #include <stdio.h> #include <libpq-fe.h> main() { PGconn *conn; PGresult *res; conn = PQsetdb(NULL, NULL, NULL, NULL, "test"); PQsendQuery(conn, "select * from test_tbl"); while(PQisBusy(conn)) ; res = PQgetResult(conn); printf("%s.\n", PQgetvalue(res, 0, 0)); PQclear(res); PQfinish(conn); return 0; } First off, is this OK? (Of course, my real program does things whilst PQisBusy() and checks for errors etc.) My problem is that PQisBusy() is never returning FALSE because conn->asyncStatus is always PGASYNC_BUSY. PQisBusy() looks like this: int PQisBusy(PGconn *conn) { if (!conn) return FALSE; /* Parse any available data, if our state permits. */ parseInput(conn); /* PQgetResult will return immediately in all states except BUSY. */ return (conn->asyncStatus == PGASYNC_BUSY); } It seems to me that the call to parseInput() will never do anything because there is no way that data will be read from the backend. Is that correct? Is the user application supposed to do that? I am using a snapshot dated a month or two ago. Thanks in advance, Ewan Mellor.
В списке pgsql-interfaces по дате отправления: