How to ALTER TABLE in Nifi

[#1]

Hi,

how can I alter the table using NIFI Processor where source dbname : org, tableName:status, destination dbName:report and tableName: orgStatus.

I am using captureChangeMySql Processor to read the binary-bin log file.

Below json i am getting in updateAtribute processor:

{"type":"ddl","timestamp":1658078637000,"binlog_filename":"mysql-bin.000030","binlog_position":2727,"database":"nrpsubscriptiondb2306","table_name":null,"table_id":null,"query":"ALTER TABLE `nrpuserorgdb2306`.`status` \nADD COLUMN `is_deleted` TINYINT NULL AFTER `code`"}

Please find my processor screenshot for this flow.

[#2 · Accepted solution]

Using replace text processor , I am able to modify it.