DatabaseRecordSink¶
描述¶
提供使用配置的数据库连接写入记录的服务。
属性¶
下表列出了各项属性，其中带星号 (*) 的为必需属性。其他属性视为可选属性。该表还指出了所有默认值以及属性是否支持 NiFi 表达式语言。
显示名称 |
API 名称 |
默认值 |
允许值 |
描述 |
|---|---|---|---|---|
目录名称 |
db-record-sink-catalog-name |
语句应更新的目录的名称。这可能不适用于您正在更新的数据库。在这种情况下，将该字段留空 |
||
数据库连接池服务 * |
db-record-sink-dcbp-service |
用于获取与数据库的连接以发送记录的控制器服务。 |
||
最大等待时间 * |
db-record-sink-query-timeout |
0 秒 |
允许正在运行的 SQL 语句运行的最长时间量，零表示没有限制。如果最长时间小于 1 秒，则视同为零。 |
|
引用列标识符 |
db-record-sink-quoted-identifiers |
false |
|
启用此选项将导致所有列名都被置于引号之间，从而允许您在表中使用保留字作为列名。 |
引用表标识符 |
db-record-sink-quoted-table-identifiers |
false |
|
启用此选项将导致表名被置于引号之间，以支持在表名中使用特殊字符。 |
架构名称 |
db-record-sink-schema-name |
表所属的架构的名称。这可能不适用于您正在更新的数据库。在这种情况下，将该字段留空 |
||
表名称 * |
db-record-sink-table-name |
该语句应影响的表的名称。 |
||
转换字段名称 |
db-record-sink-translate-field-names |
true |
|
如果为 true，处理器将尝试将字段名称转换为指定表的相应列名称。如果为 false，则字段名称必须与列名称完全匹配，否则该列将不会更新 |
不匹配的列行为 |
db-record-sink-unmatched-column-behavior |
列不匹配时失败 |
|
如果传入记录没有数据库表所有列的字段映射，则此属性指定应如何处理这种情况 |
不匹配的字段行为 |
db-record-sink-unmatched-field-behavior |
忽略不匹配的字段 |
|
如果传入记录的字段未映射到数据库表的任何列，则此属性指定应如何处理这种情况 |
状态管理¶
此组件不存储状态。
受限¶
此组件不受限制。
系统资源注意事项¶
此组件未指定系统资源注意事项。