Lines Matching refs:pg
22 PGconn *pg;
132 PQfinish(db->pg);
133 db->pg = NULL;
151 msg = PQerrorMessage(db->pg);
168 while ((ret = PQconnectPoll(db->pg)) == PGRES_POLLING_ACTIVE)
184 pgsql_prefix(db), PQdb(db->pg), last_error(db), db->connect_state);
190 db->io = io_add(PQsocket(db->pg), io_dir, connect_callback, db);
226 db->pg = PQconnectStart(db->connect_string);
227 if (db->pg == NULL) {
232 if (PQstatus(db->pg) == CONNECTION_BAD) {
234 pgsql_prefix(db), PQdb(db->pg), last_error(db));
249 if (PQsetnonblocking(db->pg, 1) < 0)
255 db->io = io_add(PQsocket(db->pg), IO_WRITE, connect_callback, db);
322 while (PQconsumeInput(db->pg) != 0) {
323 if (PQisBusy(db->pg) != 0) {
324 db->io = io_add(PQsocket(db->pg), IO_READ,
330 pgres = PQgetResult(db->pg);
336 if (PQstatus(db->pg) == CONNECTION_BAD)
394 if (PQstatus(db->pg) == CONNECTION_BAD || result->pgres == NULL ||
424 if (PQconsumeInput(db->pg) == 0) {
429 if (PQisBusy(db->pg) != 0) {
430 db->io = io_add(PQsocket(db->pg), IO_READ,
436 result->pgres = PQgetResult(db->pg);
447 ret = PQflush(db->pg);
449 db->io = io_add(PQsocket(db->pg), IO_WRITE,
488 if (PQsendQuery(db->pg, query) == 0 ||
489 (ret = PQflush(db->pg)) < 0) {
497 db->io = io_add(PQsocket(db->pg), IO_WRITE,
521 len = PQescapeStringConn(db->pg, to, string, len, &error);
596 db->io = io_add(PQsocket(db->pg), db->io_dir, connect_callback, db);
670 result->pgres = PQgetResult(db->pg);