diff --git a/package.json b/package.json index a56fdc4..562ca5e 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "mycdc", - "version": "0.0.6", + "version": "0.0.8", "author": "Verdnatura Levante SL", "description": "Asynchronous DB calculations reading the binary log", "license": "GPL-3.0", diff --git a/queues/queue-id.js b/queues/queue-id.js index 526506e..eea9db7 100644 --- a/queues/queue-id.js +++ b/queues/queue-id.js @@ -24,9 +24,8 @@ module.exports = class QueueId extends Queue { await consumer.db.query(query, myParams); } - const keyChanged = data.cols.indexOf(key) !== -1; - if (data.eventName === 'updaterows') { + const keyChanged = data.cols.indexOf(key) !== -1; for (const row of data.rows) { if (keyChanged) await dbQuery(row.before[key]);