【NIFI】实现HANA-＞ORACLE数据同步

【NIFI】实现HANA->ORACLE数据同步

需求

实现 HANA->ORACLE数据同步

• HANA表名（视图）："_SYS_BIC"."ZUNIS/CAL_ZFI019_DETAIL"
• ORACLE表明：CAL_ZFI019_DETAIL

配置如下

1、QueryDatabaseTable：用于读取数据
2、SplitAvro :数据分割
3、ConvertAvroToJSON：读取数据转换JSON
4、ConvertJSONToSQL： 转换插入语句
5、PutSQL： 执插入语句

1、QueryDatabaseTable 配置

• Database Connection Pooling Service：数据库连接池，点击后面红色的按钮可以添加：
  
  

• Database Connection URL：jdbc:sap://:?reconnect=true
• DatabaseDriver Class Name:com.sap.db.jdbc.Driver
• DatabaseDriverLocation(s):/app/nifi-1.27.0/extensions/ngdbc.jar
• Database User:
• Password:

• 1、QueryDatabaseTable 其他配置

• JDBC Connection Pool：HANA-TEST-68
• Database Type：Generic
• TableName:“_SYS_BIC”.“ZUNIS/CAL_ZFI019_DETAIL”
• Additional WHERE clause：UPDDATE >‘20220101’
• Maximum-value Columns:UPDDATE,UPDTM
• Max Rows Per Flow File：1000

2、SplitAvro

可以直接使用默认值，当数据量台大了，需要对数据进行分割

3、ConvertJSONToSQL

使用默认值即可

4、ConvertJSONToSQL

JDBC Connection Pool：ORACLE-DEV-PO-119
Statement Type：INSERT
TableName:CAL_ZFI019_DETAIL
Update Keys:OID

5、PutSQL

• JDBC Connection Pool：ORACLE-DEV-PO-119
  其他无需调整

然后按照顺序进行连线即可，连线关系参考：【NIFI】实现ORACLE-＞ORACLE数据同步

然后就是启动各个节点就可以实现数据同步