Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var MySQLEvents = require('mysql-events');
- var dsn = {
- host: 'localhost',
- user: 'root',
- password: '' // no password set that's why keep blank
- };
- var mysqlEventWatcher = MySQLEvents(dsn);
- console.log(mysqlEventWatcher);
- var watcher =mysqlEventWatcher.add(
- 'myDB.myTable',
- function (oldRow, newRow, event) {
- //row inserted
- if (oldRow === null) {
- //insert code goes here
- }
- //row deleted
- if (newRow === null) {
- //delete code goes here
- }
- //row updated
- if (oldRow !== null && newRow !== null) {
- //update code goes here
- }
- //detailed event information
- console.log(event); // don't matter, it updates, delete or insert
- },
- 'Active'
- );
- { started: false,
- zongji: {},
- databases: [],
- tables: {},
- columns: {},
- events: [ 'tablemap', 'writerows', 'updaterows', 'deleterows' ],
- triggers: [],
- dsn: { host: 'localhost', user: 'root', password: '' },
- settings: {},
- connect: [Function: connect],
- add: [Function: add],
- remove: [Function: remove],
- stop: [Function: stop],
- reload: [Function: reload],
- includeSchema: [Function: includeSchema] }
- var watcher =mysqlEventWatcher.add(
- 'your_database_name.your_table_name',
- function (oldRow, newRow, event) {}
- );
- var ZongJi = require('zongji');
- var zongji = new ZongJi({
- host : 'localhost',
- user : 'user',
- password : 'password',
- debug: true
- });
- zongji.on('binlog', function(evt) {
- evt.dump();
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement