diff --git a/lib/client.js b/lib/client.js index 01ec505..c5ae429 100644 --- a/lib/client.js +++ b/lib/client.js @@ -163,7 +163,7 @@ Client.prototype.connect = function(callback) { con.once('end', function() { if(self.activeQuery) { - var disconnectError = new Error('Stream unexpectedly ended during query execution') + var disconnectError = new Error('Stream unexpectedly ended during query execution'); self.activeQuery.handleError(disconnectError); self.activeQuery = null; } diff --git a/lib/query.js b/lib/query.js index ee86022..efde2b5 100644 --- a/lib/query.js +++ b/lib/query.js @@ -72,7 +72,7 @@ Query.prototype.handleCommandComplete = function(msg, con) { this._result.addCommandComplete(msg); //need to sync after each command complete of a prepared statement if(this.isPreparedStatement) { - con.sync() + con.sync(); } };