ListDatabaseTables 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Description¶

Génère un ensemble de FlowFiles, chacun contenant des attributs correspondant aux métadonnées d’une table à partir d’une connexion à la base de données. Une fois que les métadonnées d’une table ont été extraites, elles ne le seront plus jusqu’à ce que l’intervalle d’actualisation (s’il a été paramétré) se soit écoulé ou jusqu’à ce que l’état ait été manuellement effacé.

Balises¶

database, jdbc, list, sql, table

Exigences en matière d’entrées¶

FORBIDDEN

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
list-db-include-count	Indique s’il faut inclure le nombre de lignes de la table en tant qu’attribut du FlowFile. Cela affecte les performances car une requête de base de données sera générée pour chaque table de la liste récupérée.
list-db-refresh-interval	Temps qui doit s’écouler avant la réinitialisation de l’état du processeur, entraînant ainsi la liste de toutes les tables en cours. Pendant cet intervalle, le processeur peut continuer à fonctionner, mais les tables qui ont déjà été répertoriées ne seront pas une nouvelle fois. Toutefois, des tables nouvelles ou ajoutées seront répertoriées à mesure de l’exécution du processeur. Une valeur de zéro signifie que l’état ne sera jamais réinitialisé automatiquement, l’utilisateur doit effacer l’état manuellement.
list-db-tables-catalog	Nom d’un catalogue à partir duquel les tables de la base de données doivent être répertoriées. Le nom doit correspondre au nom du catalogue tel qu’il est stocké dans la base de données. Si la propriété n’est pas définie, le nom du catalogue ne sera pas utilisé pour restreindre la recherche de tables. Si la propriété est réglée sur une chaîne vide, les tables sans catalogue seront répertoriées.
list-db-tables-db-connection	Le Controller Service qui est utilisé pour obtenir la connexion à la base de données
list-db-tables-name-pattern	Modèle de correspondance entre les tables de la base de données. À l’intérieur d’un modèle, « % » signifie qu’une sous-chaîne de 0 caractère ou plus doit être prise en compte, et « _ » signifie qu’un seul caractère doit être pris en compte. Le modèle doit correspondre au nom de la table tel qu’il est stocké dans la base de données. Si la propriété n’est pas définie, toutes les tables seront récupérées.
list-db-tables-schema-pattern	Un modèle de correspondance entre les schémas de la base de données. À l’intérieur d’un modèle, « % » signifie qu’une sous-chaîne de 0 caractère ou plus doit être prise en compte, et « _ » signifie qu’un seul caractère doit être pris en compte. Le modèle doit correspondre au nom du schéma tel qu’il est stocké dans la base de données. Si la propriété n’est pas définie, le nom du schéma ne sera pas utilisé pour limiter la recherche de tables. Si la propriété est réglée sur une chaîne vide, les tables sans schéma seront répertoriées.
list-db-tables-types	Une liste de types de tables séparées par des virgules à inclure. Par exemple, certaines bases de données prennent en charge les types TABLE et VIEW. Si la propriété n’est pas définie, des tables de tous types seront retournées.
record-writer	Spécifie le Record Writer à utiliser pour créer le listing. Si vous ne le précisez pas, un FlowFile sera créé pour chaque entité inscrite sur la liste. Si le Record Writer est spécifié, toutes les entités seront écrites sur un seul FlowFile au lieu d’ajouter des attributs à des FlowFiles individuels.

Gestion de l’État¶

Champs d’application	Description
CLUSTER	Après avoir effectué un listing des tables, l’horodatage de la requête est stocké. Cela permet au processeur de ne pas réinscrire les tables sur la liste lors de sa prochaine exécution. La spécification de l’intervalle d’actualisation dans les propriétés du processeur indique que lorsque le processeur détecte que l’intervalle s’est écoulé, l’état est réinitialisé et les tables sont réinscrites sur la liste en conséquence. Ce processeur est destiné à être exécuté sur le nœud principal uniquement.

Champs d’application

Description

CLUSTER

Après avoir effectué un listing des tables, l’horodatage de la requête est stocké. Cela permet au processeur de ne pas réinscrire les tables sur la liste lors de sa prochaine exécution. La spécification de l’intervalle d’actualisation dans les propriétés du processeur indique que lorsque le processeur détecte que l’intervalle s’est écoulé, l’état est réinitialisé et les tables sont réinscrites sur la liste en conséquence. Ce processeur est destiné à être exécuté sur le nœud principal uniquement.

Relations¶

Nom	Description
success	Tous les FlowFiles reçus sont routés vers le succès

Écrit les attributs¶

Nom	Description
db.table.name	Contient le nom d’une table de la base de données de la connexion
db.table.catalog	Contient le nom du catalogue auquel la table appartient (peut être nul)
db.table.schema	Contient le nom du schéma auquel la table appartient (peut être nul)
db.table.fullname	Contient le nom de la table entièrement qualifié (avec éventuellement le catalogue, le schéma, etc.)
db.table.type	Contient le type de la table de base de données de la connexion. Les types standards sont « TABLE », « VIEW », « SYSTEM TABLE », « GLOBAL TEMPORARY », « LOCAL TEMPORARY », « ALIAS », « SYNONYM »
db.table.remarks	Contient le nom d’une table de la base de données de la connexion
db.table.count	Contient le nombre de lignes de la table

Cas d’utilisation impliquant d’autres composants¶

Charger complètement une base de données, en récupérant toutes les lignes de toutes les tables ou d’un ensemble spécifique de tables.