PutDBRecord
描述:
针对传入的数据写入数据库
标签:
sql, record, jdbc, put, database, update, insert, delete, 数据库
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 记录读取器 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 指定用于解析输入数据流数据格式的服务 | |
| 记录写入器 | 控制器服务API: RecordSetWriterFactory 实现: CSVRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter JsonRecordSetWriter XMLRecordSetWriter ParquetRecordSetWriter ScriptedRecordSetWriter | 指定用于定义输出数据流数据格式的服务 | |
| 数据库连接池服务 | 控制器服务API: DBCPService 实现: DBCPConnectionPoolLookup DBCPConnectionPool | 数据库连接池服务用来获得数据库连接 | |
| 自动提交 | false | - true - false | 自动提交到数据库 |
| 预处理SQL | 预处理SQL, 一般配合“自动提交=false”参数使用 支持表达式语言 (支持流属性和变量) | ||
| 批量执行条数 | 1000 | 每多少条数据，执行一次数据库操作 支持表达式语言 (支持流属性和变量) | |
| 批量提交条数 | 5000 | 批量提交条数，建议设置为批量执行行数的倍数，以达到不影响效率的目的 支持表达式语言 (支持流属性和变量) | |
| 输出错误数据到failure | false | - true - false | 输出错误数据到failure |
| 输出正确数据到success | false | - true - false | 输出正确数据到success |
连线:
| 名字 | 描述 |
|---|---|
| success | 成功执行操作后，数据输出到此连线 |
| failure | 由于某种原因导致数据库操作失败的原始数据输出到连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| execute.row.count | 总计执行行数 |
| success.row.count | 正确执行行数 |
| error.row.count | 错误执行行数 |
| error.message | 错误信息 |
| execute.success | 是否全部执行成功 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。