【NiFi csv to mysql系列】二 JSON文件写入数据库

Abstract

本文的主要目的是将一个JSON格式的文件写入到数据库中

整体流程

包含三个Processor:

GetFile:读取json格式的文件
ConvertJSONToSQL:将json中的元素转化为sql中的insert语句
PutSQL:执行上一个processor生成的sql语句,将json中的元素插入到数据库中


详细配置

GetFile处理器

此处理器的配置已经在上一篇文章中进行了介绍,这里将省略此部分内容,输入的文件为包含一个json元素的文件:


ConvertJSONToSQL处理器

注意:该处理器有一个特性,只能处理flat json,所谓flat是指it consists of a single JSON element and each field maps to a simple type


其中的参数: 
JDBC Connection Pool:根据要连接的数据库类型选择,我要连接的是mysql数据库,因此选择DBCPConnectionPool 
Statement Type:设置要执行的操作,INSERT和UPDATE等,这里要执行的是插入操作 
Translate Field Name: 如果json中元素的属性名称与数据表中的列名称一致,则选择false,否则选择true

JDBC Connection Pool的属性后面有一个小箭头,点击箭头对此项进行设置: 
实际上这个java连接数据的设置是一致的, 
Database Driver Class Name: 根据要连接的数据库类型选择 
Database Driver location:选择对应数据库连接jar包的完整路径 
Database User:登录数据库的用户名 
Password:用户名对应的密码

PutSQL处理器

这里只设定了 JDBC Connection Pool


对应数据库表的结构:


至此已经完成了将一条json数据插入到数据库中


目前只能插入单条的json记录,接下来将探索如何将包含多条记录的json文件写入到数据库中

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 136,660评论 19 139
  • 关于Mongodb的全面总结 MongoDB的内部构造《MongoDB The Definitive Guide》...
    中v中阅读 32,313评论 2 89
  • 人生最关键的是童年,比如如何处理问题的能力,比如如何与人交流,如何一步步建立自己的自信。
    七根白发阅读 304评论 0 0
  • 谁,执我之手,敛我半世癫狂; 谁,吻我之眸,遮我半世流离; 谁,扶我之面,慰我半世...
    付春雷阅读 337评论 0 1
  • 我作为正在大学念书的大二学生。作为一个想要创业的我总是极力的加了学校很多的创业社团,认识了许多指导学生创业的老师...
    致遗忘了我的你YXY阅读 480评论 2 2

友情链接更多精彩内容