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文件写入到数据库中