Talend et les bases de données SQL

SELECT * FROM table; 

SELECT attr1, attr2, attr3 FROM table; 

SELECT * -- tout sélectionner 
FROM table1 -- dans la table "table1" 

SELECT * /* tout selectionner */ 
FROM table1 /* dans la table "table1" */ 
WHERE 1 = 1 /* exemple en milieu de requete */ 1 

SELECT * FROM table 
               WHERE attribut='valeure' AND attribut2='valeure2';...

Job 32 : connecter Talend à une base de données

Avant de pouvoir effectuer des manipulations de bases de données sur Talend, la première étape consiste à établir une connexion avec la base de données. Pour cela, vous aurez besoin de collecter un ensemble d’informations spécifiques à la base de données..

Méthode

Paramètres de la base de données

Job 33 : importer des tables dans Talend

Après avoir connecté votre base de données à Talend vous aurez besoin d’importer les tables de cette dernière. Pour cela, il est nécessaire de récupérer et vérifier le schéma de la base de données, de sélectionner les tables à importer et surtout de définir le type des données de ces tables.

Méthode

Job 34 : lier un fichier Excel et une BDD

Il est souvent nécessaire de travailler avec différentes sources de données à la fois, comme les bases de données et les fichiers plats par exemple, afin de compléter les données extraites de l’un ou de l’autre et ensuite charger les données intéressantes dans un autre fichier plat, une base de données ou même dans la log.

Méthode

Job 35 : BDD_EXTRACTION

Dans ce job Talend BDD_EXTRACTION, il s’agit d’aborder le premier job concernant la manipulation des bases de données.

Job BDD_EXTRACTION

Le composant tMysqlConnection permet de vérifier que la connexion à une base de données MySQL s’est effectuée sans erreurs.

Paramètres du composant tMysqlConnection

Contextes du composant tMysqlConnection

Le composant tMysqlInput permet de se connecter à une base de données MySQL et d’extraire les données à partir de celle-ci à l’aide d’une requête SQL (Structured Query Language).

Paramètres du composant tMysqlInput

Dans ce composant tMysqlInput, une requête SQL a été mise en place et permet d’importer toutes les colonnes dans une limite de 25 lignes de données depuis la table customer de la base de données MySQL.

Schéma de la table Customer

Le composant tMysqlClose permet de se déconnecter de la base de données.

Paramétrage du composant tMysqlClose

Job 36 : CONNECT_AND_CHARGE

Le job Talend CONNECT_AND_CHARGE permet de se connecter à deux bases de données différentes Oracle et MySQL et d’extraire des données à partir de fichiers, afin de les charger dans les bases de données.

Job CONNECT_AND_CHARGE

Paramètres du composant tOracleConnection_1

Paramètres du composant tMysqlConnection_1

Paramètres du composant tFileInputDelimited_4 (SUPPLIERS)

Paramètres du composant tMysqlOutput_1 (SUPPLIERS)

Paramètres du composant tFileInputDelimited_1  (PRODUCTS)

Paramètres du composant tMysqlOutput_2 (PRODUCTS)

Paramètres du composant tFileInputDelimited_7 (ORDERS)

Paramètres du composant tOracleOutput_1 (ORDERS)

Paramètres du composant tMysqlClose_1

Paramètres du composant tOracleClose_1

Groupe de contextes MySQL

Groupe de contextes Oracle