@@ -180,15 +180,15 @@ var MySQLEvents = function(dsn, settings) {
180
180
return t . trigger == database ;
181
181
} ) ;
182
182
_underScore . each ( dbTriggers , function ( dbTrigger ) {
183
- dbTrigger . callback . call ( dbTrigger , oldRow , newRow ) ;
183
+ dbTrigger . callback . call ( dbTrigger , oldRow , newRow , evt ) ;
184
184
} ) ;
185
185
186
186
//call all database.table callbacks
187
187
var tblTriggers = _underScore . filter ( mySQLEvents . triggers , function ( t ) {
188
188
return t . trigger == database + '.' + table ;
189
189
} ) ;
190
190
_underScore . each ( tblTriggers , function ( tblTrigger ) {
191
- tblTrigger . callback . call ( tblTrigger , oldRow , newRow ) ;
191
+ tblTrigger . callback . call ( tblTrigger , oldRow , newRow , evt ) ;
192
192
} ) ;
193
193
194
194
//call all database.table.column, database.table.column, database.table.column.value & database.table.column.regexp callbacks
@@ -199,10 +199,10 @@ var MySQLEvents = function(dsn, settings) {
199
199
} ) ;
200
200
_underScore . each ( colTriggers , function ( colTrigger ) {
201
201
if ( _underScore . isUndefined ( colTrigger . value ) ) {
202
- colTrigger . callback . call ( colTrigger , oldRow , newRow ) ;
202
+ colTrigger . callback . call ( colTrigger , oldRow , newRow , evt ) ;
203
203
}
204
204
else if ( row . after [ col ] == colTrigger . value ) {
205
- colTrigger . callback . call ( colTrigger , oldRow , newRow ) ;
205
+ colTrigger . callback . call ( colTrigger , oldRow , newRow , evt ) ;
206
206
}
207
207
} ) ;
208
208
//regexp match
@@ -211,7 +211,7 @@ var MySQLEvents = function(dsn, settings) {
211
211
} ) ;
212
212
_underScore . each ( colTriggers , function ( colTrigger ) {
213
213
if ( ! _underScore . isUndefined ( colTrigger . value ) && colTrigger . value . test ( row . after [ col ] ) ) {
214
- colTrigger . callback . call ( colTrigger , oldRow , newRow ) ;
214
+ colTrigger . callback . call ( colTrigger , oldRow , newRow , evt ) ;
215
215
}
216
216
} ) ;
217
217
} ) ;
0 commit comments