Discussion :

[HBA_BO]

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.

[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 java :

Sélectionner tout - Visualiser dans une fenêtre à part

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"

[HBA_BO]

Bonjour,

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

Cdt

[HBA_BO]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

[HBA_BO]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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



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

[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.

[HBA_BO]

Bonjour sovo,

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :



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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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

[HBA_BO]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :



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



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...

[HBA_BO]

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 sql :

Sélectionner tout - Visualiser dans une fenêtre à part

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

[Matthieu2000]

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