pass sequelize instance to queries

lib/dialects/mysql/connector-manager.js

@@ -14,7 +14,9 @@ module.exports = (function() {
     this.activeQueue = []
     this.maxConcurrentQueries = (this.config.maxConcurrentQueries || 50)
     this.poolCfg = this.config.pool
+
     var self = this
+
     if (this.poolCfg) {
       //the user has requested pooling, so create our connection pool
       if (!this.poolCfg.maxConnections) {
@@ -32,6 +34,7 @@ module.exports = (function() {
         idleTimeoutMillis: self.poolCfg.maxIdleTime
       })
     }
+
     process.on('exit', function () {
       //be nice & close our connections on exit
       if (self.pool) {
@@ -43,16 +46,16 @@ module.exports = (function() {
       return
     })
   }
+
   Utils._.extend(ConnectorManager.prototype, require("../connector-manager").prototype)
 
   var isConnecting = false
 
   ConnectorManager.prototype.query = function(sql, callee, options) {
-
     if(!this.isConnected && !this.pool) this.connect()
 
     var queueItem = {
-      query: new Query(this.client, callee, options || {}),
+      query: new Query(this.client, this.sequelize, callee, options || {}),
       sql: sql
     }
 

lib/dialects/mysql/query.js

 var Utils = require("../../utils")
 
 module.exports = (function() {
-  var Query = function(client, callee, options) {
+  var Query = function(client, sequelize, callee, options) {
     var self = this
 
-    this.client = client
-    this.callee = callee
-    this.options = Utils._.extend({
+    this.client    = client
+    this.callee    = callee
+    this.sequelize = sequelize
+    this.options   = Utils._.extend({
       logging: console.log,
       plain: false,
       raw: false

lib/dialects/postgres/connector-manager.js

@@ -26,7 +26,7 @@ module.exports = (function() {
   ConnectorManager.prototype.query = function(sql, callee, options) {
     var self = this
     if (this.client == null) this.connect()
-    var query = new Query(this.client, callee, options || {})
+    var query = new Query(this.client, this.sequelize, callee, options || {})
     self.pendingQueries += 1
     return query.run(sql)
       .success(function() { self.endQuery.call(self) })

lib/dialects/postgres/query.js

 var Utils = require("../../utils");
 
 module.exports = (function() {
-  var Query = function(client, callee, options) {
+  var Query = function(client, sequelize, callee, options) {
     var self = this
 
     this.client = client
+    this.sequelize = sequelize
     this.callee = callee
     this.options = Utils._.extend({
       logging: console.log,

lib/dialects/sqlite/connector-manager.js

@@ -10,7 +10,7 @@ module.exports = (function() {
   Utils._.extend(ConnectorManager.prototype, require("../connector-manager").prototype)
 
   ConnectorManager.prototype.query = function(sql, callee, options) {
-    return new Query(this.database, callee, options).run(sql)
+    return new Query(this.database, this.sequelize, callee, options).run(sql)
   }
 
   return ConnectorManager

lib/dialects/sqlite/query.js

 var Utils = require("../../utils")
 
 module.exports = (function() {
-  var Query = function(database, callee, options) {
+  var Query = function(database, sequelize, callee, options) {
     this.database = database
+    this.sequelize = sequelize
     this.callee = callee
     this.options = Utils._.extend({
       logging: console.log,