@@ -146,15 +146,15 @@ var MySQLEvents = function(dsn) {
146
146
}
147
147
148
148
//call all database callbacks
149
- var dbTriggers = _underScore . filter ( mySQLEvents . triggers , function ( t ) {
149
+ var dbTriggers = _underScore . filter ( this . triggers , function ( t ) {
150
150
return t . trigger == database ;
151
151
} ) ;
152
152
_underScore . each ( dbTriggers , function ( dbTrigger ) {
153
153
dbTrigger . callback . call ( dbTrigger , oldRow , newRow ) ;
154
154
} ) ;
155
155
156
156
//call all database.table callbacks
157
- var tblTriggers = _underScore . filter ( mySQLEvents . triggers , function ( t ) {
157
+ var tblTriggers = _underScore . filter ( this . triggers , function ( t ) {
158
158
return t . trigger == database + '.' + table ;
159
159
} ) ;
160
160
_underScore . each ( tblTriggers , function ( tblTrigger ) {
@@ -164,7 +164,7 @@ var MySQLEvents = function(dsn) {
164
164
//call all database.table.column, database.table.column, database.table.column.value & database.table.column.regexp callbacks
165
165
_underScore . each ( changedColumns , function ( col ) {
166
166
//value match
167
- var colTriggers = _underScore . filter ( mySQLEvents . triggers , function ( t ) {
167
+ var colTriggers = _underScore . filter ( this . triggers , function ( t ) {
168
168
return ( ( t . trigger == database + '.' + table + '.' + col ) || ( t . trigger == database + '.' + table + '.' + col + '.value' ) ) ;
169
169
} ) ;
170
170
_underScore . each ( colTriggers , function ( colTrigger ) {
@@ -176,7 +176,7 @@ var MySQLEvents = function(dsn) {
176
176
}
177
177
} ) ;
178
178
//regexp match
179
- var colTriggers = _underScore . filter ( mySQLEvents . triggers , function ( t ) {
179
+ var colTriggers = _underScore . filter ( this . triggers , function ( t ) {
180
180
return t . trigger == database + '.' + table + '.' + col + '.regexp' ;
181
181
} ) ;
182
182
_underScore . each ( colTriggers , function ( colTrigger ) {
@@ -207,40 +207,40 @@ var MySQLEvents = function(dsn) {
207
207
var watcher = trigger . trigger . split ( '.' ) ;
208
208
209
209
if ( watcher . length == 1 ) {
210
- if ( _underScore . indexOf ( mySQLEvents . databases , watcher [ 0 ] ) == - 1 )
211
- mySQLEvents . databases . push ( watcher [ 0 ] ) ;
210
+ if ( _underScore . indexOf ( this . databases , watcher [ 0 ] ) == - 1 )
211
+ this . databases . push ( watcher [ 0 ] ) ;
212
212
}
213
213
214
214
if ( watcher . length == 2 ) {
215
- if ( ! _underScore . has ( mySQLEvents . tables , watcher [ 0 ] ) ) {
215
+ if ( ! _underScore . has ( this . tables , watcher [ 0 ] ) ) {
216
216
var map = { } ;
217
217
map [ watcher [ 0 ] ] = [ ] ;
218
- _underScore . extend ( mySQLEvents . tables , map ) ;
218
+ _underScore . extend ( this . tables , map ) ;
219
219
}
220
- mySQLEvents . tables [ watcher [ 0 ] ] . push ( watcher [ 1 ] ) ;
220
+ this . tables [ watcher [ 0 ] ] . push ( watcher [ 1 ] ) ;
221
221
}
222
222
223
223
if ( watcher . length == 3 ) {
224
224
var map = {
225
225
type : 'value'
226
226
} ;
227
227
228
- if ( ! _underScore . has ( mySQLEvents . columns , watcher [ 0 ] ) ) {
228
+ if ( ! _underScore . has ( this . columns , watcher [ 0 ] ) ) {
229
229
var db = { } ;
230
230
db [ watcher [ 0 ] ] = [ ] ;
231
- _underScore . extend ( mySQLEvents . columns , db ) ;
231
+ _underScore . extend ( this . columns , db ) ;
232
232
}
233
- if ( ! _underScore . has ( mySQLEvents . columns [ watcher [ 0 ] ] , watcher [ 1 ] ) ) {
233
+ if ( ! _underScore . has ( this . columns [ watcher [ 0 ] ] , watcher [ 1 ] ) ) {
234
234
var table = { } ;
235
235
table [ watcher [ 1 ] ] = [ ] ;
236
- _underScore . extend ( mySQLEvents . columns [ watcher [ 0 ] ] , table ) ;
236
+ _underScore . extend ( this . columns [ watcher [ 0 ] ] , table ) ;
237
237
}
238
- if ( ! _underScore . has ( mySQLEvents . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , watcher [ 2 ] ) ) {
238
+ if ( ! _underScore . has ( this . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , watcher [ 2 ] ) ) {
239
239
var col = { } ;
240
240
col [ watcher [ 2 ] ] = [ ] ;
241
- _underScore . extend ( mySQLEvents . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , col ) ;
241
+ _underScore . extend ( this . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , col ) ;
242
242
}
243
- mySQLEvents . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] [ watcher [ 2 ] ] . push ( map ) ;
243
+ this . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] [ watcher [ 2 ] ] . push ( map ) ;
244
244
}
245
245
246
246
if ( watcher . length == 4 ) {
@@ -255,22 +255,22 @@ var MySQLEvents = function(dsn) {
255
255
} ;
256
256
}
257
257
258
- if ( ! _underScore . has ( mySQLEvents . columns , watcher [ 0 ] ) ) {
258
+ if ( ! _underScore . has ( this . columns , watcher [ 0 ] ) ) {
259
259
var db = { } ;
260
260
db [ watcher [ 0 ] ] = [ ] ;
261
- _underScore . extend ( mySQLEvents . columns , db ) ;
261
+ _underScore . extend ( this . columns , db ) ;
262
262
}
263
- if ( ! _underScore . has ( mySQLEvents . columns [ watcher [ 0 ] ] , watcher [ 1 ] ) ) {
263
+ if ( ! _underScore . has ( this . columns [ watcher [ 0 ] ] , watcher [ 1 ] ) ) {
264
264
var table = { } ;
265
265
table [ watcher [ 1 ] ] = [ ] ;
266
- _underScore . extend ( mySQLEvents . columns [ watcher [ 0 ] ] , table ) ;
266
+ _underScore . extend ( this . columns [ watcher [ 0 ] ] , table ) ;
267
267
}
268
- if ( ! _underScore . has ( mySQLEvents . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , watcher [ 2 ] ) ) {
268
+ if ( ! _underScore . has ( this . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , watcher [ 2 ] ) ) {
269
269
var col = { } ;
270
270
col [ watcher [ 2 ] ] = [ ] ;
271
- _underScore . extend ( mySQLEvents . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , col ) ;
271
+ _underScore . extend ( this . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] , col ) ;
272
272
}
273
- mySQLEvents . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] [ watcher [ 2 ] ] . push ( map ) ;
273
+ this . columns [ watcher [ 0 ] ] [ watcher [ 1 ] ] [ watcher [ 2 ] ] . push ( map ) ;
274
274
}
275
275
}
276
276
} ) ;
0 commit comments