佛山网站设计哪家便宜,法拍房北京网站,自媒体平台排名,企业专业网站建设哪家好1、本节通过一个小例子来讲解下处理器PutDatabaseRecord#xff0c;该处理器的作用是将数据写入数据库。
如下流程通过处理器GenerateFlowFile 生成数据#xff0c;然后通过处理器JoltTransformJSON转换结构#xff0c;最后通过处理器PutDatabaseRecord将数据写入数据库。如…1、本节通过一个小例子来讲解下处理器PutDatabaseRecord该处理器的作用是将数据写入数据库。
如下流程通过处理器GenerateFlowFile 生成数据然后通过处理器JoltTransformJSON转换结构最后通过处理器PutDatabaseRecord将数据写入数据库。如下图所示 2、处理器GenerateFlowFile 生成自定义数据如下图所示 3、处理器JoltTransformJSON转换结构将结构转换成适合表字段的结构此时有两种方式驼峰和下划线两种方式。下图采用驼峰方式 4、处理器PutDatabaseRecord将数据写入数据库此处理器需要配置两个控制器Record Reader和Database Connection Pooling Service 两个控制器。 Record Reader
指定用于解析传入数据并确定数据模式的控制器服务。
Database Type
数据库的类型/版本用于生成特定于数据库的代码。在许多情况下通用类型应该足够但某些数据库例如Oracle需要自定义的SQL子句。这里我们选择mysql
Statement Type
支持常见的sql语句类型如增删改查我们这里选择insert
Data Record Path
指定数据记录的路径该路径确定了要发送到目标数据库的记录。
Database Connection Pooling Service
配置数据库连接池信息如下图所 Catalog Name
SQL语句应该更新的目录名称
Schema Name
database 名称
Table Name
表名
Translate Field Names
如果设置为 true处理器将尝试将字段名翻译为指定表格的相应列名。如果设置为 false字段名必须与列名完全匹配否则列将不会被更新。
Unmatched Field Behavior
未匹配的字段行为自己根据要求进行选择。未匹配的字段行为自己根据要求进行选择策略。
Unmatched Field Behavior 如果传入记录没有数据库表的所有列的字段映射该属性指定如何处理这种情况。
其他属性如果感兴趣的可以自行尝试配置。
5、大功告成查看表my_user,数据已经写入这里为了演示方便所以user_id 没有设置唯一健。
