DatabaseRecordSink - ACAL Lynxus 组件文档

DatabaseRecordSink Controller Service

类型全限定名：cn.org.acal.lynxus.record.sink.db.DatabaseRecordSink

所属 Bundle：cn.org.acal.lynxus:lynxus-dbcp-service-nar:2.11.8

描述

提供使用配置的数据库连接写入记录的服务。

标签

dbjdbcdatabaseconnectionrecord

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Database Connection Pooling Service		控制器服务 API： `DBCPService` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	用于获取与数据库的连接以发送记录的Controller Service。
Catalog Name			语句应更新的目录的名称。这可能不适用于您正在更新的数据库。在这种情况下，将该字段留空支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Schema Name			表所属架构的名称。这可能不适用于您正在更新的数据库。在这种情况下，将该字段留空支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Table Name			该语句应影响的表的名称。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Translate Field Names	`true`	true false	如果为 true，处理器将尝试将字段名转换为指定表的相应列名。如果为 false，字段名必须与列名完全匹配，否则该列将不会被更新
Unmatched Field Behavior	`Ignore Unmatched Fields`	忽略不匹配的字段 — 文档中无法映射到数据库列的任何字段都将被忽略不匹配字段时失败 — 如果文档有任何无法映射到数据库列的字段，FlowFile 将被路由到失败关系	如果传入记录的字段未映射到数据库表的任何列，则此属性指定如何处理这种情况
Unmatched Column Behavior	`Fail on Unmatched Columns`	忽略不匹配的列 — 数据库中没有对应文档字段的列将被视为不需要。不会记录任何通知不匹配列时警告 — 数据库中没有对应文档字段的列将被视为不需要。将记录警告不匹配列时失败 — 如果数据库中有任何列在文档中没有对应字段，流程将失败。将记录错误	如果传入记录没有数据库表所有列的字段映射，则此属性指定如何处理这种情况
Quote Column Identifiers	`false`	true false	启用此选项将导致所有列名被引用，从而允许您使用保留字作为表中的列名。
Quote Table Identifiers	`false`	true false	启用此选项将导致表名被引用，以支持在表名中使用特殊字符。
Max Wait Time	`0 seconds`		正在运行的 SQL 语句允许的最大时间，零表示没有限制。最大时间小于 1 秒将等于零。支持表达式语言：是（仅使用环境/系统变量求值）

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

提供的 Service API

RecordSinkService (cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8)