query errors passed to a query callback function are considered handled

lib/query.js

@@ -74,8 +74,9 @@ p.submit = function(connection) {
     if(self.callback) {
       self.callback(err);
       connection.removeListener('commandComplete', onCommandComplete);
-    }
+    } else {
       self.emit('error', err);
+    }
     self.emit('end');
   };