How to ALTER TABLE in Nifi

AbhishekSingh — Sun, 17 Jul 2022 18:04:00 GMT

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.

Re: How to ALTER TABLE in Nifi

AbhishekSingh — Thu, 21 Jul 2022 09:03:27 GMT

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

question Re: How to ALTER TABLE in Nifi in Support Questions

How to ALTER TABLE in Nifi

Re: How to ALTER TABLE in Nifi