Mettre des paramettres de context dans une clause where d'un job qui extrait une table dans un fichier csv.

Version imprimable

12/07/2019, 15h20
HBA_BO

Mettre des paramettres de context dans une clause where d'un job qui extrait une table dans un fichier csv.

j'ai 3 paramètres défini dans un contexte talend. une date, un statut et un numéro d'établissement. Je voudrait appliquer ce filtre en fonction de l'établissement saisi dans le fichier de paramétrage des contexte. Si etablissment = E1 (exemple), alors applique filtre sur date et statut, si <> E1, il extrait toute la table.

Je voudrais que ça soit le même job pour tous les établissement avec certain qui souhaite n'extraire que certaine donnée...je voudrai que ça soit le même job dont la clause where du sql du job soit paramétrable à la demande.

Merci pour votre aide.
12/07/2019, 18h59
supergeoffrey
Ta requete est une chaîne de caractère java, tu peux utiliser la concaténation à intérieurement.

Il faut juste faire attention que la fin de ligne soit bien dans des guillemets car Talend les remplaces par des \n.

avec ce genre d'expression tu pourras surement faire ton job
Code:

1 2 3 4 5 6 "Select ... From ... Where " + ! "E1".equals(context.status) ? " status = " + context.status + " AND date < " + TalendDate.formatDate("yyyyMMdd",context.date) : " 1 < 2"
15/07/2019, 09h15
HBA_BO

Bonjour,

Merci pour le proposition de solution. Je vais la tester et revenir vers toi.

Cdt

1 pièce(s) jointe(s)

je viens de faire le test mais j'ai l'impression que ma requête n'est pas bonne... requête ci-dessous : est ce qu'il manque quelque chose ou est ce la requête est mal codée?
-------------
variables de contexte :

Code:

1
2
3
logipren2_filtre_date                       order_set.ordered_date          2018-12-01
logipren2_filtre_PrescriptionValid          order_set.history_status        VALIDATED
logipren2_etablissement                     integer                         1   (variable par défaut : mais imaginons que c'est l'établissement dont les données sont filtrées)

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
"SELECT 
  common_order_history.id, 
  common_order_history.label, 
  common_order_history.order_control, 
  common_order_history.order_status, 
  common_order_history.order_validity_status, 
  common_order_history.start_date, 
  common_order_history.start_time, 
  common_order_history.end_date, 
  common_order_history.end_time, 
  common_order_history.urgent, 
  common_order_history.warning, 
  common_order_history.common_order_id, 
  common_order_history.order_set_id, 
  common_order_history.common_order_group_history_id, 
  common_order_history.version, 
  common_order_history.created_date, 
  common_order_history.last_modified_date
FROM 
common_order_history
INNER JOIN order_set ON common_order_history.order_set_id = order_set.id
INNER JOIN patient ON patient.id = order_set.patient_id
WHERE 
" + ! "logipren2_etablissement".equals(context.logipren2_filtre_PrescriptionValide) ? "
order_set.history_status = " + context.logipren2_filtre_PrescriptionValide + " AND order_set.ordered_date >= " + TalendDate.formatDate("yyyyMMdd",context.logipren2_filtre_date)  : "
1 > 2"

voila le message d'erreur :
Pièce jointe 491069

2 pièce(s) jointe(s)

je viens de faire qq modification mais ça ne fonctionne toujours pas....
La requête sql :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
"SELECT 
  common_order_history.id, 
  common_order_history.label, 
  common_order_history.order_control, 
  common_order_history.order_status, 
  common_order_history.order_validity_status, 
  common_order_history.start_date, 
  common_order_history.start_time, 
  common_order_history.end_date, 
  common_order_history.end_time, 
  common_order_history.urgent, 
  common_order_history.warning, 
  common_order_history.common_order_id, 
  common_order_history.order_set_id, 
  common_order_history.common_order_group_history_id, 
  common_order_history.version, 
  common_order_history.created_date, 
  common_order_history.last_modified_date
FROM 
common_order_history
INNER JOIN order_set ON common_order_history.order_set_id = order_set.id
INNER JOIN patient ON patient.id = order_set.patient_id
WHERE 
" + context.logipren2_etablissement_filtre == context.logipren2_etablissement ? "
order_set.history_status = " + context.logipren2_filtre_PrescriptionValide + " AND order_set.ordered_date >= " + TalendDate.formatDate("yyyyMMdd",context.logipren2_filtre_date)  : "
1 > 2"

les contextes en pièces jointes avec nouveau message d'erreur
Pièce jointe 491122
Pièce jointe 491124

Si tu as une idée de la bonne syntaxe ça serait super....

15/07/2019, 14h12
sovo

Bonjour HBA_BO,

est ce je n'arrive pas a comprendre ce que tu veux faire.

Est ce que tu peux écrire ta requête directement ?? CAD avec les vrai valeurs, sans utiliser les variables de contexte.

1 pièce(s) jointe(s)

Bonjour sovo,

voila ce que je veux faire dans le composant de la table source....
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 "SELECT common_order_history.id, common_order_history.label, common_order_history.order_control, common_order_history.order_status, common_order_history.order_validity_status, common_order_history.start_date, common_order_history.start_time, common_order_history.end_date, common_order_history.end_time, common_order_history.urgent, common_order_history.warning, common_order_history.common_order_id, common_order_history.order_set_id, common_order_history.common_order_group_history_id, common_order_history.version, common_order_history.created_date, common_order_history.last_modified_date FROM logipren_2.common_order_history INNER JOIN extraction.temp_order ON common_order_history.order_set_id = temp_order.id INNER JOIN logipren_2.patient ON patient.id = temp_order.patient_id WHERE temp_order.etablissement = " + ! "temp_order.etablissement.equals (context.logipren2_etablissement)? " temp_order.history_status = '" + context.logipren2_filtre_PrescriptionValide + "' and temp_order.ordered_date >= " + TalendDate.formatDate("yyyyMMdd",context.logipren2_filtre_date) : " 1>2"
Erreur produite par la requête sous talend :
Pièce jointe 491264

je voudrai variabiliser les contextes pour mutualiser les jobs dont le but est de faire des extractions de tables vers des fichiers csv. En fonction de chaque établissement, certains souhaitent qu'on extrait des données à partir d'une date donnée et à un status donné. D'ou ma question de créer 3 contextes qui sont les suivants :
Code:

1 2 3 logipren2_filtre_date order_set.ordered_date 2018-12-01 logipren2_filtre_PrescriptionValid order_set.history_status VALIDATED logipren2_etablissement integer 1 (variable par défaut : mais imaginons que c'est l'établissement dont les données sont filtrées)
il faut qu'à partir de ces contextes je puisse activer ou pas le filtre dans la clause WHERE en fonction des établissements qui demanderont d'extraire des données qu'à partir d'une date données et d'un statut donné. Ces contextes de filtrage de données, je pourrai les modifier une fois dans le fichiers de propriété des contextes une seule fois et non dans tous les jobs...

dans la requête fourni ci-dessus, j'ai encore des erreurs types java que je n'arrive pas à résoudre...

Est ce que mon explication t'éclaire sur mon besoin?
Merci pour ton aide

2 pièce(s) jointe(s)

je viens de résoudre partiellement mon problème de requête.... ci dessous la requête ou le code java généré par talend ne détecte pas d'erreur au niveau de la requête
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 "SELECT logipren_2.common_order_history.id, logipren_2.common_order_history.label, logipren_2.common_order_history.order_control, logipren_2.common_order_history.order_status, logipren_2.common_order_history.order_validity_status, logipren_2.common_order_history.start_date, logipren_2.common_order_history.start_time, logipren_2.common_order_history.end_date, logipren_2.common_order_history.end_time, logipren_2. common_order_history.urgent, logipren_2.common_order_history.warning, logipren_2.common_order_history.common_order_id, logipren_2.common_order_history.order_set_id, logipren_2.common_order_history.common_order_group_history_id, logipren_2.common_order_history.version, logipren_2.common_order_history.created_date, logipren_2.common_order_history.last_modified_date FROM logipren_2.common_order_history INNER JOIN extraction.temp_order ON logipren_2.common_order_history.order_set_id = extraction.temp_order.id INNER JOIN logipren_2.patient ON logipren_2.patient.id = extraction.temp_order.patient_id WHERE extraction.temp_order.etablissement = " + ! temp_order.etablissement.equals(context.logipren2_etablissement) ? "extraction.temp_order.history_status = ' " + context.logipren2_filtre_PrescriptionValide + " ' and extraction.temp_order.ordered_date >= " + TalendDate.formatDate("yyyyMMdd",context.logipren2_filtre_date) :" 1>=2"
Par contre maintenant le soucis, il me met le message erreur suivant :

Pièce jointe 491298

et dans le code généré par talend, c'est une ligne vide qu'il souligne...

Pièce jointe 491304

j'ai l'impression qu'il ne trouve pas la table temp_order ...j'utilise des jointure avec table d'un schéma 1 avec la table temp_order qui est dans un autre schéma....
serait ce un problème de user talend qui n'arrive pas à lire dans les deux schéma? c'est une idée...
Merci pour votre aide...

Bonjour,

j'ai enfin résolu mon soucis en utilisant un case when... voici la requête qui fonctionne dans mon cas qui posait problème

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
"SELECT 
 logipren_2.common_order_history.id, 
 logipren_2.common_order_history.label, 
 logipren_2.common_order_history.order_control, 
 logipren_2.common_order_history.order_status, 
 logipren_2.common_order_history.order_validity_status, 
 logipren_2.common_order_history.start_date, 
 logipren_2.common_order_history.start_time, 
 logipren_2.common_order_history.end_date, 
 logipren_2.common_order_history.end_time, 
 logipren_2. common_order_history.urgent, 
 logipren_2.common_order_history.warning, 
 logipren_2.common_order_history.common_order_id, 
 logipren_2.common_order_history.order_set_id, 
 logipren_2.common_order_history.common_order_group_history_id, 
 logipren_2.common_order_history.version, 
 logipren_2.common_order_history.created_date, 
 logipren_2.common_order_history.last_modified_date
FROM 
logipren_2.common_order_history
INNER JOIN extraction.temp_order ON common_order_history.order_set_id = temp_order.id
INNER JOIN logipren_2.patient ON patient.id = temp_order.patient_id
WHERE 
case when temp_order.etablissement != " + context.logipren2_etablissement + " then 2  else temp_order.history_status = '"+ context.logipren2_filtre_PrescriptionValide + "' 
and temp_order.ordered_date >=" + TalendDate.formatDate("yyyyMMdd",context.logipren2_filtre_date) + " end"

ça pourra servir à d'autre...
Merci à bientôt

07/08/2019, 14h22
Matthieu2000

et surtout le ! dans la chaîne de caractères