nifi之将已经定义好的数据进行取值并拼装成sql语句

上一篇我们已经成功的将数据进行了自定义,方便交接给下游处理器进行使用,今天我们就用ReplaceText处理器来对数据进行拼接

对ReplaceText处理器命名

进行处理器的属性配置

准备我们需要的sql插入语句,应为我们后期还要对数据库进行写入,我们就的需要一个数据库的插入语句,每个人与每个表的字段都不一样,如果大家要用的话,还是建议大家先在数据库试下能不能正常的插入数据

我的sql语句如下:

因为小编的id是自增的还是主键,就不需要考虑他了
INSERT INTO user_source.user(name,age,ipone,email,sex) VALUES("小米","23","1122222","12345@qq.com","男")

其中的valus的值我们需要从上游数据里面进行提取,所以我们要这样写

INSERT INTO user_source.user(name,age,ipone,email,sex) VALUES("${name}","${age}","${ipone}","${email}","${sex}")

创建下游PutSQL 处理器

这个处理器主要是为了向数据库中写入数据的

连接上下游

配置自连接

启动查看效果

查看数据格式是不是sql语句

测试在数据库里面是不是可以执行

可以正常的执行说明咱离成功又近了一步

结束语

下一步,咱要利用putsql将这些sql语句写进数据库