Skip to main content

PutDatabaseRecord

对数据库指定表进行数据更新、插入或删除操作。

参数说明​

记录读取器​

用于解析输入数据流的数据格式，一般JSON、AVRO、CSV或XML都可以。

语句类型​

选择进行SQL操作的语句类型，分为Insert、Update和Delete。

数据库连接池​

提供数据库连接。

表名​

指定SQL操作的数据表。

转换字段名​

  • 是否尝试适当的转换字段名为数据库可接受的表字段名。
  • 选择转换时，会自动把传入数据中字段名里面的类似下划线之类的东西忽略，这样有可能会导致组件运行出错。
  • 没有特殊情况该选项建议选择不转换。

更新字段​

当语句类型为Update时，用于指定要更新的字段列表，以英文逗号分隔。

示例​

GenerateFlowFile属性设置​

设置自定义文本如下：

{
    "test_id":2,
    "test_title":"网易新闻",
    "test_author":"网易163",
    "submission_date":"2019-07-13"
}

PutDatabaseRecord属性设置​

设置了语句类型为MySQL，表名为test_tbl，数据库连接池服务配置如下：

  • 数据库连接URL和数据库驱动类名与JDBC连接数据库时的配置一致。
  • 数据库驱动包为驱动包的绝对路径，需要提前把相应数据库驱动jar包存放在runtime所运行的机器上。
  • 密码设置后，被标注为“敏感值设置”，实际上为了安全，是不会显示字面值的，显示敏感值设置说明已经设置上。

结果​

运行完PutDatabaseRecord组件后，再通过QueryDatabaseTable查看数据表里面的数据，最后输出结果如下：

流程模板​

参见附件(请右键另存保存)：模板文件