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 по дате отправления:

Предыдущее
От: Herouth Maoz
Дата:
Сообщение: RE: [INTERFACES] What technology ???
Следующее
От: Herouth Maoz
Дата:
Сообщение: Re: [INTERFACES] libpq & user