Как сравнить данные из БД в Нифи - PullRequest
Новая
       19

Как сравнить данные из БД в Нифи

0 голосов
/ 03 апреля 2020

Использование двух ExecuteSqlRecord процессоров для выполнения следующих sql.

"SELECT COLUMN_NAME, DATA_TYPE FROM user_tab_cols WHERE table_name = 'table_new';"

"SELECT COLUMN_NAME, DATA_TYPE FROM user_tab_cols WHERE table_name = 'table_old".

данные из table_old 

[ {
  "COLUMN_NAME" : "STUID",
  "DATA_TYPE" : "NUMBER"
}, {
  "COLUMN_NAME" : "STUNAME",
  "DATA_TYPE" : "VARCHAR2"
} ]

данные из table_new 


[ {
  "COLUMN_NAME" : "STUID",
  "DATA_TYPE" : "NUMBER"
}, {
  "COLUMN_NAME" : "STUNAME",
  "DATA_TYPE" : "VARCHAR2"
}, {
  "COLUMN_NAME" : "STUSEX",
  "DATA_TYPE" : "VARCHAR2"
}, {
  "COLUMN_NAME" : "STUPAR",
  "DATA_TYPE" : "VARCHAR2"
} ]

Как сравнить данные из другой таблицы, а затем сгенерировать DDL sql,

, например "ALTER TABLE ISA.table_old ADD (STUSEX varchar2 (20), STUPAR VARCHAR2); ".

я думаю, что можно использовать sql" ALTER TABLE ISA.table_old add ($ {параметр}) ", и сравниваемый результат передается и заменяется на $ {параметр}.

Возможно, мое решение неверно. Любая помощь оценена!

...