好看响应式网站模板下载,韩国做美食的视频网站,对于网站建设的体会,呼和浩特做网站的公司有哪些【NIFI】实现ORACLE-ORACLE数据同步
需求 使用nifi实现 oracle-oracle 不同数据库之间的数据同步#xff0c; 如果想实现 oracle-oracle技术有很多#xff0c;例如使用oracle golden gate或者是kettle等#xff0c;或者是使用oralce的dblink技术也能实现。当让…【NIFI】实现ORACLE-ORACLE数据同步
需求 使用nifi实现 oracle-oracle 不同数据库之间的数据同步 如果想实现 oracle-oracle技术有很多例如使用oracle golden gate或者是kettle等或者是使用oralce的dblink技术也能实现。当让如果使用dblink就不是数据同步了属于数据共享了。 配置如下 1、QueryDatabaseTable用于读取数据 2、ConvertAvroToJSON读取数据转换JSON 3、ConvertJSONToSQL 转换插入语句 4、PutSQL 执插入语句 5、ConvertJSONToSQL 转换更新语句 6、PutSQL 执更新语句 1、QueryDatabaseTable 配置 Database Connection Pooling Service数据库连接池点击后面红色的按钮可以添加 Database Connection URLjdbc:oracle:thin:ip:port/db DatabaseDriver Class Name:oracle.jdbc.driver.OracleDriver Database DriverLocation(s):/app/nifi-1.27.0/extensions/ojdbc6-11.2.0.4.0-atlassian-hosted.jar Database User:username Password:password 以上根据实际情况配置如果存在多个jar可以只填写到文件夹 点击小闪电可以启动获取是关闭连接池
JDBC Connection PoolORACLE-TEST-CA-155Database TypeORALCETable Name:application_20230210Maximum-value Columns:OID
Maximum-value Columns填写了意味着每次只比上一次同步记录值大的数据
2、ConvertAvroToJSON 配置 不用做任何调整使用默认位置
3、ConvertJSONToSQL 配置 JDBC Connection PoolORACLE-DEV-PO-119Statement TypeINSERTTable Name:APPLICATION_20230210Update Keys:OID
注意避坑Table Name 必须大写ORACLE 默认大小写不敏感的否则无法实现数据同ConvertJSONToSQL 在生成sql时候去读的是oracle表的字段
4、PutSQL 配置 JDBC Connection PoolORACLE-DEV-PO-119
5、ConvertJSONToSQL 配置 JDBC Connection PoolORACLE-DEV-PO-119Statement TypeUPDATETable Name:APPLICATION_20230210Update Keys:OID
注意避坑Table Name 必须大写ORACLE 默认大小写不敏感的否则无法实现数据同ConvertJSONToSQL 在生成sql时候去读的是oracle表的字段
6、PutSQL 配置 JDBC Connection PoolORACLE-DEV-PO-119
连线配置 1、QueryDatabaseTable用于读取数据 2、ConvertAvroToJSON读取数据转换JSON 3、ConvertJSONToSQL 转换插入语句 4、PutSQL 执插入语句 5、ConvertJSONToSQL 转换更新语句 6、PutSQL 执更新语句 1-2 QueryDatabaseTable - ConvertAvroToJSON 2-3 ConvertAvroToJSON- ConvertJSONToSQL 3-4ConvertJSONToSQL - PutSQL 2-5 ConvertAvroToJSON - ConvertJSONToSQL 5-6ConvertJSONToSQL - PutSQL 其他场景的均终止即可 最后节点的关系是全部终止
启动流程
对流程中的每个步骤进行启动 这样就完成了同步的配置接下来就能去检查数据表中的数据了
