Postgres Async API che rileva la fine della query

Question

Sto lavorando con l'API C PostgreSQL. Leggendo il documentation si dice che una query è finita quando PQgetResult restituisce NULL e PQgetResult si bloccherà se PQisBusy non restituisce 0. Tuttavia PQisBusy restituisce 1 se non c'è più input, quindi non posso chiamare PQgetResult e ottenere il NULL. Pertanto non posso sapere se la query è finita. C'è un altro modo per sapere se la query è stata eseguita? Ho frainteso l'API asincrona?

---- ----- modificare

L'idea di base come codice C è:

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; 
     } 
    } 
} 

Il risultato verrà stampato, ma il ciclo non termina. Perché PQisBusy restituisce 0 solo una volta.

Answer 1

È possibile visualizzare un problema con il codice. Non si sta verificando il ritorno della funzione PQconsumeInput (conn). Poiché è responsabilità di PQconsumeInput eliminare la bandiera occupata. Quello che potrebbe accadere è che PQconsumeInput fallirebbe senza elaborare alcun dato e cancellare la bandiera di occupato.

Penso che controllare il risultato di PQconsumeInput prima di chiamare PQisBusy dovrebbe funzionare correttamente.

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

In base a quello che ho capito dal link nel mio commento, vorrei provare qualcosa di simile (i parametri da select() e le altre chiamate di funzione può essere molto diverso):

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

penso quello che ti serve è PQsetSingleRowMode lasciare che PQgetResult restituisca una riga ogni volta.

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

Ordinariamente, libpq raccoglie intero risultato di un comando SQL e restituisce alla domanda di come un singolo PGresult. Questo può non essere possibile per i comandi che restituiscono un numero elevato di righe. Per tali casi, le applicazioni possono utilizzare PQsendQuery e PQgetResult in modalità a riga singola. In questa modalità, le righe dei risultati vengono restituite all'applicazione uno a in un momento, poiché vengono ricevute dal server.

Se la query restituisce tutte le righe, sono restituiti come singoli oggetti PGresult, che sembrano normali risultati delle query tranne avere il codice di stato PGRES_SINGLE_TUPLE invece di PGRES_TUPLES_OK. Dopo l'ultima riga, o immediatamente se la query restituisce zero righe, viene restituito un oggetto a riga zero con stato PGRES_TUPLES_OK; questo è il segnale che non arriveranno più righe.

check out il codice di esempio: https://github.com/markokr/libpq-rowproc-demos/blob/master/demo-onerow-async.c