Skip to main content
AbhishekSingh
Gold ⭐️
July 17, 2022
Solved

How to ALTER TABLE in Nifi

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.

 

Screenshot from 2022-07-17 23-24-00.pngScreenshot from 2022-07-17 23-12-24.pngScreenshot from 2022-07-17 23-12-46.png

 

  

AbhishekSingh
Gold ⭐️
July 21, 2022

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

1 reply

AbhishekSingh
AbhishekSinghAuthorAnswer
Gold ⭐️
July 21, 2022

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

Translate