自学内容网 自学内容网

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

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

需求

实现MySQL->ORACLE数据同步
MySQL表名:eb_merchant_admin
ORACLE表名:EB_MERCHANT_ADMIN

配置流程

在这里插入图片描述
与oralce->oralce的类似,如果想了解 oracle->oracle 请参考【NIFI】实现ORACLE->ORACLE数据同步

1、QueryDatabaseTable:用于读取数据
2、ConvertAvroToJSON:读取数据转换JSON
3、ConvertJSONToSQL: 转换插入语句
4、PutSQL: 执插入语句
5、ConvertJSONToSQL: 转换更新语句
6、PutSQL: 执更新语句

这里只对和ORACLE不一样的地方做出标注,

1、QueryDatabaseTable

在这里插入图片描述
Database Type:MySQL(当然也可以使用默认值)

4、PutSQL 插入

在这里插入图片描述

  • 这里如果填写了 SQL Statement 则使用填写的,不使用上游传递下来的
  • INSERT INTO EB_MERCHANT_ADMIN (MERCHANT_ADMIN_ID, MER_ID, ACCOUNT, PWD, REAL_NAME, PHONE, LAST_IP, LAST_TIME, "roles", LOGIN_COUNT, "level", IS_DEL, STATUS, CREATE_TIME) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
  • 之所以填写是因为,MySQL表中存在2个字段roleslevel,是ORACLE数据库的关键字
  • 在oracle创建字段名称时,需要用双引号括起来

如果碰到MySQL字段使用ORACLE关键字时可以这么处理

6、PutSQL 更新

和步骤4是一样的,处理方式,将ConvertJSONToSQL生成的SQL简单处理,然后填写SQL Statement


原文地址:https://blog.csdn.net/weixin_43159039/article/details/144710326

免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!