Adding the ability to provide a custom logging function in lieu of console.log

lib/dialects/mysql/query.js

@@ -23,10 +23,11 @@ module.exports = (function() {
 
 
     bindClient.call(this)
     bindClient.call(this)
 
 
-    if(this.options.logging)
+    if((this.options.logging) && (this.options.customLogger))
+      this.options.customLogger('Executing: ' + this.sql)
+    else if (this.options.logging)
       console.log('Executing: ' + this.sql)
       console.log('Executing: ' + this.sql)
 
 
-
     this.client.query(this.sql, function(err, results, fields) {
     this.client.query(this.sql, function(err, results, fields) {
       self.emit('sql', self.sql)
       self.emit('sql', self.sql)
       err ? onFailure.call(self, err) : onSuccess.call(self, results, fields)
       err ? onFailure.call(self, err) : onSuccess.call(self, results, fields)

lib/dialects/sqlite/query.js

@@ -17,7 +17,9 @@ module.exports = (function() {
 
 
     this.sql = sql
     this.sql = sql
 
 
-    if(this.options.logging)
+    if((this.options.logging) && (this.options.customLogger))
+      this.options.customLogger('Executing: ' + this.sql)
+    else if(this.options.logging)
       console.log('Executing: ' + this.sql)
       console.log('Executing: ' + this.sql)
 
 
     this.database.serialize(function() {
     this.database.serialize(function() {

lib/migrator.js

@@ -46,11 +46,15 @@ module.exports = (function() {
           migrations.forEach(function(migration) {
           migrations.forEach(function(migration) {
             chainer.add(migration, 'execute', [options], {
             chainer.add(migration, 'execute', [options], {
               before: function(migration) {
               before: function(migration) {
-                if(self.options.logging)
+                if((self.options.logging) && (self.options.customLogger))
+                  self.options.customLogger('Executing migration: ' + migration.filename)
+                else if(self.options.logging)
                   console.log('Executing migration: ' + migration.filename)
                   console.log('Executing migration: ' + migration.filename)
               },
               },
               after: function(migration) {
               after: function(migration) {
-                if(self.options.logging)
+                if ((self.options.logging) && (self.options.customLogger))
+                  self.options.customLogger('Executed migration: ' + migration.filename)
+                else if (self.options.logging)
                   console.log('Executed migration: ' + migration.filename)
                   console.log('Executed migration: ' + migration.filename)
               },
               },
               success: function(migration, callback) {
               success: function(migration, callback) {

lib/sequelize.js

@@ -72,7 +72,9 @@ module.exports = (function() {
   Sequelize.prototype.query = function(sql, callee, options) {
   Sequelize.prototype.query = function(sql, callee, options) {
     options = Utils._.extend(Utils._.clone(this.options.query), options || {})
     options = Utils._.extend(Utils._.clone(this.options.query), options || {})
     options = Utils._.extend(options, {
     options = Utils._.extend(options, {
-      logging: this.options.hasOwnProperty('logging') ? this.options.logging : true
+      logging: this.options.hasOwnProperty('logging') ? this.options.logging : true,
+      customLogger: this.options.hasOwnProperty('customLogger') &&
+          typeof(this.options.customLogger) === 'function' ? this.options.customLogger : undefined
     })
     })
 
 
     return this.connectorManager.query(sql, callee, options)
     return this.connectorManager.query(sql, callee, options)