ListTableNames 2025.5.31.15

Bundle

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

Description

Récupère tous les noms de tables sources et les associe à l’une des configurations possibles :

  • Expression Regexp. Exemple : « (?i)customer.(orders|payments) »

    • Celle-ci permet de faire correspondre les noms sans tenir compte de la casse, de sorte que « CUSTOMER.ORDERS » et « customer.orders » soient tous deux pris en compte. Microsoft SQL Server accepte également les noms pleinement qualifiés, par exemple : (?i)prod.customer.(orders|payments).

  • Liste de noms de tables sources séparés par des virgules, par exemple : « customer.orders, customer.payments ».

    • Celle-ci permet de faire correspondre les noms de tables sources de manière sensible à la casse ; par exemple, « customer.orders » sera pris en compte, mais pas « customer.ORDERS ». Microsoft SQL Server accepte également les noms pleinement qualifiés, tels que « prod1.customer.orders, prod1.customer.payments ».

La configuration est transmise en tant qu’attribut FlowFile. Le nom de la table source est représenté par <schema_name>.<table_name>. Les deux entrées doivent en tenir compte.

Les noms de tables sources correspondants sont transférés vers la relation MATCHED. Le processeur génère un fichier de flux unique avec les tables correspondantes.

Considérations

  • Dans PostgreSQL, les noms des objets de base de données peuvent être sensibles à la casse ou non. Si vous créez une table avec “CREATE TABLE ORDERS(id int non null)”, PostgreSQL stocke le nom en minuscules sous forme d’ordres.

  • Pour renforcer la sensibilité à la casse, mettez le nom de la table entre guillemets, par exemple : “CREATE TABLE « ORDERS » (id int non null)’.

Balises

Exigences en matière d’entrées

REQUIRED

Prend en charge les propriétés dynamiques sensibles

false

Propriétés

Propriété

Description

Connection Pool

Le composant Controller Service qui est utilisé pour obtenir une connexion à la base de données.

Noms de tables sources inclus, séparés par des virgules

Fournissez une liste de tables séparées par des virgules à répliquer, au format <schema_name>.<table_name> (par exemple : customer.orders, customer.payments). Cette liste fonctionne avec l’expression régulière pour trouver des correspondances.

Modèle de table source inclus

Utilisez une expression régulière pour spécifier les noms de table à répliquer, par exemple : customer.(orders|payments). Celle-ci fonctionne avec la liste de tables séparées par des virgules pour faire correspondre des tables.

Relations

Nom

Description

failure

Si un attribut FlowFile ne peut pas être lu ou est incorrect, il sera routé vers cette relation.

matched

Création réussie de FlowFile, avec une liste de tables correspondantes trouvées dans la base de données source.

Écrit les attributs

Nom

Description

base.de.données.version.majeure

La version majeure de la base de données source.