Transaction status is handled by readyForQuery message. Please, share!

langpavel · langpavel · commit 9311e2c4582e · 2017-11-24T17:13:40.000+01:00
readyForQuery can receive one of this state:

/*
 * getReadyForQuery - process ReadyForQuery message
 */
static int
getReadyForQuery(PGconn *conn)
{
    charxact_status;

    if (pqGetc(&amp;xact_status, conn)              )
        return EOF;
    switch (xact_status)
    {
        case 'I':
            conn-&gt;xactStatus = PQTRANS_IDLE;
            break;
        case 'T':
            conn-&gt;xactStatus = PQTRANS_INTRANS;
            break;
        case 'E':
            conn-&gt;xactStatus = PQTRANS_INERROR;
            break;
        default:
            conn-&gt;xactStatus = PQTRANS_UNKNOWN;
            break;
    }

    return 0;
}
diff --git a/lib/client.js b/lib/client.js
@@ -138,7 +138,8 @@ Client.prototype.connect = function (callback) {
 
   // hook up query handling events to connection
   // after the connection initially becomes ready for queries
-  con.once('readyForQuery', function () {
+  con.once('readyForQuery', function (msg) {
+    self._transactionStatus = msg.status
     self._connecting = false
     self._connected = true
     self._attachListeners(con)
@@ -155,8 +156,9 @@ Client.prototype.connect = function (callback) {
     self.emit('connect')
   })
 
-  con.on('readyForQuery', function () {
+  con.on('readyForQuery', function (msg) {
     var activeQuery = self.activeQuery
+    self._transactionStatus = msg.status
     self.activeQuery = null
     self.readyForQuery = true
     if (activeQuery) {
