Postgres Async API Erkennung Ende der Abfrage

Question

Ich arbeite mit der PostgreSQL C API. Beim Lesen der documentation wird angegeben, dass eine Abfrage beendet ist, wenn PQgetResult NULL zurückgibt und PQgetResult blockiert, wenn PQisBusy nicht 0 zurückgibt. PQisBusy gibt jedoch 1 zurück, wenn keine Eingabe mehr vorhanden ist. Daher kann ich PQgetResult nicht aufrufen und NULL abrufen. Daher kann ich nicht wissen, ob die Abfrage beendet ist. Gibt es eine andere Möglichkeit zu wissen, ob die Abfrage abgeschlossen ist? Habe ich die async API falsch verstanden?

---- ----- edit

Die Grundidee, wie C-Code ist:

PQsendQuery(conn, query) 

while(true) 
{ 
    PQconsumeInput(conn) 
    if(PQisBusy(conn) == 0) 
    { 
     PGresult* res = PQgetResult(conn); 
     if(res) 
     { 
      //print result 
     } 
     else 
     { 
      //res == NULL 
      //indicates query is over 
      break; 
     } 
    } 
} 

Das Ergebnis gedruckt werden, aber die Schleife endet nie. Weil PQisBusy nur einmal 0 zurückgibt.

Answer 1

Ich kann ein Problem mit dem Code sehen, Sie überprüfen nicht Rückkehr der PQconsumeInput (conn) -Funktion. Es liegt in der Verantwortung von PQconsumeInput, die Besetztflagge zu löschen. Was passieren könnte, ist, dass PQconsumeInput fehlschlägt, ohne Daten zu verarbeiten und das Flag "Besetzt" zu löschen.

Ich denke, das Ergebnis von PQconsumeInput vor dem Aufruf von PQisBusy überprüfen sollte gut funktionieren.

while (PQconsumeInput(conn) == 1) 
{ 
    if(PQisBusy(conn) == 0) 
    { 
     PGresult* res = PQgetResult(conn); 
     if(res) 
     { 
      //print result 
     } 
     else 
     { 
      //res == NULL 
      //indicates query is over 
      break; 
     } 
    } 
} 

Answer 2

Nach dem, was ich über den Link in meinem Kommentar zu verstehen, würde ich so etwas wie dies (die Parameter select() und die anderen Funktionsaufrufe können ganz unterschiedlich sein) versuchen:

if (select(sock 1, &input_mask, NULL, NULL, NULL) < 0) { 

    fprintf(stderr, "select() failed: %s\n", strerror(errno)); 
    exit_nicely(conn); 
} 

PQconsumeInput(conn); 

while (PQisBusy(conn) != 0) { 

    /* wait here */ 

} 

while (PGresult* res = PQgetResult(conn)) { /* not sure this is OK, test for not null */ 

    /* do something with res */ 

} 

Answer 3

Ich denke, Was Sie brauchen, ist PQsetSingleRowMode zu lassen PQgetResult eine Zeile jedes Mal zurückgeben.

von http://www.postgresql.org/docs/9.2/static/libpq-single-row-mode.html

Normalerweise sammelt libpq ein Gesamtergebnis des SQL-Befehl und gibt es auf die Anwendung als eine einzige PGresult. Dies kann für Befehle nicht funktionieren, die eine große Anzahl von Zeilen zurückgeben. In solchen Fällen können Anwendungen PQsendQuery und PQgetResult im Einzelzeilenmodus verwenden. In diesem Modus werden die Ergebniszeilen einmal an die Anwendung zurückgegeben, und zwar einmal um , da sie vom Server empfangen werden.

Wenn die Abfrage keine Zeilen zurückgibt, werden sie als einzelne PGresult Objekte zurückgegeben, die mit Ausnahme wie normale Abfrage-Ergebnisse aussehen Statuscode PGRES_SINGLE_TUPLE statt PGRES_TUPLES_OK haben. Nach der letzten Zeile oder sofort, wenn die Abfrage null Zeilen zurückgibt, wird ein Nullzeilenobjekt mit dem Status PGRES_TUPLES_OK zurückgegeben; Dies ist das Signal, dass keine Zeilen mehr ankommen werden.

Scheck aus dem Beispielcode: https://github.com/markokr/libpq-rowproc-demos/blob/master/demo-onerow-async.c