Query should return an error if there is no connection anymore

Author: Florian Gambert

lib/client.js

@@ -126,6 +126,12 @@ Client.prototype.connect = function (callback) {
   }
 
   const connectedErrorHandler = (err) => {
+    if (err.severity === 'FATAL') {
+      con.conTerminated = true
+      this.queryQueue.forEach(query => {
+        query.handleError(err, con)
+      })
+    }
     if (this.activeQuery) {
       var activeQuery = self.activeQuery
       this.activeQuery = null
@@ -166,6 +172,7 @@ Client.prototype.connect = function (callback) {
   })
 
   con.once('end', () => {
+    con.conTerminated = true
     if (this.activeQuery) {
       var disconnectError = new Error('Connection terminated')
       this.activeQuery.handleError(disconnectError, con)
@@ -382,6 +389,10 @@ Client.prototype.query = function (config, values, callback) {
     }
   }
 
+  if (this.connection.conTerminated) {
+    return query.callback(new Error('Client has lost its connection. You cannot execute query on it.'))
+  }
+
   if (this.binary && !query.binary) {
     query.binary = true
   }