Fixed up postgres client + query.run

lib/dialects/postgres/connector-manager.js

@@ -37,12 +37,12 @@ module.exports = (function() {
     self.pendingQueries += 1
     self.pendingQueries += 1
 
 
     return new Utils.CustomEventEmitter(function(emitter) {
     return new Utils.CustomEventEmitter(function(emitter) {
-      self.connect(function(err) {
+      self.connect(function(err, client) {
         if (!!err) {
         if (!!err) {
           return emitter.emit('error', err)
           return emitter.emit('error', err)
         }
         }
 
 
-        var query = new Query(self.client, self.sequelize, callee, options || {})
+        var query = new Query(client, self.sequelize, callee, options || {})
 
 
         return query.run(sql)
         return query.run(sql)
           .success(function() { self.endQuery.call(self) })
           .success(function() { self.endQuery.call(self) })
@@ -64,7 +64,6 @@ module.exports = (function() {
 
 
   ConnectorManager.prototype.connect = function(callback) {
   ConnectorManager.prototype.connect = function(callback) {
     var self = this
     var self = this
-    var emitter = new (require('events').EventEmitter)()
 
 
     // in case database is slow to connect, prevent orphaning the client
     // in case database is slow to connect, prevent orphaning the client
     if (this.isConnecting) {
     if (this.isConnecting) {
@@ -96,7 +95,7 @@ module.exports = (function() {
         client.query("SET TIME ZONE 'UTC'").on('end', function() {
         client.query("SET TIME ZONE 'UTC'").on('end', function() {
           self.isConnected = true
           self.isConnected = true
           self.client = client
           self.client = client
-          callback(null)
+          callback(null, client)
         });
         });
       } else {
       } else {
         self.client = null
         self.client = null
@@ -116,8 +115,6 @@ module.exports = (function() {
         connectCallback(null, this.client)
         connectCallback(null, this.client)
       }
       }
     }
     }
-
-    return emitter
   }
   }
 
 
   ConnectorManager.prototype.disconnect = function() {
   ConnectorManager.prototype.disconnect = function() {