diff --git a/lib/native.js b/lib/native.js
index 86e35001..ef3b4609 100644
--- a/lib/native.js
+++ b/lib/native.js
@@ -25,7 +25,7 @@ p.query = function(config, values, callback) {
   return q;
 }
 
-p._pulseQueryQueue = function() {
+p._pulseQueryQueue = function(initialConnection) {
   if(!this._connected) {
     return;
   }
@@ -34,7 +34,9 @@ p._pulseQueryQueue = function() {
   }
   var query = this._queryQueue.shift();
   if(!query) {
-    this.emit('drain');
+    if(!initialConnection) {
+      this.emit('drain');
+    }
     return;
   }
   this._activeQuery = query;
@@ -65,7 +67,7 @@ var ctor = function(config) {
   connection._config = utils.normalizeConnectionInfo(config);
   connection.on('connect', function() {
     connection._connected = true;
-    connection._pulseQueryQueue();
+    connection._pulseQueryQueue(true);
   });
 
   //proxy some events to active query