【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数据同步
然后就是启动各个节点就可以实现数据同步
