ListTableNames 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Description¶
Récupère tous les noms des tables sources et les fait correspondre à l’une des configurations possibles:- expression regexp, par exemple « (?i)customer.(orders |payments)" - elle fait correspondre les noms sans tenir compte de la casse. Il correspondrait à la fois aux noms des tables sources "CUSTOMER.ORDERS" et " customer.orders ". Le serveur MicrosoftSQL accepte FQN contenant le nom de la base de données, par exemple (?i)prod.customer.(orders| payments)- liste séparée par des virgules des noms des tables sources. par exemple « customer.orders, customer.payments ». Il fait correspondre les noms des tables sources en respectant la casse, c’est-à-dire que la table source « customer.orders » sera transmise à la relation MATCH, mais « customer.ORDERS » ne correspondra pas. Le serveur Microsoft SQL accepte FQN contenant le nom de la base de données, par exemple « prod1.customer.orders, prod1.customer.payments ». La configuration est transmise sous la forme d’un attribut FlowFile. Le nom de la table source est représenté par <schema_name>.<table_name> de sorte que les deux entrées doivent en tenir compte. Les noms de table source correspondants sont transmis à la relation MATCHED. Le processeur génère un FlowFile unique avec les tables correspondantes.Disclaimers- Postgresql permet de définir les noms des objets de la base de données en tenant compte ou non de la casse. Lorsque l’utilisateur crée une table à l’aide de la requête suivante : « CREATE TABLE ORDERS(id int not null) « , Postgresql la stocke en interne en utilisant des lettres minuscules, comme orders. Pour respecter la casse, l’utilisateur doit placer le nom de la table entre guillemets doubles. “CREATE TABLE « ORDERS »(id int notnull)”. Il s’agit d’un aspect important lors de la configuration de la table que l’on souhaite répliquer.
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 |
La liste des tables séparées par des virgules à répliquer. Une table unique doit être formatée comme suit : <schema_name>.<ntable_name> par exemple : client.commandes, client.paiements. Celle-ci est combinée à l’expression régulière pour inclure toute table correspondante. |
Modèle de table source inclus |
Expression régulière pour spécifier les noms des tables à répliquer, par exemple client.(commandes|paiements). Elle est combinée à la liste séparée par des virgules pour inclure toute table correspondante. |
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. |