MySQL binlog filter

Binlog_filter.js

const fs = require("fs");

const binlogFile = "allbinglog.sql"; // bin log file name

const db = ""; // db name
const table = ""; // table

const outputFile = "output.sql";

const pattern = new RegExp(
  `### (UPDATE|INSERT INTO|DELETE FROM) ${db}.${table}`, // activites
  "g"
);

const input = fs.createReadStream(binlogFile);
const output = fs.createWriteStream(outputFile);

let currentEvent = "";
let streak = false;

input.on("data", (data) => {
  const lines = data.toString().split("\n");
  lines.forEach((line) => {
    if (pattern.test(line)) {
      currentEvent = line + "\n";
      streak = true;
    } else if (streak && /^### (WHERE|\s*@|SET)/.test(line)) {
      currentEvent += `${line}\n`;
    } else {
      output.write(currentEvent);
      currentEvent = "";
      streak = false;
    }
  });
});

input.on("end", () => {
  if (currentEvent !== "") output.write(currentEvent);
  output.end();
});

input.on("error", (err) =>
  console.error(`Error reading from input file: ${err}`)
);

output.on("error", (err) =>
  console.error(`Error writing to output file: ${err}`)
);

output.on("finish", () =>
  console.log(`Finished writing to output file: ${outputFile}`)
);