Pass the uuid as a second parameter to the sql event

lib/dialects/mysql/query.js

@@ -24,7 +24,7 @@ module.exports = (function() {
     }
     }
 
 
     this.client.query(this.sql, function(err, results, fields) {
     this.client.query(this.sql, function(err, results, fields) {
-      this.emit('sql', this.sql)
+      this.emit('sql', this.sql, this.options.uuid)
 
 
       if (err) {
       if (err) {
         err.sql = sql
         err.sql = sql
@@ -38,5 +38,3 @@ module.exports = (function() {
 
 
   return Query
   return Query
 })()
 })()
-
-

lib/dialects/postgres/query.js

@@ -38,12 +38,12 @@ module.exports = (function() {
     query.on('error', function(err) {
     query.on('error', function(err) {
       receivedError = true
       receivedError = true
       err.sql = sql
       err.sql = sql
-      self.emit('sql', sql)
+      self.emit('sql', sql, self.options.uuid)
       self.emit('error', err, self.callee)
       self.emit('error', err, self.callee)
     })
     })
 
 
     query.on('end', function(result) {
     query.on('end', function(result) {
-      self.emit('sql', self.sql)
+      self.emit('sql', self.sql, self.options.uuid)
 
 
       if (receivedError) {
       if (receivedError) {
         return
         return

lib/dialects/sqlite/query.js

@@ -36,13 +36,13 @@ module.exports = (function() {
         if (self.sql.indexOf('-- ') === 0) {
         if (self.sql.indexOf('-- ') === 0) {
           // the sql query starts with a comment. don't bother the server with that ...
           // the sql query starts with a comment. don't bother the server with that ...
           Utils.tick(function() {
           Utils.tick(function() {
-            self.emit('sql', self.sql)
+            self.emit('sql', self.sql, self.options.uuid)
             self.emit('success', null)
             self.emit('success', null)
           })
           })
         } else {
         } else {
           self.database[getDatabaseMethod.call(self)](self.sql, function(err, results) {
           self.database[getDatabaseMethod.call(self)](self.sql, function(err, results) {
             // allow clients to listen to sql to do their own logging or whatnot
             // allow clients to listen to sql to do their own logging or whatnot
-            self.emit('sql', self.sql)
+            self.emit('sql', self.sql, self.options.uuid)
 
 
             if (err) {
             if (err) {
               err.sql = self.sql
               err.sql = self.sql