About data_tr

data_tr · ‎09-08-2022

Thanks for your reply, I checked CDC processor but it is specific to MySQL db. My source db is Oracle. ID is not the incremental column in the tables. There is a modifiedtime column in both table_a and table_b that shows the updated time of the row. For now I used modifiedtime column in table_a as Maximum-value Columns in QueryDatabase processor, but when modifiedtime column updated on table_b (eg. column_1 table value updated in table_b) I can't track the change in this table. Should I use another QueryDatabase processor and set modifiedtime column in table_b as Maximum-value Columns?

data_tr · ‎09-06-2022

Hi, I am using a QueryDatabase Table processor to get data from Oracle database to transfer data. I use custom query like below. Both table_a and table_b has incremental columns that I can use for maximum-value columns. My question is, can we track changes from both tables in a single QueryDatabase processor. When any column from table_a or table_b changes, I want to transfer below query result to another Oracle database. Select a.column_1, a.column_2, a.column_3, b.column_1, b.column_2, b.column_3 from table_a a table_b b where a.id=b.id Thanks

Online	Offline
Last Visited	‎09-14-2022 10:56 AM

Member Since	‎09-06-2022 09:43 AM
Last Visited	‎09-14-2022 10:56 AM
Posts	2

Cloudera Community

Re: Using multiple tables in nifi querydatabasetab...

Using multiple tables in nifi querydatabasetable c...