API Postgres Async phát hiện kết thúc truy vấn

Question

Tôi đang làm việc với API PostgreSQL C. Đọc các documentation nó nói rằng một truy vấn được hoàn thành khi PQgetResult trả về NULL và PQgetResult sẽ chặn nếu PQisBusy không trở về 0. Tuy nhiên PQisBusy trả về 1 nếu không có đầu vào nhiều hơn, vì vậy tôi không thể gọi PQgetResult và nhận được NULL. Vì vậy, tôi không thể biết nếu truy vấn kết thúc. Có cách nào khác để biết nếu truy vấn được thực hiện? Tôi có hiểu nhầm API async không?

---- chỉnh sửa -----

Ý tưởng cơ bản là mã C là:

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

Kết quả sẽ được in nhưng vòng lặp không bao giờ chấm dứt. Bởi vì PQisBusy chỉ trả về 0 một lần.

Answer 1

Tôi có thể thấy một vấn đề với mã, Bạn không kiểm tra trả về hàm PQconsumeInput (conn). Vì nó là trách nhiệm của PQconsumeInput để xóa bỏ lá cờ bận. Điều gì có thể xảy ra là PQconsumeInput sẽ thất bại mà không cần xử lý bất kỳ dữ liệu nào và xóa bỏ cờ bận.

Tôi nghĩ rằng việc kiểm tra kết quả của PQconsumeInput trước khi gọi PQisBusy sẽ hoạt động tốt.

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

Dựa trên những gì tôi hiểu từ các liên kết trong nhận xét của tôi, tôi sẽ cố gắng một cái gì đó như thế này (các thông số để select() và các cuộc gọi chức năng khác có thể khá khác nhau):

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

Tôi nghĩ những gì bạn cần là PQsetSingleRowMode để cho phép PQgetResult trả lại một hàng mỗi lần.

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

Thông thường, libpq thu thập toàn bộ kết quả một lệnh SQL và trả nó vào ứng dụng như một PGresult duy nhất. Điều này có thể không hoạt động đối với các lệnh trả về một số lượng lớn hàng. Đối với các trường hợp như vậy, các ứng dụng có thể sử dụng PQsendQuery và PQgetResult ở chế độ một hàng. Trong chế độ này, (các) hàng kết quả được trả về ứng dụng một tại một lần, khi chúng được nhận từ máy chủ.

Nếu truy vấn trả về bất kỳ hàng nào, chúng sẽ được trả về dưới dạng đối tượng PGresult riêng lẻ, trông giống như kết quả truy vấn bình thường ngoại trừ có mã trạng thái PGRES_SINGLE_TUPLE thay vì PGRES_TUPLES_OK. Sau hàng cuối cùng, hoặc ngay lập tức nếu truy vấn trả về 0 hàng, một đối tượng không có hàng với trạng thái PGRES_TUPLES_OK được trả về; đây là tín hiệu không còn hàng nào nữa.

kiểm tra ra các mẫu mã: https://github.com/markokr/libpq-rowproc-demos/blob/master/demo-onerow-async.c