nifi之将上游的生成的sql语句写入到数据库中

在上一篇中我们已经成功的将数据转换成了sql语句,那么这一篇我们会将sql语句写进数据库中

PutSQL：通过Flowfile中的内容对数据库进行更新(flowfile包含的是一些数据库DDM语句

更改处理器名称

配置putsql处理器的属性

新建一个连接池

配置连接池

基本上与从数据库里面取数据的配置方法一样

我的构想是这样的,数据基本上原理都一样,无论是mysql 还是sql server都是通过java驱动来进行读取和写入数据的,咱们这里是为了练习测试,所以小编决定再将数据写进同一个数据库中只不过不是同一个表

确保dest数据库中的表与我们取数据的表的字段格式是一样的

字段名称可以不一样,生成的sql语句里面的字段名称可以在上一篇自己配置
如果没有表,请创建一张测试表,和小编一样

开始配置

需要更改一下SpliteText处理器的属性配置

我们在上一篇文章中生成sql中,sql语句中我们需要插入的数据的表不对,我们需要改改.

创建自连接

因为到了这里就是一个结束了,不需要下游了,可以让他自连接了就

启动查看效果

可以看到我们的表中是空的

执行开始

出现报错

原因是我们忘了配置数据库账号密码了

重新开始

同理全部处理器停止

检查数据库

结束语

到这里,这个总体也就结束了,感谢大家的陪伴,下一步,小编在编写一下实时同步数据库的数据