ListDatabaseTables 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

生成一组 FlowFile,每个文件都包含与数据库连接中表的元数据相对应的属性。提取有关表的元数据后,除非刷新间隔(若已设置)已过或状态被手动清除,否则不会再次提取该元数据。

标签

database、jdbc、list、sql、table

输入要求

FORBIDDEN

支持敏感的动态属性

false

属性

属性

描述

list-db-include-count

是否将表的行数作为 FlowFile 属性包括在内。这会影响性能,因为将为检索到的列表中的每个表生成数据库查询。

list-db-refresh-interval

重置处理器状态从而列出所有当前表之前需要经过的时间。在此间隔内,处理器可以继续运行,但不会重新列出已列出的表。但是,处理器运行时将列出新增/添加的表。值为零表示该状态永远不会自动重置,用户必须手动清除状态。

list-db-tables-catalog

用于列出数据库表的目录的名称。该名称必须与存储在数据库中的目录名称相匹配。如果未设置该属性,则不会使用目录名称来缩小表的搜索范围。如果将该属性设置为空字符串,则将列出没有目录的表。

list-db-tables-db-connection

用于获取数据库连接的控制器服务

list-db-tables-name-pattern

一种用于匹配数据库中表的模式。在此模式中,“%”表示匹配任何包含 0 个或更多字符的子字符串,“_”表示匹配任何一个字符。此模式必须与存储在数据库中的表名相匹配。如果未设置该属性,则将检索所有表。

list-db-tables-schema-pattern

一种用于匹配数据库中架构的模式。在此模式中,“%”表示匹配任何包含 0 个或更多字符的子字符串,“_”表示匹配任何一个字符。此模式必须与存储在数据库中的架构名称相匹配。如果未设置该属性,则不会使用架构名称来缩小表的搜索范围。如果将该属性设置为空字符串,则将列出没有架构的表。

list-db-tables-types

要包含的表类型列表,以逗号分隔。例如,某些数据库支持 TABLE 和 VIEW 类型。如果未设置该属性,则将返回所有类型的表。

record-writer

指定用于创建列表的记录写入器。如果未指定,则将为列出的每个实体创建一个 FlowFile。如果指定了记录写入器,则所有实体都将写入单个 FlowFile,而不是向单个 FlowFiles 添加属性。

状态管理

范围

描述

CLUSTER

执行表列表后,系统将存储查询的时间戳。这允许处理器在下次运行时不必重新列出表。在处理器属性中指定刷新间隔将表明,当处理器检测到间隔已过时,状态将被重置,且表将因此重新列出。该处理器只能在主节点上运行。

关系

名称

描述

success

所有收到的 FlowFiles 都将路由至“success”

写入属性

名称

描述

db.table.name

包含连接中数据库表的名称

db.table.catalog

包含该表所属目录的名称(可能为 Null)

db.table.schema

包含该表所属架构的名称(可能为 Null)

db.table.fullname

包含完全限定的表名(可能包括目录、架构等)

db.table.type

包含连接中数据库表的类型。典型的类型有“TABLE”、“VIEW”、“SYSTEM TABLE”、“GLOBAL TEMPORARY”、“LOCAL TEMPORARY”、“ALIAS”、“SYNONYM”

db.table.remarks

包含连接中数据库表的名称

db.table.count

包含表中的行数

涉及其他组件的用例

对数据库进行全面加载,检索所有表或特定表集中的所有记录。

语言: 中文