Edit C:\galaxie\jobs\GALAXIE__JOBs\backup\GALAXIE__PCKG\src\main\java\fil_galaxie\galaxie__pckg_0_1\GALAXIE__PCKG.java
// ============================================================================ // // Copyright (c) 2006-2015, Talend Inc. // // This source code has been automatically generated by_Talend Open Studio for Data Integration // / Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package fil_galaxie.galaxie__pckg_0_1; import routines.CustomSecurity; import routines.DataOperation; import routines.TalendDataGenerator; import routines.Numeric; import routines.CustomString; import routines.CustomCode; import routines.Mathematical; import routines.CustomMessage; import routines.Relational; import routines.TalendDate; import routines.TalendString; import routines.StringHandling; import routines.system.*; import routines.system.api.*; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.math.BigDecimal; import java.io.ByteArrayOutputStream; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.ObjectOutputStream; import java.io.ObjectInputStream; import java.io.IOException; import java.util.Comparator; //the import part of tJava_1 //import java.util.List; //the import part of tJava_4 //import java.util.List; //the import part of tJava_2 //import java.util.List; //the import part of tJava_3 //import java.util.List; @SuppressWarnings("unused") /** * Job: GALAXIE__PCKG Purpose: <br> * Description: Point d'entrée principal de la chaine d'alimentation <br> * @author test@talend.com * @version 6.1.1.20151214_1327 * @status */ public class GALAXIE__PCKG implements TalendJob { public final Object obj = new Object(); // for transmiting parameters purpose private Object valueObject = null; public Object getValueObject() { return this.valueObject; } public void setValueObject(Object valueObject) { this.valueObject = valueObject; } private final static String defaultCharset = java.nio.charset.Charset .defaultCharset().name(); private final static String utf8Charset = "UTF-8"; // create and load default properties private java.util.Properties defaultProps = new java.util.Properties(); // create application properties with default public class ContextProperties extends java.util.Properties { private static final long serialVersionUID = 1L; public ContextProperties(java.util.Properties properties) { super(properties); } public ContextProperties() { super(); } public void synchronizeContext() { if (CTX_EMAIL_Destinataire != null) { this.setProperty("CTX_EMAIL_Destinataire", CTX_EMAIL_Destinataire.toString()); } if (CTX_EMAIL_Destinataire_copie != null) { this.setProperty("CTX_EMAIL_Destinataire_copie", CTX_EMAIL_Destinataire_copie.toString()); } if (CTX_EMAIL_Destinataire_copie_cachee != null) { this.setProperty("CTX_EMAIL_Destinataire_copie_cachee", CTX_EMAIL_Destinataire_copie_cachee.toString()); } if (CTX_EMAIL_Emetteur != null) { this.setProperty("CTX_EMAIL_Emetteur", CTX_EMAIL_Emetteur.toString()); } if (CTX_EMAIL_Envoi_active != null) { this.setProperty("CTX_EMAIL_Envoi_active", CTX_EMAIL_Envoi_active.toString()); } if (CTX_EMAIL_Login != null) { this.setProperty("CTX_EMAIL_Login", CTX_EMAIL_Login.toString()); } if (CTX_EMAIL_Password != null) { this.setProperty("CTX_EMAIL_Password", CTX_EMAIL_Password.toString()); } if (CTX_EMAIL_Serveur_port != null) { this.setProperty("CTX_EMAIL_Serveur_port", CTX_EMAIL_Serveur_port.toString()); } if (CTX_EMAIL_Serveur_SMTP != null) { this.setProperty("CTX_EMAIL_Serveur_SMTP", CTX_EMAIL_Serveur_SMTP.toString()); } if (CTX_PGS_COMPTAFIL_Database != null) { this.setProperty("CTX_PGS_COMPTAFIL_Database", CTX_PGS_COMPTAFIL_Database.toString()); } if (CTX_PGS_COMPTAFIL_Login != null) { this.setProperty("CTX_PGS_COMPTAFIL_Login", CTX_PGS_COMPTAFIL_Login.toString()); } if (CTX_PGS_COMPTAFIL_Password != null) { this.setProperty("CTX_PGS_COMPTAFIL_Password", CTX_PGS_COMPTAFIL_Password.toString()); } if (CTX_PGS_COMPTAFIL_Port != null) { this.setProperty("CTX_PGS_COMPTAFIL_Port", CTX_PGS_COMPTAFIL_Port.toString()); } if (CTX_PGS_COMPTAFIL_Schema != null) { this.setProperty("CTX_PGS_COMPTAFIL_Schema", CTX_PGS_COMPTAFIL_Schema.toString()); } if (CTX_PGS_COMPTAFIL_Server != null) { this.setProperty("CTX_PGS_COMPTAFIL_Server", CTX_PGS_COMPTAFIL_Server.toString()); } if (CTX_PGS_COMPTALIS_Database != null) { this.setProperty("CTX_PGS_COMPTALIS_Database", CTX_PGS_COMPTALIS_Database.toString()); } if (CTX_PGS_COMPTALIS_Login != null) { this.setProperty("CTX_PGS_COMPTALIS_Login", CTX_PGS_COMPTALIS_Login.toString()); } if (CTX_PGS_COMPTALIS_Password != null) { this.setProperty("CTX_PGS_COMPTALIS_Password", CTX_PGS_COMPTALIS_Password.toString()); } if (CTX_PGS_COMPTALIS_Port != null) { this.setProperty("CTX_PGS_COMPTALIS_Port", CTX_PGS_COMPTALIS_Port.toString()); } if (CTX_PGS_COMPTALIS_Schema != null) { this.setProperty("CTX_PGS_COMPTALIS_Schema", CTX_PGS_COMPTALIS_Schema.toString()); } if (CTX_PGS_COMPTALIS_Server != null) { this.setProperty("CTX_PGS_COMPTALIS_Server", CTX_PGS_COMPTALIS_Server.toString()); } if (CTX_PGS_CRM_CommitInterval != null) { this.setProperty("CTX_PGS_CRM_CommitInterval", CTX_PGS_CRM_CommitInterval.toString()); } if (CTX_PGS_CRM_Database != null) { this.setProperty("CTX_PGS_CRM_Database", CTX_PGS_CRM_Database.toString()); } if (CTX_PGS_CRM_Login != null) { this.setProperty("CTX_PGS_CRM_Login", CTX_PGS_CRM_Login.toString()); } if (CTX_PGS_CRM_Password != null) { this.setProperty("CTX_PGS_CRM_Password", CTX_PGS_CRM_Password.toString()); } if (CTX_PGS_CRM_Port != null) { this.setProperty("CTX_PGS_CRM_Port", CTX_PGS_CRM_Port.toString()); } if (CTX_PGS_CRM_Schema != null) { this.setProperty("CTX_PGS_CRM_Schema", CTX_PGS_CRM_Schema.toString()); } if (CTX_PGS_CRM_Server != null) { this.setProperty("CTX_PGS_CRM_Server", CTX_PGS_CRM_Server.toString()); } if (CTX_PGS_DSA_CommitInterval != null) { this.setProperty("CTX_PGS_DSA_CommitInterval", CTX_PGS_DSA_CommitInterval.toString()); } if (CTX_PGS_DSA_Database != null) { this.setProperty("CTX_PGS_DSA_Database", CTX_PGS_DSA_Database.toString()); } if (CTX_PGS_DSA_Login != null) { this.setProperty("CTX_PGS_DSA_Login", CTX_PGS_DSA_Login.toString()); } if (CTX_PGS_DSA_Password != null) { this.setProperty("CTX_PGS_DSA_Password", CTX_PGS_DSA_Password.toString()); } if (CTX_PGS_DSA_Port != null) { this.setProperty("CTX_PGS_DSA_Port", CTX_PGS_DSA_Port.toString()); } if (CTX_PGS_DSA_Schema != null) { this.setProperty("CTX_PGS_DSA_Schema", CTX_PGS_DSA_Schema.toString()); } if (CTX_PGS_DSA_Server != null) { this.setProperty("CTX_PGS_DSA_Server", CTX_PGS_DSA_Server.toString()); } if (CTX_PGS_ODS_CommitInterval != null) { this.setProperty("CTX_PGS_ODS_CommitInterval", CTX_PGS_ODS_CommitInterval.toString()); } if (CTX_PGS_ODS_Database != null) { this.setProperty("CTX_PGS_ODS_Database", CTX_PGS_ODS_Database.toString()); } if (CTX_PGS_ODS_Login != null) { this.setProperty("CTX_PGS_ODS_Login", CTX_PGS_ODS_Login.toString()); } if (CTX_PGS_ODS_Password != null) { this.setProperty("CTX_PGS_ODS_Password", CTX_PGS_ODS_Password.toString()); } if (CTX_PGS_ODS_Port != null) { this.setProperty("CTX_PGS_ODS_Port", CTX_PGS_ODS_Port.toString()); } if (CTX_PGS_ODS_Schema != null) { this.setProperty("CTX_PGS_ODS_Schema", CTX_PGS_ODS_Schema.toString()); } if (CTX_PGS_ODS_Server != null) { this.setProperty("CTX_PGS_ODS_Server", CTX_PGS_ODS_Server.toString()); } if (CTX_PRM_ArchiveLogs != null) { this.setProperty("CTX_PRM_ArchiveLogs", CTX_PRM_ArchiveLogs.toString()); } if (CTX_PRM_CEV != null) { this.setProperty("CTX_PRM_CEV", CTX_PRM_CEV.toString()); } if (CTX_PRM_CodeRetour != null) { this.setProperty("CTX_PRM_CodeRetour", CTX_PRM_CodeRetour.toString()); } if (CTX_PRM_DateDebut != null) { String pattern_CTX_PRM_DateDebut = "yyyy-MM-dd HH:mm:ss"; String value_CTX_PRM_DateDebut = ""; String[] parts_CTX_PRM_DateDebut = value_CTX_PRM_DateDebut .split(";"); if (parts_CTX_PRM_DateDebut.length > 1) { pattern_CTX_PRM_DateDebut = parts_CTX_PRM_DateDebut[0]; this.setProperty( "CTX_PRM_DateDebut", pattern_CTX_PRM_DateDebut + ";" + FormatterUtils.format_Date( CTX_PRM_DateDebut, pattern_CTX_PRM_DateDebut)); } else { this.setProperty("CTX_PRM_DateDebut", FormatterUtils .format_Date(CTX_PRM_DateDebut, pattern_CTX_PRM_DateDebut)); } } if (CTX_PRM_DateFin != null) { String pattern_CTX_PRM_DateFin = "yyyy-MM-dd HH:mm:ss"; String value_CTX_PRM_DateFin = ""; String[] parts_CTX_PRM_DateFin = value_CTX_PRM_DateFin .split(";"); if (parts_CTX_PRM_DateFin.length > 1) { pattern_CTX_PRM_DateFin = parts_CTX_PRM_DateFin[0]; this.setProperty( "CTX_PRM_DateFin", pattern_CTX_PRM_DateFin + ";" + FormatterUtils.format_Date( CTX_PRM_DateFin, pattern_CTX_PRM_DateFin)); } else { this.setProperty("CTX_PRM_DateFin", FormatterUtils .format_Date(CTX_PRM_DateFin, pattern_CTX_PRM_DateFin)); } } if (CTX_PRM_Edeal_ASSO_FIL != null) { this.setProperty("CTX_PRM_Edeal_ASSO_FIL", CTX_PRM_Edeal_ASSO_FIL.toString()); } if (CTX_PRM_Edeal_ASSO_LIS != null) { this.setProperty("CTX_PRM_Edeal_ASSO_LIS", CTX_PRM_Edeal_ASSO_LIS.toString()); } if (CTX_PRM_EdealBascounter != null) { this.setProperty("CTX_PRM_EdealBascounter", CTX_PRM_EdealBascounter.toString()); } if (CTX_PRM_EdealBasid != null) { this.setProperty("CTX_PRM_EdealBasid", CTX_PRM_EdealBasid.toString()); } if (CTX_PRM_EdealCodeActor != null) { this.setProperty("CTX_PRM_EdealCodeActor", CTX_PRM_EdealCodeActor.toString()); } if (CTX_PRM_EdealIdActor != null) { this.setProperty("CTX_PRM_EdealIdActor", CTX_PRM_EdealIdActor.toString()); } if (CTX_PRM_EdealLicence != null) { this.setProperty("CTX_PRM_EdealLicence", CTX_PRM_EdealLicence.toString()); } if (CTX_PRM_EncryptedPassword != null) { this.setProperty("CTX_PRM_EncryptedPassword", CTX_PRM_EncryptedPassword.toString()); } if (CTX_PRM_Environnement != null) { this.setProperty("CTX_PRM_Environnement", CTX_PRM_Environnement.toString()); } if (CTX_PRM_EQUALITING != null) { this.setProperty("CTX_PRM_EQUALITING", CTX_PRM_EQUALITING.toString()); } if (CTX_PRM_Exec_RES != null) { this.setProperty("CTX_PRM_Exec_RES", CTX_PRM_Exec_RES.toString()); } if (CTX_PRM_FichierConfiguration != null) { this.setProperty("CTX_PRM_FichierConfiguration", CTX_PRM_FichierConfiguration.toString()); } if (CTX_PRM_FichierLog != null) { this.setProperty("CTX_PRM_FichierLog", CTX_PRM_FichierLog.toString()); } if (CTX_PRM_FichierLogs != null) { this.setProperty("CTX_PRM_FichierLogs", CTX_PRM_FichierLogs.toString()); } if (CTX_PRM_FichierMetrique != null) { this.setProperty("CTX_PRM_FichierMetrique", CTX_PRM_FichierMetrique.toString()); } if (CTX_PRM_FichierStatistique != null) { this.setProperty("CTX_PRM_FichierStatistique", CTX_PRM_FichierStatistique.toString()); } if (CTX_PRM_fileEncodage != null) { this.setProperty("CTX_PRM_fileEncodage", CTX_PRM_fileEncodage.toString()); } if (CTX_PRM_fileName != null) { this.setProperty("CTX_PRM_fileName", CTX_PRM_fileName.toString()); } if (CTX_PRM_IdAudit != null) { this.setProperty("CTX_PRM_IdAudit", CTX_PRM_IdAudit.toString()); } if (CTX_PRM_IdEtape != null) { this.setProperty("CTX_PRM_IdEtape", CTX_PRM_IdEtape.toString()); } if (CTX_PRM_IdEtapeDebut != null) { this.setProperty("CTX_PRM_IdEtapeDebut", CTX_PRM_IdEtapeDebut.toString()); } if (CTX_PRM_IdEtapeFin != null) { this.setProperty("CTX_PRM_IdEtapeFin", CTX_PRM_IdEtapeFin.toString()); } if (CTX_PRM_listOfTableToDisableConstraints != null) { this.setProperty("CTX_PRM_listOfTableToDisableConstraints", CTX_PRM_listOfTableToDisableConstraints.toString()); } if (CTX_PRM_LKPCursorSize != null) { this.setProperty("CTX_PRM_LKPCursorSize", CTX_PRM_LKPCursorSize.toString()); } if (CTX_PRM_NomAppliSource != null) { this.setProperty("CTX_PRM_NomAppliSource", CTX_PRM_NomAppliSource.toString()); } if (CTX_PRM_NomSource != null) { this.setProperty("CTX_PRM_NomSource", CTX_PRM_NomSource.toString()); } if (CTX_PRM_OLAKALA_ERROR != null) { this.setProperty("CTX_PRM_OLAKALA_ERROR", CTX_PRM_OLAKALA_ERROR.toString()); } if (CTX_PRM_OLAKALA_FINISHED != null) { this.setProperty("CTX_PRM_OLAKALA_FINISHED", CTX_PRM_OLAKALA_FINISHED.toString()); } if (CTX_PRM_OLAKALA_PROGRESS != null) { this.setProperty("CTX_PRM_OLAKALA_PROGRESS", CTX_PRM_OLAKALA_PROGRESS.toString()); } if (CTX_PRM_ProfondeurRetentionLogs != null) { this.setProperty("CTX_PRM_ProfondeurRetentionLogs", CTX_PRM_ProfondeurRetentionLogs.toString()); } if (CTX_PRM_ProfondeurRetentionRejets != null) { this.setProperty("CTX_PRM_ProfondeurRetentionRejets", CTX_PRM_ProfondeurRetentionRejets.toString()); } if (CTX_PRM_RepertoireConf != null) { this.setProperty("CTX_PRM_RepertoireConf", CTX_PRM_RepertoireConf.toString()); } if (CTX_PRM_RepertoireData != null) { this.setProperty("CTX_PRM_RepertoireData", CTX_PRM_RepertoireData.toString()); } if (CTX_PRM_RepertoireDataArchive != null) { this.setProperty("CTX_PRM_RepertoireDataArchive", CTX_PRM_RepertoireDataArchive.toString()); } if (CTX_PRM_RepertoireDataIn != null) { this.setProperty("CTX_PRM_RepertoireDataIn", CTX_PRM_RepertoireDataIn.toString()); } if (CTX_PRM_RepertoireDataOut != null) { this.setProperty("CTX_PRM_RepertoireDataOut", CTX_PRM_RepertoireDataOut.toString()); } if (CTX_PRM_RepertoireLog != null) { this.setProperty("CTX_PRM_RepertoireLog", CTX_PRM_RepertoireLog.toString()); } if (CTX_PRM_RepertoireRacine != null) { this.setProperty("CTX_PRM_RepertoireRacine", CTX_PRM_RepertoireRacine.toString()); } if (CTX_PRM_RepertoireSql != null) { this.setProperty("CTX_PRM_RepertoireSql", CTX_PRM_RepertoireSql.toString()); } if (CTX_PRM_RepertoireTmp != null) { this.setProperty("CTX_PRM_RepertoireTmp", CTX_PRM_RepertoireTmp.toString()); } if (CTX_PRM_RESERVIT != null) { this.setProperty("CTX_PRM_RESERVIT", CTX_PRM_RESERVIT.toString()); } if (CTX_PRM_SoucheVersion != null) { this.setProperty("CTX_PRM_SoucheVersion", CTX_PRM_SoucheVersion.toString()); } if (CTX_PRM_SRCCursorSize != null) { this.setProperty("CTX_PRM_SRCCursorSize", CTX_PRM_SRCCursorSize.toString()); } if (CTX_PRM_TalendRootPackage != null) { this.setProperty("CTX_PRM_TalendRootPackage", CTX_PRM_TalendRootPackage.toString()); } if (CTX_PRM_TalendRootPid != null) { this.setProperty("CTX_PRM_TalendRootPid", CTX_PRM_TalendRootPid.toString()); } } public String CTX_EMAIL_Destinataire; public String getCTX_EMAIL_Destinataire() { return this.CTX_EMAIL_Destinataire; } public String CTX_EMAIL_Destinataire_copie; public String getCTX_EMAIL_Destinataire_copie() { return this.CTX_EMAIL_Destinataire_copie; } public String CTX_EMAIL_Destinataire_copie_cachee; public String getCTX_EMAIL_Destinataire_copie_cachee() { return this.CTX_EMAIL_Destinataire_copie_cachee; } public String CTX_EMAIL_Emetteur; public String getCTX_EMAIL_Emetteur() { return this.CTX_EMAIL_Emetteur; } public Integer CTX_EMAIL_Envoi_active; public Integer getCTX_EMAIL_Envoi_active() { return this.CTX_EMAIL_Envoi_active; } public String CTX_EMAIL_Login; public String getCTX_EMAIL_Login() { return this.CTX_EMAIL_Login; } public java.lang.String CTX_EMAIL_Password; public java.lang.String getCTX_EMAIL_Password() { return this.CTX_EMAIL_Password; } public String CTX_EMAIL_Serveur_port; public String getCTX_EMAIL_Serveur_port() { return this.CTX_EMAIL_Serveur_port; } public String CTX_EMAIL_Serveur_SMTP; public String getCTX_EMAIL_Serveur_SMTP() { return this.CTX_EMAIL_Serveur_SMTP; } public String CTX_PGS_COMPTAFIL_Database; public String getCTX_PGS_COMPTAFIL_Database() { return this.CTX_PGS_COMPTAFIL_Database; } public String CTX_PGS_COMPTAFIL_Login; public String getCTX_PGS_COMPTAFIL_Login() { return this.CTX_PGS_COMPTAFIL_Login; } public java.lang.String CTX_PGS_COMPTAFIL_Password; public java.lang.String getCTX_PGS_COMPTAFIL_Password() { return this.CTX_PGS_COMPTAFIL_Password; } public String CTX_PGS_COMPTAFIL_Port; public String getCTX_PGS_COMPTAFIL_Port() { return this.CTX_PGS_COMPTAFIL_Port; } public String CTX_PGS_COMPTAFIL_Schema; public String getCTX_PGS_COMPTAFIL_Schema() { return this.CTX_PGS_COMPTAFIL_Schema; } public String CTX_PGS_COMPTAFIL_Server; public String getCTX_PGS_COMPTAFIL_Server() { return this.CTX_PGS_COMPTAFIL_Server; } public String CTX_PGS_COMPTALIS_Database; public String getCTX_PGS_COMPTALIS_Database() { return this.CTX_PGS_COMPTALIS_Database; } public String CTX_PGS_COMPTALIS_Login; public String getCTX_PGS_COMPTALIS_Login() { return this.CTX_PGS_COMPTALIS_Login; } public java.lang.String CTX_PGS_COMPTALIS_Password; public java.lang.String getCTX_PGS_COMPTALIS_Password() { return this.CTX_PGS_COMPTALIS_Password; } public String CTX_PGS_COMPTALIS_Port; public String getCTX_PGS_COMPTALIS_Port() { return this.CTX_PGS_COMPTALIS_Port; } public String CTX_PGS_COMPTALIS_Schema; public String getCTX_PGS_COMPTALIS_Schema() { return this.CTX_PGS_COMPTALIS_Schema; } public String CTX_PGS_COMPTALIS_Server; public String getCTX_PGS_COMPTALIS_Server() { return this.CTX_PGS_COMPTALIS_Server; } public Integer CTX_PGS_CRM_CommitInterval; public Integer getCTX_PGS_CRM_CommitInterval() { return this.CTX_PGS_CRM_CommitInterval; } public String CTX_PGS_CRM_Database; public String getCTX_PGS_CRM_Database() { return this.CTX_PGS_CRM_Database; } public String CTX_PGS_CRM_Login; public String getCTX_PGS_CRM_Login() { return this.CTX_PGS_CRM_Login; } public java.lang.String CTX_PGS_CRM_Password; public java.lang.String getCTX_PGS_CRM_Password() { return this.CTX_PGS_CRM_Password; } public String CTX_PGS_CRM_Port; public String getCTX_PGS_CRM_Port() { return this.CTX_PGS_CRM_Port; } public String CTX_PGS_CRM_Schema; public String getCTX_PGS_CRM_Schema() { return this.CTX_PGS_CRM_Schema; } public String CTX_PGS_CRM_Server; public String getCTX_PGS_CRM_Server() { return this.CTX_PGS_CRM_Server; } public Integer CTX_PGS_DSA_CommitInterval; public Integer getCTX_PGS_DSA_CommitInterval() { return this.CTX_PGS_DSA_CommitInterval; } public String CTX_PGS_DSA_Database; public String getCTX_PGS_DSA_Database() { return this.CTX_PGS_DSA_Database; } public String CTX_PGS_DSA_Login; public String getCTX_PGS_DSA_Login() { return this.CTX_PGS_DSA_Login; } public java.lang.String CTX_PGS_DSA_Password; public java.lang.String getCTX_PGS_DSA_Password() { return this.CTX_PGS_DSA_Password; } public String CTX_PGS_DSA_Port; public String getCTX_PGS_DSA_Port() { return this.CTX_PGS_DSA_Port; } public String CTX_PGS_DSA_Schema; public String getCTX_PGS_DSA_Schema() { return this.CTX_PGS_DSA_Schema; } public String CTX_PGS_DSA_Server; public String getCTX_PGS_DSA_Server() { return this.CTX_PGS_DSA_Server; } public Integer CTX_PGS_ODS_CommitInterval; public Integer getCTX_PGS_ODS_CommitInterval() { return this.CTX_PGS_ODS_CommitInterval; } public String CTX_PGS_ODS_Database; public String getCTX_PGS_ODS_Database() { return this.CTX_PGS_ODS_Database; } public String CTX_PGS_ODS_Login; public String getCTX_PGS_ODS_Login() { return this.CTX_PGS_ODS_Login; } public java.lang.String CTX_PGS_ODS_Password; public java.lang.String getCTX_PGS_ODS_Password() { return this.CTX_PGS_ODS_Password; } public String CTX_PGS_ODS_Port; public String getCTX_PGS_ODS_Port() { return this.CTX_PGS_ODS_Port; } public String CTX_PGS_ODS_Schema; public String getCTX_PGS_ODS_Schema() { return this.CTX_PGS_ODS_Schema; } public String CTX_PGS_ODS_Server; public String getCTX_PGS_ODS_Server() { return this.CTX_PGS_ODS_Server; } public String CTX_PRM_ArchiveLogs; public String getCTX_PRM_ArchiveLogs() { return this.CTX_PRM_ArchiveLogs; } public String CTX_PRM_CEV; public String getCTX_PRM_CEV() { return this.CTX_PRM_CEV; } public Integer CTX_PRM_CodeRetour; public Integer getCTX_PRM_CodeRetour() { return this.CTX_PRM_CodeRetour; } public java.util.Date CTX_PRM_DateDebut; public java.util.Date getCTX_PRM_DateDebut() { return this.CTX_PRM_DateDebut; } public java.util.Date CTX_PRM_DateFin; public java.util.Date getCTX_PRM_DateFin() { return this.CTX_PRM_DateFin; } public String CTX_PRM_Edeal_ASSO_FIL; public String getCTX_PRM_Edeal_ASSO_FIL() { return this.CTX_PRM_Edeal_ASSO_FIL; } public String CTX_PRM_Edeal_ASSO_LIS; public String getCTX_PRM_Edeal_ASSO_LIS() { return this.CTX_PRM_Edeal_ASSO_LIS; } public String CTX_PRM_EdealBascounter; public String getCTX_PRM_EdealBascounter() { return this.CTX_PRM_EdealBascounter; } public String CTX_PRM_EdealBasid; public String getCTX_PRM_EdealBasid() { return this.CTX_PRM_EdealBasid; } public String CTX_PRM_EdealCodeActor; public String getCTX_PRM_EdealCodeActor() { return this.CTX_PRM_EdealCodeActor; } public String CTX_PRM_EdealIdActor; public String getCTX_PRM_EdealIdActor() { return this.CTX_PRM_EdealIdActor; } public String CTX_PRM_EdealLicence; public String getCTX_PRM_EdealLicence() { return this.CTX_PRM_EdealLicence; } public Integer CTX_PRM_EncryptedPassword; public Integer getCTX_PRM_EncryptedPassword() { return this.CTX_PRM_EncryptedPassword; } public String CTX_PRM_Environnement; public String getCTX_PRM_Environnement() { return this.CTX_PRM_Environnement; } public String CTX_PRM_EQUALITING; public String getCTX_PRM_EQUALITING() { return this.CTX_PRM_EQUALITING; } public Object CTX_PRM_Exec_RES; public Object getCTX_PRM_Exec_RES() { return this.CTX_PRM_Exec_RES; } public String CTX_PRM_FichierConfiguration; public String getCTX_PRM_FichierConfiguration() { return this.CTX_PRM_FichierConfiguration; } public String CTX_PRM_FichierLog; public String getCTX_PRM_FichierLog() { return this.CTX_PRM_FichierLog; } public String CTX_PRM_FichierLogs; public String getCTX_PRM_FichierLogs() { return this.CTX_PRM_FichierLogs; } public String CTX_PRM_FichierMetrique; public String getCTX_PRM_FichierMetrique() { return this.CTX_PRM_FichierMetrique; } public String CTX_PRM_FichierStatistique; public String getCTX_PRM_FichierStatistique() { return this.CTX_PRM_FichierStatistique; } public String CTX_PRM_fileEncodage; public String getCTX_PRM_fileEncodage() { return this.CTX_PRM_fileEncodage; } public String CTX_PRM_fileName; public String getCTX_PRM_fileName() { return this.CTX_PRM_fileName; } public Long CTX_PRM_IdAudit; public Long getCTX_PRM_IdAudit() { return this.CTX_PRM_IdAudit; } public Integer CTX_PRM_IdEtape; public Integer getCTX_PRM_IdEtape() { return this.CTX_PRM_IdEtape; } public Integer CTX_PRM_IdEtapeDebut; public Integer getCTX_PRM_IdEtapeDebut() { return this.CTX_PRM_IdEtapeDebut; } public Integer CTX_PRM_IdEtapeFin; public Integer getCTX_PRM_IdEtapeFin() { return this.CTX_PRM_IdEtapeFin; } public String CTX_PRM_listOfTableToDisableConstraints; public String getCTX_PRM_listOfTableToDisableConstraints() { return this.CTX_PRM_listOfTableToDisableConstraints; } public Integer CTX_PRM_LKPCursorSize; public Integer getCTX_PRM_LKPCursorSize() { return this.CTX_PRM_LKPCursorSize; } public String CTX_PRM_NomAppliSource; public String getCTX_PRM_NomAppliSource() { return this.CTX_PRM_NomAppliSource; } public String CTX_PRM_NomSource; public String getCTX_PRM_NomSource() { return this.CTX_PRM_NomSource; } public String CTX_PRM_OLAKALA_ERROR; public String getCTX_PRM_OLAKALA_ERROR() { return this.CTX_PRM_OLAKALA_ERROR; } public String CTX_PRM_OLAKALA_FINISHED; public String getCTX_PRM_OLAKALA_FINISHED() { return this.CTX_PRM_OLAKALA_FINISHED; } public String CTX_PRM_OLAKALA_PROGRESS; public String getCTX_PRM_OLAKALA_PROGRESS() { return this.CTX_PRM_OLAKALA_PROGRESS; } public Integer CTX_PRM_ProfondeurRetentionLogs; public Integer getCTX_PRM_ProfondeurRetentionLogs() { return this.CTX_PRM_ProfondeurRetentionLogs; } public Integer CTX_PRM_ProfondeurRetentionRejets; public Integer getCTX_PRM_ProfondeurRetentionRejets() { return this.CTX_PRM_ProfondeurRetentionRejets; } public String CTX_PRM_RepertoireConf; public String getCTX_PRM_RepertoireConf() { return this.CTX_PRM_RepertoireConf; } public String CTX_PRM_RepertoireData; public String getCTX_PRM_RepertoireData() { return this.CTX_PRM_RepertoireData; } public String CTX_PRM_RepertoireDataArchive; public String getCTX_PRM_RepertoireDataArchive() { return this.CTX_PRM_RepertoireDataArchive; } public String CTX_PRM_RepertoireDataIn; public String getCTX_PRM_RepertoireDataIn() { return this.CTX_PRM_RepertoireDataIn; } public String CTX_PRM_RepertoireDataOut; public String getCTX_PRM_RepertoireDataOut() { return this.CTX_PRM_RepertoireDataOut; } public String CTX_PRM_RepertoireLog; public String getCTX_PRM_RepertoireLog() { return this.CTX_PRM_RepertoireLog; } public String CTX_PRM_RepertoireRacine; public String getCTX_PRM_RepertoireRacine() { return this.CTX_PRM_RepertoireRacine; } public String CTX_PRM_RepertoireSql; public String getCTX_PRM_RepertoireSql() { return this.CTX_PRM_RepertoireSql; } public String CTX_PRM_RepertoireTmp; public String getCTX_PRM_RepertoireTmp() { return this.CTX_PRM_RepertoireTmp; } public String CTX_PRM_RESERVIT; public String getCTX_PRM_RESERVIT() { return this.CTX_PRM_RESERVIT; } public String CTX_PRM_SoucheVersion; public String getCTX_PRM_SoucheVersion() { return this.CTX_PRM_SoucheVersion; } public Integer CTX_PRM_SRCCursorSize; public Integer getCTX_PRM_SRCCursorSize() { return this.CTX_PRM_SRCCursorSize; } public String CTX_PRM_TalendRootPackage; public String getCTX_PRM_TalendRootPackage() { return this.CTX_PRM_TalendRootPackage; } public String CTX_PRM_TalendRootPid; public String getCTX_PRM_TalendRootPid() { return this.CTX_PRM_TalendRootPid; } } private ContextProperties context = new ContextProperties(); public ContextProperties getContext() { return this.context; } private final String jobVersion = "0.1"; private final String jobName = "GALAXIE__PCKG"; private final String projectName = "FIL_GALAXIE"; public Integer errorCode = null; private String currentComponent = ""; private final java.util.Map<String, Object> globalMap = new java.util.HashMap<String, Object>(); private final static java.util.Map<String, Object> junitGlobalMap = new java.util.HashMap<String, Object>(); private final java.util.Map<String, Long> start_Hash = new java.util.HashMap<String, Long>(); private final java.util.Map<String, Long> end_Hash = new java.util.HashMap<String, Long>(); private final java.util.Map<String, Boolean> ok_Hash = new java.util.HashMap<String, Boolean>(); public final java.util.List<String[]> globalBuffer = new java.util.ArrayList<String[]>(); // OSGi DataSource private final static String KEY_DB_DATASOURCES = "KEY_DB_DATASOURCES"; public void setDataSources( java.util.Map<String, javax.sql.DataSource> dataSources) { java.util.Map<String, routines.system.TalendDataSource> talendDataSources = new java.util.HashMap<String, routines.system.TalendDataSource>(); for (java.util.Map.Entry<String, javax.sql.DataSource> dataSourceEntry : dataSources .entrySet()) { talendDataSources.put( dataSourceEntry.getKey(), new routines.system.TalendDataSource(dataSourceEntry .getValue())); } globalMap.put(KEY_DB_DATASOURCES, talendDataSources); } private final java.io.ByteArrayOutputStream baos = new java.io.ByteArrayOutputStream(); private final java.io.PrintStream errorMessagePS = new java.io.PrintStream( new java.io.BufferedOutputStream(baos)); public String getExceptionStackTrace() { if ("failure".equals(this.getStatus())) { errorMessagePS.flush(); return baos.toString(); } return null; } private Exception exception; public Exception getException() { if ("failure".equals(this.getStatus())) { return this.exception; } return null; } private class TalendException extends Exception { private static final long serialVersionUID = 1L; private java.util.Map<String, Object> globalMap = null; private Exception e = null; private String currentComponent = null; private String virtualComponentName = null; public void setVirtualComponentName(String virtualComponentName) { this.virtualComponentName = virtualComponentName; } private TalendException(Exception e, String errorComponent, final java.util.Map<String, Object> globalMap) { this.currentComponent = errorComponent; this.globalMap = globalMap; this.e = e; } public Exception getException() { return this.e; } public String getCurrentComponent() { return this.currentComponent; } public String getExceptionCauseMessage(Exception e) { Throwable cause = e; String message = null; int i = 10; while (null != cause && 0 < i--) { message = cause.getMessage(); if (null == message) { cause = cause.getCause(); } else { break; } } if (null == message) { message = e.getClass().getName(); } return message; } @Override public void printStackTrace() { if (!(e instanceof TalendException || e instanceof TDieException)) { if (virtualComponentName != null && currentComponent.indexOf(virtualComponentName + "_") == 0) { globalMap.put(virtualComponentName + "_ERROR_MESSAGE", getExceptionCauseMessage(e)); } globalMap.put(currentComponent + "_ERROR_MESSAGE", getExceptionCauseMessage(e)); System.err .println("Exception in component " + currentComponent); } if (!(e instanceof TDieException)) { if (e instanceof TalendException) { e.printStackTrace(); } else { e.printStackTrace(); e.printStackTrace(errorMessagePS); GALAXIE__PCKG.this.exception = e; } } if (!(e instanceof TalendException)) { try { for (java.lang.reflect.Method m : this.getClass() .getEnclosingClass().getMethods()) { if (m.getName().compareTo(currentComponent + "_error") == 0) { m.invoke(GALAXIE__PCKG.this, new Object[] { e, currentComponent, globalMap }); break; } } if (!(e instanceof TDieException)) { } } catch (Exception e) { this.e.printStackTrace(); } } } } public void tJava_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tJava_1_onSubJobError(exception, errorComponent, globalMap); } public void tRunJob_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); tRunJob_1_onSubJobError(exception, errorComponent, globalMap); } public void tContextLoad_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); tRunJob_1_onSubJobError(exception, errorComponent, globalMap); } public void tJava_4_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tJava_4_onSubJobError(exception, errorComponent, globalMap); } public void tRunJob_2_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); tRunJob_2_onSubJobError(exception, errorComponent, globalMap); } public void tContextLoad_3_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); tRunJob_2_onSubJobError(exception, errorComponent, globalMap); } public void tDie_2_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tDie_2_onSubJobError(exception, errorComponent, globalMap); } public void tDie_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tDie_1_onSubJobError(exception, errorComponent, globalMap); } public void tPostjob_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tPostjob_1_onSubJobError(exception, errorComponent, globalMap); } public void tJava_2_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tJava_2_onSubJobError(exception, errorComponent, globalMap); } public void tRunJob_3_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tRunJob_3_onSubJobError(exception, errorComponent, globalMap); } public void tContextLoad_2_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tRunJob_3_onSubJobError(exception, errorComponent, globalMap); } public void tJava_3_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tJava_3_onSubJobError(exception, errorComponent, globalMap); } public void tWarn_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tWarn_1_onSubJobError(exception, errorComponent, globalMap); } public void tWarn_2_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tWarn_2_onSubJobError(exception, errorComponent, globalMap); } public void tFileDelete_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tFileDelete_1_onSubJobError(exception, errorComponent, globalMap); } public void tSendMail_1_error(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { end_Hash.put(errorComponent, System.currentTimeMillis()); status = "failure"; tSendMail_1_onSubJobError(exception, errorComponent, globalMap); } public void tJava_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tRunJob_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "ERROR", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); try { errorCode = null; tDie_1Process(globalMap); if (!"failure".equals(status)) { status = "end"; } } catch (Exception e) { e.printStackTrace(); } } public void tJava_4_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tRunJob_2_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "ERROR", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); try { errorCode = null; tDie_2Process(globalMap); if (!"failure".equals(status)) { status = "end"; } } catch (Exception e) { e.printStackTrace(); } } public void tDie_2_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tDie_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tPostjob_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tJava_2_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tRunJob_3_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tJava_3_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tWarn_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tWarn_2_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tFileDelete_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tSendMail_1_onSubJobError(Exception exception, String errorComponent, final java.util.Map<String, Object> globalMap) throws TalendException { resumeUtil.addLog("SYSTEM_LOG", "NODE:" + errorComponent, "", Thread .currentThread().getId() + "", "FATAL", "", exception.getMessage(), ResumeUtil.getExceptionStackTrace(exception), ""); } public void tJava_1Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tJava_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tJava_1 begin ] start */ ok_Hash.put("tJava_1", false); start_Hash.put("tJava_1", System.currentTimeMillis()); currentComponent = "tJava_1"; int tos_count_tJava_1 = 0; context.CTX_PRM_DateDebut = new Date(); context.CTX_PRM_IdEtape = (context.CTX_PRM_IdEtape == null ? 1 : context.CTX_PRM_IdEtape); context.CTX_PRM_Environnement = (context.CTX_PRM_Environnement == null || ("").equals(context.CTX_PRM_Environnement) || contextStr .equals("Default")) ? "Default" : context.CTX_PRM_Environnement; context.CTX_PRM_FichierConfiguration = (context.CTX_PRM_FichierConfiguration != null && !("") .equals(context.CTX_PRM_FichierConfiguration)) ? context.CTX_PRM_FichierConfiguration : context.CTX_PRM_RepertoireConf + context.CTX_PRM_Environnement + ".properties"; context.CTX_PRM_RepertoireConf = (contextStr.equals("Default") ? context.CTX_PRM_RepertoireConf : "../../../conf/"); context.CTX_PRM_TalendRootPid = rootPid; context.CTX_PRM_TalendRootPackage = jobName; context.CTX_PRM_FichierStatistique = context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".stat"; context.CTX_PRM_FichierLog = context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".log"; context.CTX_PRM_FichierMetrique = context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".meter"; context.CTX_PRM_FichierLogs = context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".html"; globalMap.put("CTX_PRM_Exec_RES", new java.util.concurrent.ConcurrentHashMap()); /** * [tJava_1 begin ] stop */ /** * [tJava_1 main ] start */ currentComponent = "tJava_1"; tos_count_tJava_1++; /** * [tJava_1 main ] stop */ /** * [tJava_1 end ] start */ currentComponent = "tJava_1"; ok_Hash.put("tJava_1", true); end_Hash.put("tJava_1", System.currentTimeMillis()); /** * [tJava_1 end ] stop */ }// end the resume if (resumeEntryMethodName == null || globalResumeTicket) { resumeUtil.addLog("CHECKPOINT", "CONNECTION:SUBJOB_OK:tJava_1:OnSubjobOk", "", Thread .currentThread().getId() + "", "", "", "", "", ""); } tRunJob_1Process(globalMap); } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tJava_1 finally ] start */ currentComponent = "tJava_1"; /** * [tJava_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tJava_1_SUBPROCESS_STATE", 1); } public static class LOAD__contextesStruct implements routines.system.IPersistableRow<LOAD__contextesStruct> { final static byte[] commonByteArrayLock_FIL_GALAXIE_GALAXIE__PCKG = new byte[0]; static byte[] commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[0]; public String key; public String getKey() { return this.key; } public String value; public String getValue() { return this.value; } private String readString(ObjectInputStream dis) throws IOException { String strReturn = null; int length = 0; length = dis.readInt(); if (length == -1) { strReturn = null; } else { if (length > commonByteArray_FIL_GALAXIE_GALAXIE__PCKG.length) { if (length < 1024 && commonByteArray_FIL_GALAXIE_GALAXIE__PCKG.length == 0) { commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[1024]; } else { commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[2 * length]; } } dis.readFully(commonByteArray_FIL_GALAXIE_GALAXIE__PCKG, 0, length); strReturn = new String( commonByteArray_FIL_GALAXIE_GALAXIE__PCKG, 0, length, utf8Charset); } return strReturn; } private void writeString(String str, ObjectOutputStream dos) throws IOException { if (str == null) { dos.writeInt(-1); } else { byte[] byteArray = str.getBytes(utf8Charset); dos.writeInt(byteArray.length); dos.write(byteArray); } } public void readData(ObjectInputStream dis) { synchronized (commonByteArrayLock_FIL_GALAXIE_GALAXIE__PCKG) { try { int length = 0; this.key = readString(dis); this.value = readString(dis); } catch (IOException e) { throw new RuntimeException(e); } } } public void writeData(ObjectOutputStream dos) { try { // String writeString(this.key, dos); // String writeString(this.value, dos); } catch (IOException e) { throw new RuntimeException(e); } } public String toString() { StringBuilder sb = new StringBuilder(); sb.append(super.toString()); sb.append("["); sb.append("key=" + key); sb.append(",value=" + value); sb.append("]"); return sb.toString(); } /** * Compare keys */ public int compareTo(LOAD__contextesStruct other) { int returnValue = -1; return returnValue; } private int checkNullsAndCompare(Object object1, Object object2) { int returnValue = 0; if (object1 instanceof Comparable && object2 instanceof Comparable) { returnValue = ((Comparable) object1).compareTo(object2); } else if (object1 != null && object2 != null) { returnValue = compareStrings(object1.toString(), object2.toString()); } else if (object1 == null && object2 != null) { returnValue = 1; } else if (object1 != null && object2 == null) { returnValue = -1; } else { returnValue = 0; } return returnValue; } private int compareStrings(String string1, String string2) { return string1.compareTo(string2); } } public void tRunJob_1Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tRunJob_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; LOAD__contextesStruct LOAD__contextes = new LOAD__contextesStruct(); /** * [tContextLoad_1 begin ] start */ ok_Hash.put("tContextLoad_1", false); start_Hash.put("tContextLoad_1", System.currentTimeMillis()); currentComponent = "tContextLoad_1"; int tos_count_tContextLoad_1 = 0; java.util.List<String> assignList_tContextLoad_1 = new java.util.ArrayList<String>(); java.util.List<String> newPropertyList_tContextLoad_1 = new java.util.ArrayList<String>(); java.util.List<String> noAssignList_tContextLoad_1 = new java.util.ArrayList<String>(); int nb_line_tContextLoad_1 = 0; /** * [tContextLoad_1 begin ] stop */ /** * [tRunJob_1 begin ] start */ ok_Hash.put("tRunJob_1", false); start_Hash.put("tRunJob_1", System.currentTimeMillis()); currentComponent = "tRunJob_1"; int tos_count_tRunJob_1 = 0; /** * [tRunJob_1 begin ] stop */ /** * [tRunJob_1 main ] start */ currentComponent = "tRunJob_1"; java.util.List<String> paraList_tRunJob_1 = new java.util.ArrayList<String>(); paraList_tRunJob_1.add("--father_pid=" + pid); paraList_tRunJob_1.add("--root_pid=" + rootPid); paraList_tRunJob_1.add("--father_node=tRunJob_1"); paraList_tRunJob_1.add("--context=RE7"); // for feature:10589 paraList_tRunJob_1.add("--stat_port=" + portStats); if (resuming_logs_dir_path != null) { paraList_tRunJob_1.add("--resuming_logs_dir_path=" + resuming_logs_dir_path); } String childResumePath_tRunJob_1 = ResumeUtil .getChildJobCheckPointPath(resuming_checkpoint_path); String tRunJobName_tRunJob_1 = ResumeUtil .getRighttRunJob(resuming_checkpoint_path); if ("tRunJob_1".equals(tRunJobName_tRunJob_1) && childResumePath_tRunJob_1 != null) { paraList_tRunJob_1 .add("--resuming_checkpoint_path=" + ResumeUtil .getChildJobCheckPointPath(resuming_checkpoint_path)); } paraList_tRunJob_1.add("--parent_part_launcher=JOB:" + jobName + "/NODE:tRunJob_1"); java.util.Map<String, Object> parentContextMap_tRunJob_1 = new java.util.HashMap<String, Object>(); context.synchronizeContext(); java.util.Enumeration<?> propertyNames_tRunJob_1 = context .propertyNames(); while (propertyNames_tRunJob_1.hasMoreElements()) { String key_tRunJob_1 = (String) propertyNames_tRunJob_1 .nextElement(); Object value_tRunJob_1 = (Object) context .get(key_tRunJob_1); paraList_tRunJob_1.add("--context_param " + key_tRunJob_1 + "=" + value_tRunJob_1); } parentContextMap_tRunJob_1.put("CTX_EMAIL_Destinataire", context.CTX_EMAIL_Destinataire); parentContextMap_tRunJob_1.put("CTX_EMAIL_Destinataire_copie", context.CTX_EMAIL_Destinataire_copie); parentContextMap_tRunJob_1.put( "CTX_EMAIL_Destinataire_copie_cachee", context.CTX_EMAIL_Destinataire_copie_cachee); parentContextMap_tRunJob_1.put("CTX_EMAIL_Emetteur", context.CTX_EMAIL_Emetteur); parentContextMap_tRunJob_1.put("CTX_EMAIL_Envoi_active", context.CTX_EMAIL_Envoi_active); parentContextMap_tRunJob_1.put("CTX_EMAIL_Login", context.CTX_EMAIL_Login); parentContextMap_tRunJob_1.put("CTX_EMAIL_Password", context.CTX_EMAIL_Password); parentContextMap_tRunJob_1.put("CTX_EMAIL_Serveur_port", context.CTX_EMAIL_Serveur_port); parentContextMap_tRunJob_1.put("CTX_EMAIL_Serveur_SMTP", context.CTX_EMAIL_Serveur_SMTP); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTAFIL_Database", context.CTX_PGS_COMPTAFIL_Database); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTAFIL_Login", context.CTX_PGS_COMPTAFIL_Login); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTAFIL_Password", context.CTX_PGS_COMPTAFIL_Password); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTAFIL_Port", context.CTX_PGS_COMPTAFIL_Port); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTAFIL_Schema", context.CTX_PGS_COMPTAFIL_Schema); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTAFIL_Server", context.CTX_PGS_COMPTAFIL_Server); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTALIS_Database", context.CTX_PGS_COMPTALIS_Database); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTALIS_Login", context.CTX_PGS_COMPTALIS_Login); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTALIS_Password", context.CTX_PGS_COMPTALIS_Password); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTALIS_Port", context.CTX_PGS_COMPTALIS_Port); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTALIS_Schema", context.CTX_PGS_COMPTALIS_Schema); parentContextMap_tRunJob_1.put("CTX_PGS_COMPTALIS_Server", context.CTX_PGS_COMPTALIS_Server); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_CommitInterval", context.CTX_PGS_CRM_CommitInterval); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_Database", context.CTX_PGS_CRM_Database); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_Login", context.CTX_PGS_CRM_Login); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_Password", context.CTX_PGS_CRM_Password); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_Port", context.CTX_PGS_CRM_Port); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_Schema", context.CTX_PGS_CRM_Schema); parentContextMap_tRunJob_1.put("CTX_PGS_CRM_Server", context.CTX_PGS_CRM_Server); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_CommitInterval", context.CTX_PGS_DSA_CommitInterval); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_Database", context.CTX_PGS_DSA_Database); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_Login", context.CTX_PGS_DSA_Login); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_Password", context.CTX_PGS_DSA_Password); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_Port", context.CTX_PGS_DSA_Port); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_Schema", context.CTX_PGS_DSA_Schema); parentContextMap_tRunJob_1.put("CTX_PGS_DSA_Server", context.CTX_PGS_DSA_Server); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_CommitInterval", context.CTX_PGS_ODS_CommitInterval); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_Database", context.CTX_PGS_ODS_Database); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_Login", context.CTX_PGS_ODS_Login); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_Password", context.CTX_PGS_ODS_Password); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_Port", context.CTX_PGS_ODS_Port); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_Schema", context.CTX_PGS_ODS_Schema); parentContextMap_tRunJob_1.put("CTX_PGS_ODS_Server", context.CTX_PGS_ODS_Server); parentContextMap_tRunJob_1.put("CTX_PRM_ArchiveLogs", context.CTX_PRM_ArchiveLogs); parentContextMap_tRunJob_1.put("CTX_PRM_CEV", context.CTX_PRM_CEV); parentContextMap_tRunJob_1.put("CTX_PRM_CodeRetour", context.CTX_PRM_CodeRetour); parentContextMap_tRunJob_1.put("CTX_PRM_DateDebut", context.CTX_PRM_DateDebut); parentContextMap_tRunJob_1.put("CTX_PRM_DateFin", context.CTX_PRM_DateFin); parentContextMap_tRunJob_1.put("CTX_PRM_Edeal_ASSO_FIL", context.CTX_PRM_Edeal_ASSO_FIL); parentContextMap_tRunJob_1.put("CTX_PRM_Edeal_ASSO_LIS", context.CTX_PRM_Edeal_ASSO_LIS); parentContextMap_tRunJob_1.put("CTX_PRM_EdealBascounter", context.CTX_PRM_EdealBascounter); parentContextMap_tRunJob_1.put("CTX_PRM_EdealBasid", context.CTX_PRM_EdealBasid); parentContextMap_tRunJob_1.put("CTX_PRM_EdealCodeActor", context.CTX_PRM_EdealCodeActor); parentContextMap_tRunJob_1.put("CTX_PRM_EdealIdActor", context.CTX_PRM_EdealIdActor); parentContextMap_tRunJob_1.put("CTX_PRM_EdealLicence", context.CTX_PRM_EdealLicence); parentContextMap_tRunJob_1.put("CTX_PRM_EncryptedPassword", context.CTX_PRM_EncryptedPassword); parentContextMap_tRunJob_1.put("CTX_PRM_Environnement", context.CTX_PRM_Environnement); parentContextMap_tRunJob_1.put("CTX_PRM_EQUALITING", context.CTX_PRM_EQUALITING); parentContextMap_tRunJob_1.put("CTX_PRM_Exec_RES", context.CTX_PRM_Exec_RES); parentContextMap_tRunJob_1.put("CTX_PRM_FichierConfiguration", context.CTX_PRM_FichierConfiguration); parentContextMap_tRunJob_1.put("CTX_PRM_FichierLog", context.CTX_PRM_FichierLog); parentContextMap_tRunJob_1.put("CTX_PRM_FichierLogs", context.CTX_PRM_FichierLogs); parentContextMap_tRunJob_1.put("CTX_PRM_FichierMetrique", context.CTX_PRM_FichierMetrique); parentContextMap_tRunJob_1.put("CTX_PRM_FichierStatistique", context.CTX_PRM_FichierStatistique); parentContextMap_tRunJob_1.put("CTX_PRM_fileEncodage", context.CTX_PRM_fileEncodage); parentContextMap_tRunJob_1.put("CTX_PRM_fileName", context.CTX_PRM_fileName); parentContextMap_tRunJob_1.put("CTX_PRM_IdAudit", context.CTX_PRM_IdAudit); parentContextMap_tRunJob_1.put("CTX_PRM_IdEtape", context.CTX_PRM_IdEtape); parentContextMap_tRunJob_1.put("CTX_PRM_IdEtapeDebut", context.CTX_PRM_IdEtapeDebut); parentContextMap_tRunJob_1.put("CTX_PRM_IdEtapeFin", context.CTX_PRM_IdEtapeFin); parentContextMap_tRunJob_1.put( "CTX_PRM_listOfTableToDisableConstraints", context.CTX_PRM_listOfTableToDisableConstraints); parentContextMap_tRunJob_1.put("CTX_PRM_LKPCursorSize", context.CTX_PRM_LKPCursorSize); parentContextMap_tRunJob_1.put("CTX_PRM_NomAppliSource", context.CTX_PRM_NomAppliSource); parentContextMap_tRunJob_1.put("CTX_PRM_NomSource", context.CTX_PRM_NomSource); parentContextMap_tRunJob_1.put("CTX_PRM_OLAKALA_ERROR", context.CTX_PRM_OLAKALA_ERROR); parentContextMap_tRunJob_1.put("CTX_PRM_OLAKALA_FINISHED", context.CTX_PRM_OLAKALA_FINISHED); parentContextMap_tRunJob_1.put("CTX_PRM_OLAKALA_PROGRESS", context.CTX_PRM_OLAKALA_PROGRESS); parentContextMap_tRunJob_1.put( "CTX_PRM_ProfondeurRetentionLogs", context.CTX_PRM_ProfondeurRetentionLogs); parentContextMap_tRunJob_1.put( "CTX_PRM_ProfondeurRetentionRejets", context.CTX_PRM_ProfondeurRetentionRejets); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireConf", context.CTX_PRM_RepertoireConf); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireData", context.CTX_PRM_RepertoireData); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireDataArchive", context.CTX_PRM_RepertoireDataArchive); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireDataIn", context.CTX_PRM_RepertoireDataIn); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireDataOut", context.CTX_PRM_RepertoireDataOut); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireLog", context.CTX_PRM_RepertoireLog); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireRacine", context.CTX_PRM_RepertoireRacine); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireSql", context.CTX_PRM_RepertoireSql); parentContextMap_tRunJob_1.put("CTX_PRM_RepertoireTmp", context.CTX_PRM_RepertoireTmp); parentContextMap_tRunJob_1.put("CTX_PRM_RESERVIT", context.CTX_PRM_RESERVIT); parentContextMap_tRunJob_1.put("CTX_PRM_SoucheVersion", context.CTX_PRM_SoucheVersion); parentContextMap_tRunJob_1.put("CTX_PRM_SRCCursorSize", context.CTX_PRM_SRCCursorSize); parentContextMap_tRunJob_1.put("CTX_PRM_TalendRootPackage", context.CTX_PRM_TalendRootPackage); parentContextMap_tRunJob_1.put("CTX_PRM_TalendRootPid", context.CTX_PRM_TalendRootPid); Object obj_tRunJob_1 = null; fil_galaxie.util__job__load__properties_0_1.UTIL__JOB__LOAD__PROPERTIES childJob_tRunJob_1 = new fil_galaxie.util__job__load__properties_0_1.UTIL__JOB__LOAD__PROPERTIES(); // pass DataSources java.util.Map<String, routines.system.TalendDataSource> talendDataSources_tRunJob_1 = (java.util.Map<String, routines.system.TalendDataSource>) globalMap .get(KEY_DB_DATASOURCES); if (null != talendDataSources_tRunJob_1) { java.util.Map<String, javax.sql.DataSource> dataSources_tRunJob_1 = new java.util.HashMap<String, javax.sql.DataSource>(); for (java.util.Map.Entry<String, routines.system.TalendDataSource> talendDataSourceEntry_tRunJob_1 : talendDataSources_tRunJob_1 .entrySet()) { dataSources_tRunJob_1.put( talendDataSourceEntry_tRunJob_1.getKey(), talendDataSourceEntry_tRunJob_1.getValue() .getRawDataSource()); } childJob_tRunJob_1.setDataSources(dataSources_tRunJob_1); } childJob_tRunJob_1.parentContextMap = parentContextMap_tRunJob_1; String[][] childReturn_tRunJob_1 = childJob_tRunJob_1 .runJob((String[]) paraList_tRunJob_1 .toArray(new String[paraList_tRunJob_1.size()])); errorCode = childJob_tRunJob_1.getErrorCode(); if (childJob_tRunJob_1.getErrorCode() == null) { globalMap.put( "tRunJob_1_CHILD_RETURN_CODE", childJob_tRunJob_1.getStatus() != null && ("failure").equals(childJob_tRunJob_1 .getStatus()) ? 1 : 0); } else { globalMap.put("tRunJob_1_CHILD_RETURN_CODE", childJob_tRunJob_1.getErrorCode()); } if (childJob_tRunJob_1.getExceptionStackTrace() != null) { globalMap.put("tRunJob_1_CHILD_EXCEPTION_STACKTRACE", childJob_tRunJob_1.getExceptionStackTrace()); } if (childJob_tRunJob_1.getErrorCode() != null || ("failure").equals(childJob_tRunJob_1.getStatus())) { throw new RuntimeException("Child job running failed"); } for (String[] item_tRunJob_1 : childReturn_tRunJob_1) { if (childJob_tRunJob_1.hastBufferOutputComponent() || true) { if (0 < item_tRunJob_1.length) { LOAD__contextes.key = item_tRunJob_1[0]; } else { LOAD__contextes.key = null; } if (1 < item_tRunJob_1.length) { LOAD__contextes.value = item_tRunJob_1[1]; } else { LOAD__contextes.value = null; } } tos_count_tRunJob_1++; /** * [tRunJob_1 main ] stop */ /** * [tContextLoad_1 main ] start */ currentComponent = "tContextLoad_1"; // //////////////////////// String tmp_key_tContextLoad_1 = null; String key_tContextLoad_1 = null; if (LOAD__contextes.key != null) { tmp_key_tContextLoad_1 = LOAD__contextes.key.trim(); if ((tmp_key_tContextLoad_1.startsWith("#") || tmp_key_tContextLoad_1 .startsWith("!"))) { tmp_key_tContextLoad_1 = null; } else { LOAD__contextes.key = tmp_key_tContextLoad_1; } } if (LOAD__contextes.key != null) { key_tContextLoad_1 = LOAD__contextes.key; } String value_tContextLoad_1 = null; if (LOAD__contextes.value != null) { value_tContextLoad_1 = LOAD__contextes.value; } if (tmp_key_tContextLoad_1 != null) { try { if (key_tContextLoad_1 != null && "CTX_EMAIL_Destinataire" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Destinataire = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Destinataire_copie" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Destinataire_copie = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Destinataire_copie_cachee" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Destinataire_copie_cachee = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Emetteur" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Emetteur = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Envoi_active" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Envoi_active = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_EMAIL_Login" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Login = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Password" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Password = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Serveur_port" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Serveur_port = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_EMAIL_Serveur_SMTP" .equals(key_tContextLoad_1)) { context.CTX_EMAIL_Serveur_SMTP = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTAFIL_Database" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTAFIL_Database = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTAFIL_Login" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTAFIL_Login = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTAFIL_Password" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTAFIL_Password = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTAFIL_Port" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTAFIL_Port = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTAFIL_Schema" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTAFIL_Schema = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTAFIL_Server" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTAFIL_Server = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTALIS_Database" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTALIS_Database = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTALIS_Login" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTALIS_Login = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTALIS_Password" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTALIS_Password = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTALIS_Port" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTALIS_Port = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTALIS_Schema" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTALIS_Schema = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_COMPTALIS_Server" .equals(key_tContextLoad_1)) { context.CTX_PGS_COMPTALIS_Server = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_CommitInterval" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_CommitInterval = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_Database" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_Database = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_Login" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_Login = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_Password" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_Password = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_Port" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_Port = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_Schema" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_Schema = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_CRM_Server" .equals(key_tContextLoad_1)) { context.CTX_PGS_CRM_Server = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_CommitInterval" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_CommitInterval = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_Database" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_Database = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_Login" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_Login = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_Password" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_Password = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_Port" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_Port = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_Schema" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_Schema = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_DSA_Server" .equals(key_tContextLoad_1)) { context.CTX_PGS_DSA_Server = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_CommitInterval" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_CommitInterval = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_Database" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_Database = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_Login" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_Login = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_Password" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_Password = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_Port" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_Port = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_Schema" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_Schema = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PGS_ODS_Server" .equals(key_tContextLoad_1)) { context.CTX_PGS_ODS_Server = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_ArchiveLogs" .equals(key_tContextLoad_1)) { context.CTX_PRM_ArchiveLogs = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_CEV".equals(key_tContextLoad_1)) { context.CTX_PRM_CEV = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_CodeRetour" .equals(key_tContextLoad_1)) { context.CTX_PRM_CodeRetour = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_DateDebut" .equals(key_tContextLoad_1)) { String context_CTX_PRM_DateDebut_value = context .getProperty("CTX_PRM_DateDebut"); if (context_CTX_PRM_DateDebut_value == null) context_CTX_PRM_DateDebut_value = ""; int context_CTX_PRM_DateDebut_pos = context_CTX_PRM_DateDebut_value .indexOf(";"); String context_CTX_PRM_DateDebut_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateDebut_pos > -1) { context_CTX_PRM_DateDebut_pattern = context_CTX_PRM_DateDebut_value .substring(0, context_CTX_PRM_DateDebut_pos); } context.CTX_PRM_DateDebut = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateDebut_pattern) .parse(value_tContextLoad_1)); } if (key_tContextLoad_1 != null && "CTX_PRM_DateFin" .equals(key_tContextLoad_1)) { String context_CTX_PRM_DateFin_value = context .getProperty("CTX_PRM_DateFin"); if (context_CTX_PRM_DateFin_value == null) context_CTX_PRM_DateFin_value = ""; int context_CTX_PRM_DateFin_pos = context_CTX_PRM_DateFin_value .indexOf(";"); String context_CTX_PRM_DateFin_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateFin_pos > -1) { context_CTX_PRM_DateFin_pattern = context_CTX_PRM_DateFin_value .substring(0, context_CTX_PRM_DateFin_pos); } context.CTX_PRM_DateFin = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateFin_pattern) .parse(value_tContextLoad_1)); } if (key_tContextLoad_1 != null && "CTX_PRM_Edeal_ASSO_FIL" .equals(key_tContextLoad_1)) { context.CTX_PRM_Edeal_ASSO_FIL = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_Edeal_ASSO_LIS" .equals(key_tContextLoad_1)) { context.CTX_PRM_Edeal_ASSO_LIS = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EdealBascounter" .equals(key_tContextLoad_1)) { context.CTX_PRM_EdealBascounter = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EdealBasid" .equals(key_tContextLoad_1)) { context.CTX_PRM_EdealBasid = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EdealCodeActor" .equals(key_tContextLoad_1)) { context.CTX_PRM_EdealCodeActor = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EdealIdActor" .equals(key_tContextLoad_1)) { context.CTX_PRM_EdealIdActor = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EdealLicence" .equals(key_tContextLoad_1)) { context.CTX_PRM_EdealLicence = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EncryptedPassword" .equals(key_tContextLoad_1)) { context.CTX_PRM_EncryptedPassword = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_Environnement" .equals(key_tContextLoad_1)) { context.CTX_PRM_Environnement = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_EQUALITING" .equals(key_tContextLoad_1)) { context.CTX_PRM_EQUALITING = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_Exec_RES" .equals(key_tContextLoad_1)) { context.CTX_PRM_Exec_RES = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_FichierConfiguration" .equals(key_tContextLoad_1)) { context.CTX_PRM_FichierConfiguration = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_FichierLog" .equals(key_tContextLoad_1)) { context.CTX_PRM_FichierLog = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_FichierLogs" .equals(key_tContextLoad_1)) { context.CTX_PRM_FichierLogs = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_FichierMetrique" .equals(key_tContextLoad_1)) { context.CTX_PRM_FichierMetrique = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_FichierStatistique" .equals(key_tContextLoad_1)) { context.CTX_PRM_FichierStatistique = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_fileEncodage" .equals(key_tContextLoad_1)) { context.CTX_PRM_fileEncodage = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_fileName" .equals(key_tContextLoad_1)) { context.CTX_PRM_fileName = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_IdAudit" .equals(key_tContextLoad_1)) { context.CTX_PRM_IdAudit = Long .parseLong(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_IdEtape" .equals(key_tContextLoad_1)) { context.CTX_PRM_IdEtape = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_IdEtapeDebut" .equals(key_tContextLoad_1)) { context.CTX_PRM_IdEtapeDebut = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_IdEtapeFin" .equals(key_tContextLoad_1)) { context.CTX_PRM_IdEtapeFin = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_listOfTableToDisableConstraints" .equals(key_tContextLoad_1)) { context.CTX_PRM_listOfTableToDisableConstraints = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_LKPCursorSize" .equals(key_tContextLoad_1)) { context.CTX_PRM_LKPCursorSize = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_NomAppliSource" .equals(key_tContextLoad_1)) { context.CTX_PRM_NomAppliSource = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_NomSource" .equals(key_tContextLoad_1)) { context.CTX_PRM_NomSource = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_OLAKALA_ERROR" .equals(key_tContextLoad_1)) { context.CTX_PRM_OLAKALA_ERROR = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_OLAKALA_FINISHED" .equals(key_tContextLoad_1)) { context.CTX_PRM_OLAKALA_FINISHED = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_OLAKALA_PROGRESS" .equals(key_tContextLoad_1)) { context.CTX_PRM_OLAKALA_PROGRESS = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_ProfondeurRetentionLogs" .equals(key_tContextLoad_1)) { context.CTX_PRM_ProfondeurRetentionLogs = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_ProfondeurRetentionRejets" .equals(key_tContextLoad_1)) { context.CTX_PRM_ProfondeurRetentionRejets = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireConf" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireConf = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireData" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireData = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireDataArchive" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireDataArchive = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireDataIn" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireDataIn = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireDataOut" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireDataOut = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireLog" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireLog = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireRacine" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireRacine = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireSql" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireSql = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RepertoireTmp" .equals(key_tContextLoad_1)) { context.CTX_PRM_RepertoireTmp = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_RESERVIT" .equals(key_tContextLoad_1)) { context.CTX_PRM_RESERVIT = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_SoucheVersion" .equals(key_tContextLoad_1)) { context.CTX_PRM_SoucheVersion = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_SRCCursorSize" .equals(key_tContextLoad_1)) { context.CTX_PRM_SRCCursorSize = Integer .parseInt(value_tContextLoad_1); } if (key_tContextLoad_1 != null && "CTX_PRM_TalendRootPackage" .equals(key_tContextLoad_1)) { context.CTX_PRM_TalendRootPackage = value_tContextLoad_1; } if (key_tContextLoad_1 != null && "CTX_PRM_TalendRootPid" .equals(key_tContextLoad_1)) { context.CTX_PRM_TalendRootPid = value_tContextLoad_1; } if (context.getProperty(key_tContextLoad_1) != null) { assignList_tContextLoad_1 .add(key_tContextLoad_1); } else { newPropertyList_tContextLoad_1 .add(key_tContextLoad_1); } if (value_tContextLoad_1 == null) { context.setProperty(key_tContextLoad_1, ""); } else { context.setProperty(key_tContextLoad_1, value_tContextLoad_1); } } catch (java.lang.Exception e) { System.err.println("Setting a value for the key \"" + key_tContextLoad_1 + "\" has failed. Error message: " + e.getMessage()); } nb_line_tContextLoad_1++; } // //////////////////////// tos_count_tContextLoad_1++; /** * [tContextLoad_1 main ] stop */ } // C_01 /** * [tRunJob_1 end ] start */ currentComponent = "tRunJob_1"; ok_Hash.put("tRunJob_1", true); end_Hash.put("tRunJob_1", System.currentTimeMillis()); /** * [tRunJob_1 end ] stop */ /** * [tContextLoad_1 end ] start */ currentComponent = "tContextLoad_1"; java.util.Enumeration<?> enu_tContextLoad_1 = context .propertyNames(); while (enu_tContextLoad_1.hasMoreElements()) { String key_tContextLoad_1 = (String) enu_tContextLoad_1 .nextElement(); if (!assignList_tContextLoad_1.contains(key_tContextLoad_1) && !newPropertyList_tContextLoad_1 .contains(key_tContextLoad_1)) { noAssignList_tContextLoad_1.add(key_tContextLoad_1); } } String newPropertyStr_tContextLoad_1 = newPropertyList_tContextLoad_1 .toString(); String newProperty_tContextLoad_1 = newPropertyStr_tContextLoad_1 .substring(1, newPropertyStr_tContextLoad_1.length() - 1); String noAssignStr_tContextLoad_1 = noAssignList_tContextLoad_1 .toString(); String noAssign_tContextLoad_1 = noAssignStr_tContextLoad_1 .substring(1, noAssignStr_tContextLoad_1.length() - 1); globalMap.put("tContextLoad_1_KEY_NOT_INCONTEXT", newProperty_tContextLoad_1); globalMap.put("tContextLoad_1_KEY_NOT_LOADED", noAssign_tContextLoad_1); globalMap.put("tContextLoad_1_NB_LINE", nb_line_tContextLoad_1); List<String> parametersToEncrypt_tContextLoad_1 = new java.util.ArrayList<String>(); parametersToEncrypt_tContextLoad_1.add("CTX_EMAIL_Password"); parametersToEncrypt_tContextLoad_1 .add("CTX_PGS_COMPTAFIL_Password"); parametersToEncrypt_tContextLoad_1 .add("CTX_PGS_COMPTALIS_Password"); parametersToEncrypt_tContextLoad_1.add("CTX_PGS_CRM_Password"); parametersToEncrypt_tContextLoad_1.add("CTX_PGS_DSA_Password"); parametersToEncrypt_tContextLoad_1.add("CTX_PGS_ODS_Password"); resumeUtil.addLog("NODE", "NODE:tContextLoad_1", "", Thread .currentThread().getId() + "", "", "", "", "", resumeUtil.convertToJsonText(context, parametersToEncrypt_tContextLoad_1)); ok_Hash.put("tContextLoad_1", true); end_Hash.put("tContextLoad_1", System.currentTimeMillis()); /** * [tContextLoad_1 end ] stop */ }// end the resume if (resumeEntryMethodName == null || globalResumeTicket) { resumeUtil.addLog("CHECKPOINT", "CONNECTION:SUBJOB_OK:tRunJob_1:OnSubjobOk", "", Thread .currentThread().getId() + "", "", "", "", "", ""); } tJava_4Process(globalMap); } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tRunJob_1 finally ] start */ currentComponent = "tRunJob_1"; /** * [tRunJob_1 finally ] stop */ /** * [tContextLoad_1 finally ] start */ currentComponent = "tContextLoad_1"; /** * [tContextLoad_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tRunJob_1_SUBPROCESS_STATE", 1); } public void tJava_4Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tJava_4_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tJava_4 begin ] start */ ok_Hash.put("tJava_4", false); start_Hash.put("tJava_4", System.currentTimeMillis()); currentComponent = "tJava_4"; int tos_count_tJava_4 = 0; if (context.CTX_PRM_EncryptedPassword == 1) { context.CTX_PGS_CRM_Password = routines.CustomSecurity .decrypt(context.CTX_PGS_CRM_Password); context.CTX_PGS_ODS_Password = routines.CustomSecurity .decrypt(context.CTX_PGS_ODS_Password); context.CTX_PGS_DSA_Password = routines.CustomSecurity .decrypt(context.CTX_PGS_DSA_Password); context.CTX_EMAIL_Password = routines.CustomSecurity .decrypt(context.CTX_EMAIL_Password); } globalMap.put("SharedMap_EXE_RES", new java.util.concurrent.ConcurrentHashMap()); /** * [tJava_4 begin ] stop */ /** * [tJava_4 main ] start */ currentComponent = "tJava_4"; tos_count_tJava_4++; /** * [tJava_4 main ] stop */ /** * [tJava_4 end ] start */ currentComponent = "tJava_4"; ok_Hash.put("tJava_4", true); end_Hash.put("tJava_4", System.currentTimeMillis()); /** * [tJava_4 end ] stop */ }// end the resume if (resumeEntryMethodName == null || globalResumeTicket) { resumeUtil.addLog("CHECKPOINT", "CONNECTION:SUBJOB_OK:tJava_4:OnSubjobOk", "", Thread .currentThread().getId() + "", "", "", "", "", ""); } tRunJob_2Process(globalMap); } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tJava_4 finally ] start */ currentComponent = "tJava_4"; /** * [tJava_4 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tJava_4_SUBPROCESS_STATE", 1); } public static class LOAD__contexte_Struct implements routines.system.IPersistableRow<LOAD__contexte_Struct> { final static byte[] commonByteArrayLock_FIL_GALAXIE_GALAXIE__PCKG = new byte[0]; static byte[] commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[0]; public String key; public String getKey() { return this.key; } public String value; public String getValue() { return this.value; } private String readString(ObjectInputStream dis) throws IOException { String strReturn = null; int length = 0; length = dis.readInt(); if (length == -1) { strReturn = null; } else { if (length > commonByteArray_FIL_GALAXIE_GALAXIE__PCKG.length) { if (length < 1024 && commonByteArray_FIL_GALAXIE_GALAXIE__PCKG.length == 0) { commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[1024]; } else { commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[2 * length]; } } dis.readFully(commonByteArray_FIL_GALAXIE_GALAXIE__PCKG, 0, length); strReturn = new String( commonByteArray_FIL_GALAXIE_GALAXIE__PCKG, 0, length, utf8Charset); } return strReturn; } private void writeString(String str, ObjectOutputStream dos) throws IOException { if (str == null) { dos.writeInt(-1); } else { byte[] byteArray = str.getBytes(utf8Charset); dos.writeInt(byteArray.length); dos.write(byteArray); } } public void readData(ObjectInputStream dis) { synchronized (commonByteArrayLock_FIL_GALAXIE_GALAXIE__PCKG) { try { int length = 0; this.key = readString(dis); this.value = readString(dis); } catch (IOException e) { throw new RuntimeException(e); } } } public void writeData(ObjectOutputStream dos) { try { // String writeString(this.key, dos); // String writeString(this.value, dos); } catch (IOException e) { throw new RuntimeException(e); } } public String toString() { StringBuilder sb = new StringBuilder(); sb.append(super.toString()); sb.append("["); sb.append("key=" + key); sb.append(",value=" + value); sb.append("]"); return sb.toString(); } /** * Compare keys */ public int compareTo(LOAD__contexte_Struct other) { int returnValue = -1; return returnValue; } private int checkNullsAndCompare(Object object1, Object object2) { int returnValue = 0; if (object1 instanceof Comparable && object2 instanceof Comparable) { returnValue = ((Comparable) object1).compareTo(object2); } else if (object1 != null && object2 != null) { returnValue = compareStrings(object1.toString(), object2.toString()); } else if (object1 == null && object2 != null) { returnValue = 1; } else if (object1 != null && object2 == null) { returnValue = -1; } else { returnValue = 0; } return returnValue; } private int compareStrings(String string1, String string2) { return string1.compareTo(string2); } } public void tRunJob_2Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tRunJob_2_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; LOAD__contexte_Struct LOAD__contexte_ = new LOAD__contexte_Struct(); /** * [tContextLoad_3 begin ] start */ ok_Hash.put("tContextLoad_3", false); start_Hash.put("tContextLoad_3", System.currentTimeMillis()); currentComponent = "tContextLoad_3"; int tos_count_tContextLoad_3 = 0; java.util.List<String> assignList_tContextLoad_3 = new java.util.ArrayList<String>(); java.util.List<String> newPropertyList_tContextLoad_3 = new java.util.ArrayList<String>(); java.util.List<String> noAssignList_tContextLoad_3 = new java.util.ArrayList<String>(); int nb_line_tContextLoad_3 = 0; /** * [tContextLoad_3 begin ] stop */ /** * [tRunJob_2 begin ] start */ ok_Hash.put("tRunJob_2", false); start_Hash.put("tRunJob_2", System.currentTimeMillis()); currentComponent = "tRunJob_2"; int tos_count_tRunJob_2 = 0; /** * [tRunJob_2 begin ] stop */ /** * [tRunJob_2 main ] start */ currentComponent = "tRunJob_2"; java.util.List<String> paraList_tRunJob_2 = new java.util.ArrayList<String>(); paraList_tRunJob_2.add("--father_pid=" + pid); paraList_tRunJob_2.add("--root_pid=" + rootPid); paraList_tRunJob_2.add("--father_node=tRunJob_2"); paraList_tRunJob_2.add("--context=RE7"); // for feature:10589 paraList_tRunJob_2.add("--stat_port=" + portStats); if (resuming_logs_dir_path != null) { paraList_tRunJob_2.add("--resuming_logs_dir_path=" + resuming_logs_dir_path); } String childResumePath_tRunJob_2 = ResumeUtil .getChildJobCheckPointPath(resuming_checkpoint_path); String tRunJobName_tRunJob_2 = ResumeUtil .getRighttRunJob(resuming_checkpoint_path); if ("tRunJob_2".equals(tRunJobName_tRunJob_2) && childResumePath_tRunJob_2 != null) { paraList_tRunJob_2 .add("--resuming_checkpoint_path=" + ResumeUtil .getChildJobCheckPointPath(resuming_checkpoint_path)); } paraList_tRunJob_2.add("--parent_part_launcher=JOB:" + jobName + "/NODE:tRunJob_2"); java.util.Map<String, Object> parentContextMap_tRunJob_2 = new java.util.HashMap<String, Object>(); context.synchronizeContext(); java.util.Enumeration<?> propertyNames_tRunJob_2 = context .propertyNames(); while (propertyNames_tRunJob_2.hasMoreElements()) { String key_tRunJob_2 = (String) propertyNames_tRunJob_2 .nextElement(); Object value_tRunJob_2 = (Object) context .get(key_tRunJob_2); paraList_tRunJob_2.add("--context_param " + key_tRunJob_2 + "=" + value_tRunJob_2); } parentContextMap_tRunJob_2.put("CTX_EMAIL_Destinataire", context.CTX_EMAIL_Destinataire); parentContextMap_tRunJob_2.put("CTX_EMAIL_Destinataire_copie", context.CTX_EMAIL_Destinataire_copie); parentContextMap_tRunJob_2.put( "CTX_EMAIL_Destinataire_copie_cachee", context.CTX_EMAIL_Destinataire_copie_cachee); parentContextMap_tRunJob_2.put("CTX_EMAIL_Emetteur", context.CTX_EMAIL_Emetteur); parentContextMap_tRunJob_2.put("CTX_EMAIL_Envoi_active", context.CTX_EMAIL_Envoi_active); parentContextMap_tRunJob_2.put("CTX_EMAIL_Login", context.CTX_EMAIL_Login); parentContextMap_tRunJob_2.put("CTX_EMAIL_Password", context.CTX_EMAIL_Password); parentContextMap_tRunJob_2.put("CTX_EMAIL_Serveur_port", context.CTX_EMAIL_Serveur_port); parentContextMap_tRunJob_2.put("CTX_EMAIL_Serveur_SMTP", context.CTX_EMAIL_Serveur_SMTP); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTAFIL_Database", context.CTX_PGS_COMPTAFIL_Database); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTAFIL_Login", context.CTX_PGS_COMPTAFIL_Login); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTAFIL_Password", context.CTX_PGS_COMPTAFIL_Password); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTAFIL_Port", context.CTX_PGS_COMPTAFIL_Port); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTAFIL_Schema", context.CTX_PGS_COMPTAFIL_Schema); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTAFIL_Server", context.CTX_PGS_COMPTAFIL_Server); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTALIS_Database", context.CTX_PGS_COMPTALIS_Database); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTALIS_Login", context.CTX_PGS_COMPTALIS_Login); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTALIS_Password", context.CTX_PGS_COMPTALIS_Password); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTALIS_Port", context.CTX_PGS_COMPTALIS_Port); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTALIS_Schema", context.CTX_PGS_COMPTALIS_Schema); parentContextMap_tRunJob_2.put("CTX_PGS_COMPTALIS_Server", context.CTX_PGS_COMPTALIS_Server); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_CommitInterval", context.CTX_PGS_CRM_CommitInterval); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_Database", context.CTX_PGS_CRM_Database); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_Login", context.CTX_PGS_CRM_Login); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_Password", context.CTX_PGS_CRM_Password); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_Port", context.CTX_PGS_CRM_Port); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_Schema", context.CTX_PGS_CRM_Schema); parentContextMap_tRunJob_2.put("CTX_PGS_CRM_Server", context.CTX_PGS_CRM_Server); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_CommitInterval", context.CTX_PGS_DSA_CommitInterval); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_Database", context.CTX_PGS_DSA_Database); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_Login", context.CTX_PGS_DSA_Login); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_Password", context.CTX_PGS_DSA_Password); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_Port", context.CTX_PGS_DSA_Port); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_Schema", context.CTX_PGS_DSA_Schema); parentContextMap_tRunJob_2.put("CTX_PGS_DSA_Server", context.CTX_PGS_DSA_Server); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_CommitInterval", context.CTX_PGS_ODS_CommitInterval); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_Database", context.CTX_PGS_ODS_Database); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_Login", context.CTX_PGS_ODS_Login); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_Password", context.CTX_PGS_ODS_Password); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_Port", context.CTX_PGS_ODS_Port); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_Schema", context.CTX_PGS_ODS_Schema); parentContextMap_tRunJob_2.put("CTX_PGS_ODS_Server", context.CTX_PGS_ODS_Server); parentContextMap_tRunJob_2.put("CTX_PRM_ArchiveLogs", context.CTX_PRM_ArchiveLogs); parentContextMap_tRunJob_2.put("CTX_PRM_CEV", context.CTX_PRM_CEV); parentContextMap_tRunJob_2.put("CTX_PRM_CodeRetour", context.CTX_PRM_CodeRetour); parentContextMap_tRunJob_2.put("CTX_PRM_DateDebut", context.CTX_PRM_DateDebut); parentContextMap_tRunJob_2.put("CTX_PRM_DateFin", context.CTX_PRM_DateFin); parentContextMap_tRunJob_2.put("CTX_PRM_Edeal_ASSO_FIL", context.CTX_PRM_Edeal_ASSO_FIL); parentContextMap_tRunJob_2.put("CTX_PRM_Edeal_ASSO_LIS", context.CTX_PRM_Edeal_ASSO_LIS); parentContextMap_tRunJob_2.put("CTX_PRM_EdealBascounter", context.CTX_PRM_EdealBascounter); parentContextMap_tRunJob_2.put("CTX_PRM_EdealBasid", context.CTX_PRM_EdealBasid); parentContextMap_tRunJob_2.put("CTX_PRM_EdealCodeActor", context.CTX_PRM_EdealCodeActor); parentContextMap_tRunJob_2.put("CTX_PRM_EdealIdActor", context.CTX_PRM_EdealIdActor); parentContextMap_tRunJob_2.put("CTX_PRM_EdealLicence", context.CTX_PRM_EdealLicence); parentContextMap_tRunJob_2.put("CTX_PRM_EncryptedPassword", context.CTX_PRM_EncryptedPassword); parentContextMap_tRunJob_2.put("CTX_PRM_Environnement", context.CTX_PRM_Environnement); parentContextMap_tRunJob_2.put("CTX_PRM_EQUALITING", context.CTX_PRM_EQUALITING); parentContextMap_tRunJob_2.put("CTX_PRM_Exec_RES", context.CTX_PRM_Exec_RES); parentContextMap_tRunJob_2.put("CTX_PRM_FichierConfiguration", context.CTX_PRM_FichierConfiguration); parentContextMap_tRunJob_2.put("CTX_PRM_FichierLog", context.CTX_PRM_FichierLog); parentContextMap_tRunJob_2.put("CTX_PRM_FichierLogs", context.CTX_PRM_FichierLogs); parentContextMap_tRunJob_2.put("CTX_PRM_FichierMetrique", context.CTX_PRM_FichierMetrique); parentContextMap_tRunJob_2.put("CTX_PRM_FichierStatistique", context.CTX_PRM_FichierStatistique); parentContextMap_tRunJob_2.put("CTX_PRM_fileEncodage", context.CTX_PRM_fileEncodage); parentContextMap_tRunJob_2.put("CTX_PRM_fileName", context.CTX_PRM_fileName); parentContextMap_tRunJob_2.put("CTX_PRM_IdAudit", context.CTX_PRM_IdAudit); parentContextMap_tRunJob_2.put("CTX_PRM_IdEtape", context.CTX_PRM_IdEtape); parentContextMap_tRunJob_2.put("CTX_PRM_IdEtapeDebut", context.CTX_PRM_IdEtapeDebut); parentContextMap_tRunJob_2.put("CTX_PRM_IdEtapeFin", context.CTX_PRM_IdEtapeFin); parentContextMap_tRunJob_2.put( "CTX_PRM_listOfTableToDisableConstraints", context.CTX_PRM_listOfTableToDisableConstraints); parentContextMap_tRunJob_2.put("CTX_PRM_LKPCursorSize", context.CTX_PRM_LKPCursorSize); parentContextMap_tRunJob_2.put("CTX_PRM_NomAppliSource", context.CTX_PRM_NomAppliSource); parentContextMap_tRunJob_2.put("CTX_PRM_NomSource", context.CTX_PRM_NomSource); parentContextMap_tRunJob_2.put("CTX_PRM_OLAKALA_ERROR", context.CTX_PRM_OLAKALA_ERROR); parentContextMap_tRunJob_2.put("CTX_PRM_OLAKALA_FINISHED", context.CTX_PRM_OLAKALA_FINISHED); parentContextMap_tRunJob_2.put("CTX_PRM_OLAKALA_PROGRESS", context.CTX_PRM_OLAKALA_PROGRESS); parentContextMap_tRunJob_2.put( "CTX_PRM_ProfondeurRetentionLogs", context.CTX_PRM_ProfondeurRetentionLogs); parentContextMap_tRunJob_2.put( "CTX_PRM_ProfondeurRetentionRejets", context.CTX_PRM_ProfondeurRetentionRejets); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireConf", context.CTX_PRM_RepertoireConf); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireData", context.CTX_PRM_RepertoireData); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireDataArchive", context.CTX_PRM_RepertoireDataArchive); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireDataIn", context.CTX_PRM_RepertoireDataIn); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireDataOut", context.CTX_PRM_RepertoireDataOut); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireLog", context.CTX_PRM_RepertoireLog); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireRacine", context.CTX_PRM_RepertoireRacine); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireSql", context.CTX_PRM_RepertoireSql); parentContextMap_tRunJob_2.put("CTX_PRM_RepertoireTmp", context.CTX_PRM_RepertoireTmp); parentContextMap_tRunJob_2.put("CTX_PRM_RESERVIT", context.CTX_PRM_RESERVIT); parentContextMap_tRunJob_2.put("CTX_PRM_SoucheVersion", context.CTX_PRM_SoucheVersion); parentContextMap_tRunJob_2.put("CTX_PRM_SRCCursorSize", context.CTX_PRM_SRCCursorSize); parentContextMap_tRunJob_2.put("CTX_PRM_TalendRootPackage", context.CTX_PRM_TalendRootPackage); parentContextMap_tRunJob_2.put("CTX_PRM_TalendRootPid", context.CTX_PRM_TalendRootPid); Object obj_tRunJob_2 = null; obj_tRunJob_2 = globalMap.get("SharedMap_EXE_RES"); paraList_tRunJob_2.add("--context_param SharedMap_EXE_RES=" + RuntimeUtils.tRunJobConvertContext(obj_tRunJob_2)); parentContextMap_tRunJob_2.put("SharedMap_EXE_RES", obj_tRunJob_2); fil_galaxie.galaxie__mrj__alimentation_0_1.GALAXIE__MRJ__ALIMENTATION childJob_tRunJob_2 = new fil_galaxie.galaxie__mrj__alimentation_0_1.GALAXIE__MRJ__ALIMENTATION(); // pass DataSources java.util.Map<String, routines.system.TalendDataSource> talendDataSources_tRunJob_2 = (java.util.Map<String, routines.system.TalendDataSource>) globalMap .get(KEY_DB_DATASOURCES); if (null != talendDataSources_tRunJob_2) { java.util.Map<String, javax.sql.DataSource> dataSources_tRunJob_2 = new java.util.HashMap<String, javax.sql.DataSource>(); for (java.util.Map.Entry<String, routines.system.TalendDataSource> talendDataSourceEntry_tRunJob_2 : talendDataSources_tRunJob_2 .entrySet()) { dataSources_tRunJob_2.put( talendDataSourceEntry_tRunJob_2.getKey(), talendDataSourceEntry_tRunJob_2.getValue() .getRawDataSource()); } childJob_tRunJob_2.setDataSources(dataSources_tRunJob_2); } childJob_tRunJob_2.parentContextMap = parentContextMap_tRunJob_2; String[][] childReturn_tRunJob_2 = childJob_tRunJob_2 .runJob((String[]) paraList_tRunJob_2 .toArray(new String[paraList_tRunJob_2.size()])); errorCode = childJob_tRunJob_2.getErrorCode(); if (childJob_tRunJob_2.getErrorCode() == null) { globalMap.put( "tRunJob_2_CHILD_RETURN_CODE", childJob_tRunJob_2.getStatus() != null && ("failure").equals(childJob_tRunJob_2 .getStatus()) ? 1 : 0); } else { globalMap.put("tRunJob_2_CHILD_RETURN_CODE", childJob_tRunJob_2.getErrorCode()); } if (childJob_tRunJob_2.getExceptionStackTrace() != null) { globalMap.put("tRunJob_2_CHILD_EXCEPTION_STACKTRACE", childJob_tRunJob_2.getExceptionStackTrace()); } if (childJob_tRunJob_2.getErrorCode() != null || ("failure").equals(childJob_tRunJob_2.getStatus())) { throw new RuntimeException("Child job running failed"); } for (String[] item_tRunJob_2 : childReturn_tRunJob_2) { if (childJob_tRunJob_2.hastBufferOutputComponent() || true) { if (0 < item_tRunJob_2.length) { LOAD__contexte_.key = item_tRunJob_2[0]; } else { LOAD__contexte_.key = null; } if (1 < item_tRunJob_2.length) { LOAD__contexte_.value = item_tRunJob_2[1]; } else { LOAD__contexte_.value = null; } } tos_count_tRunJob_2++; /** * [tRunJob_2 main ] stop */ /** * [tContextLoad_3 main ] start */ currentComponent = "tContextLoad_3"; // //////////////////////// String tmp_key_tContextLoad_3 = null; String key_tContextLoad_3 = null; if (LOAD__contexte_.key != null) { tmp_key_tContextLoad_3 = LOAD__contexte_.key.trim(); if ((tmp_key_tContextLoad_3.startsWith("#") || tmp_key_tContextLoad_3 .startsWith("!"))) { tmp_key_tContextLoad_3 = null; } else { LOAD__contexte_.key = tmp_key_tContextLoad_3; } } if (LOAD__contexte_.key != null) { key_tContextLoad_3 = LOAD__contexte_.key; } String value_tContextLoad_3 = null; if (LOAD__contexte_.value != null) { value_tContextLoad_3 = LOAD__contexte_.value; } if (tmp_key_tContextLoad_3 != null) { try { if (key_tContextLoad_3 != null && "CTX_EMAIL_Destinataire" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Destinataire = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Destinataire_copie" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Destinataire_copie = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Destinataire_copie_cachee" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Destinataire_copie_cachee = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Emetteur" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Emetteur = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Envoi_active" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Envoi_active = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_EMAIL_Login" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Login = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Password" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Password = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Serveur_port" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Serveur_port = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_EMAIL_Serveur_SMTP" .equals(key_tContextLoad_3)) { context.CTX_EMAIL_Serveur_SMTP = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTAFIL_Database" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTAFIL_Database = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTAFIL_Login" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTAFIL_Login = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTAFIL_Password" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTAFIL_Password = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTAFIL_Port" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTAFIL_Port = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTAFIL_Schema" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTAFIL_Schema = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTAFIL_Server" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTAFIL_Server = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTALIS_Database" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTALIS_Database = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTALIS_Login" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTALIS_Login = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTALIS_Password" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTALIS_Password = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTALIS_Port" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTALIS_Port = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTALIS_Schema" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTALIS_Schema = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_COMPTALIS_Server" .equals(key_tContextLoad_3)) { context.CTX_PGS_COMPTALIS_Server = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_CommitInterval" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_CommitInterval = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_Database" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_Database = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_Login" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_Login = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_Password" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_Password = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_Port" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_Port = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_Schema" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_Schema = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_CRM_Server" .equals(key_tContextLoad_3)) { context.CTX_PGS_CRM_Server = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_CommitInterval" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_CommitInterval = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_Database" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_Database = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_Login" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_Login = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_Password" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_Password = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_Port" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_Port = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_Schema" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_Schema = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_DSA_Server" .equals(key_tContextLoad_3)) { context.CTX_PGS_DSA_Server = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_CommitInterval" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_CommitInterval = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_Database" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_Database = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_Login" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_Login = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_Password" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_Password = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_Port" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_Port = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_Schema" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_Schema = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PGS_ODS_Server" .equals(key_tContextLoad_3)) { context.CTX_PGS_ODS_Server = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_ArchiveLogs" .equals(key_tContextLoad_3)) { context.CTX_PRM_ArchiveLogs = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_CEV".equals(key_tContextLoad_3)) { context.CTX_PRM_CEV = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_CodeRetour" .equals(key_tContextLoad_3)) { context.CTX_PRM_CodeRetour = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_DateDebut" .equals(key_tContextLoad_3)) { String context_CTX_PRM_DateDebut_value = context .getProperty("CTX_PRM_DateDebut"); if (context_CTX_PRM_DateDebut_value == null) context_CTX_PRM_DateDebut_value = ""; int context_CTX_PRM_DateDebut_pos = context_CTX_PRM_DateDebut_value .indexOf(";"); String context_CTX_PRM_DateDebut_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateDebut_pos > -1) { context_CTX_PRM_DateDebut_pattern = context_CTX_PRM_DateDebut_value .substring(0, context_CTX_PRM_DateDebut_pos); } context.CTX_PRM_DateDebut = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateDebut_pattern) .parse(value_tContextLoad_3)); } if (key_tContextLoad_3 != null && "CTX_PRM_DateFin" .equals(key_tContextLoad_3)) { String context_CTX_PRM_DateFin_value = context .getProperty("CTX_PRM_DateFin"); if (context_CTX_PRM_DateFin_value == null) context_CTX_PRM_DateFin_value = ""; int context_CTX_PRM_DateFin_pos = context_CTX_PRM_DateFin_value .indexOf(";"); String context_CTX_PRM_DateFin_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateFin_pos > -1) { context_CTX_PRM_DateFin_pattern = context_CTX_PRM_DateFin_value .substring(0, context_CTX_PRM_DateFin_pos); } context.CTX_PRM_DateFin = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateFin_pattern) .parse(value_tContextLoad_3)); } if (key_tContextLoad_3 != null && "CTX_PRM_Edeal_ASSO_FIL" .equals(key_tContextLoad_3)) { context.CTX_PRM_Edeal_ASSO_FIL = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_Edeal_ASSO_LIS" .equals(key_tContextLoad_3)) { context.CTX_PRM_Edeal_ASSO_LIS = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EdealBascounter" .equals(key_tContextLoad_3)) { context.CTX_PRM_EdealBascounter = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EdealBasid" .equals(key_tContextLoad_3)) { context.CTX_PRM_EdealBasid = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EdealCodeActor" .equals(key_tContextLoad_3)) { context.CTX_PRM_EdealCodeActor = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EdealIdActor" .equals(key_tContextLoad_3)) { context.CTX_PRM_EdealIdActor = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EdealLicence" .equals(key_tContextLoad_3)) { context.CTX_PRM_EdealLicence = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EncryptedPassword" .equals(key_tContextLoad_3)) { context.CTX_PRM_EncryptedPassword = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_Environnement" .equals(key_tContextLoad_3)) { context.CTX_PRM_Environnement = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_EQUALITING" .equals(key_tContextLoad_3)) { context.CTX_PRM_EQUALITING = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_Exec_RES" .equals(key_tContextLoad_3)) { context.CTX_PRM_Exec_RES = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_FichierConfiguration" .equals(key_tContextLoad_3)) { context.CTX_PRM_FichierConfiguration = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_FichierLog" .equals(key_tContextLoad_3)) { context.CTX_PRM_FichierLog = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_FichierLogs" .equals(key_tContextLoad_3)) { context.CTX_PRM_FichierLogs = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_FichierMetrique" .equals(key_tContextLoad_3)) { context.CTX_PRM_FichierMetrique = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_FichierStatistique" .equals(key_tContextLoad_3)) { context.CTX_PRM_FichierStatistique = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_fileEncodage" .equals(key_tContextLoad_3)) { context.CTX_PRM_fileEncodage = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_fileName" .equals(key_tContextLoad_3)) { context.CTX_PRM_fileName = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_IdAudit" .equals(key_tContextLoad_3)) { context.CTX_PRM_IdAudit = Long .parseLong(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_IdEtape" .equals(key_tContextLoad_3)) { context.CTX_PRM_IdEtape = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_IdEtapeDebut" .equals(key_tContextLoad_3)) { context.CTX_PRM_IdEtapeDebut = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_IdEtapeFin" .equals(key_tContextLoad_3)) { context.CTX_PRM_IdEtapeFin = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_listOfTableToDisableConstraints" .equals(key_tContextLoad_3)) { context.CTX_PRM_listOfTableToDisableConstraints = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_LKPCursorSize" .equals(key_tContextLoad_3)) { context.CTX_PRM_LKPCursorSize = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_NomAppliSource" .equals(key_tContextLoad_3)) { context.CTX_PRM_NomAppliSource = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_NomSource" .equals(key_tContextLoad_3)) { context.CTX_PRM_NomSource = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_OLAKALA_ERROR" .equals(key_tContextLoad_3)) { context.CTX_PRM_OLAKALA_ERROR = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_OLAKALA_FINISHED" .equals(key_tContextLoad_3)) { context.CTX_PRM_OLAKALA_FINISHED = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_OLAKALA_PROGRESS" .equals(key_tContextLoad_3)) { context.CTX_PRM_OLAKALA_PROGRESS = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_ProfondeurRetentionLogs" .equals(key_tContextLoad_3)) { context.CTX_PRM_ProfondeurRetentionLogs = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_ProfondeurRetentionRejets" .equals(key_tContextLoad_3)) { context.CTX_PRM_ProfondeurRetentionRejets = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireConf" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireConf = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireData" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireData = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireDataArchive" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireDataArchive = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireDataIn" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireDataIn = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireDataOut" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireDataOut = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireLog" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireLog = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireRacine" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireRacine = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireSql" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireSql = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RepertoireTmp" .equals(key_tContextLoad_3)) { context.CTX_PRM_RepertoireTmp = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_RESERVIT" .equals(key_tContextLoad_3)) { context.CTX_PRM_RESERVIT = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_SoucheVersion" .equals(key_tContextLoad_3)) { context.CTX_PRM_SoucheVersion = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_SRCCursorSize" .equals(key_tContextLoad_3)) { context.CTX_PRM_SRCCursorSize = Integer .parseInt(value_tContextLoad_3); } if (key_tContextLoad_3 != null && "CTX_PRM_TalendRootPackage" .equals(key_tContextLoad_3)) { context.CTX_PRM_TalendRootPackage = value_tContextLoad_3; } if (key_tContextLoad_3 != null && "CTX_PRM_TalendRootPid" .equals(key_tContextLoad_3)) { context.CTX_PRM_TalendRootPid = value_tContextLoad_3; } if (context.getProperty(key_tContextLoad_3) != null) { assignList_tContextLoad_3 .add(key_tContextLoad_3); } else { newPropertyList_tContextLoad_3 .add(key_tContextLoad_3); } if (value_tContextLoad_3 == null) { context.setProperty(key_tContextLoad_3, ""); } else { context.setProperty(key_tContextLoad_3, value_tContextLoad_3); } } catch (java.lang.Exception e) { System.err.println("Setting a value for the key \"" + key_tContextLoad_3 + "\" has failed. Error message: " + e.getMessage()); } nb_line_tContextLoad_3++; } // //////////////////////// tos_count_tContextLoad_3++; /** * [tContextLoad_3 main ] stop */ } // C_01 /** * [tRunJob_2 end ] start */ currentComponent = "tRunJob_2"; ok_Hash.put("tRunJob_2", true); end_Hash.put("tRunJob_2", System.currentTimeMillis()); /** * [tRunJob_2 end ] stop */ /** * [tContextLoad_3 end ] start */ currentComponent = "tContextLoad_3"; java.util.Enumeration<?> enu_tContextLoad_3 = context .propertyNames(); while (enu_tContextLoad_3.hasMoreElements()) { String key_tContextLoad_3 = (String) enu_tContextLoad_3 .nextElement(); if (!assignList_tContextLoad_3.contains(key_tContextLoad_3) && !newPropertyList_tContextLoad_3 .contains(key_tContextLoad_3)) { noAssignList_tContextLoad_3.add(key_tContextLoad_3); } } String newPropertyStr_tContextLoad_3 = newPropertyList_tContextLoad_3 .toString(); String newProperty_tContextLoad_3 = newPropertyStr_tContextLoad_3 .substring(1, newPropertyStr_tContextLoad_3.length() - 1); String noAssignStr_tContextLoad_3 = noAssignList_tContextLoad_3 .toString(); String noAssign_tContextLoad_3 = noAssignStr_tContextLoad_3 .substring(1, noAssignStr_tContextLoad_3.length() - 1); globalMap.put("tContextLoad_3_KEY_NOT_INCONTEXT", newProperty_tContextLoad_3); globalMap.put("tContextLoad_3_KEY_NOT_LOADED", noAssign_tContextLoad_3); globalMap.put("tContextLoad_3_NB_LINE", nb_line_tContextLoad_3); List<String> parametersToEncrypt_tContextLoad_3 = new java.util.ArrayList<String>(); parametersToEncrypt_tContextLoad_3.add("CTX_EMAIL_Password"); parametersToEncrypt_tContextLoad_3 .add("CTX_PGS_COMPTAFIL_Password"); parametersToEncrypt_tContextLoad_3 .add("CTX_PGS_COMPTALIS_Password"); parametersToEncrypt_tContextLoad_3.add("CTX_PGS_CRM_Password"); parametersToEncrypt_tContextLoad_3.add("CTX_PGS_DSA_Password"); parametersToEncrypt_tContextLoad_3.add("CTX_PGS_ODS_Password"); resumeUtil.addLog("NODE", "NODE:tContextLoad_3", "", Thread .currentThread().getId() + "", "", "", "", "", resumeUtil.convertToJsonText(context, parametersToEncrypt_tContextLoad_3)); ok_Hash.put("tContextLoad_3", true); end_Hash.put("tContextLoad_3", System.currentTimeMillis()); /** * [tContextLoad_3 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tRunJob_2 finally ] start */ currentComponent = "tRunJob_2"; /** * [tRunJob_2 finally ] stop */ /** * [tContextLoad_3 finally ] start */ currentComponent = "tContextLoad_3"; /** * [tContextLoad_3 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tRunJob_2_SUBPROCESS_STATE", 1); } public void tDie_2Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tDie_2_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tDie_2 begin ] start */ ok_Hash.put("tDie_2", false); start_Hash.put("tDie_2", System.currentTimeMillis()); currentComponent = "tDie_2"; int tos_count_tDie_2 = 0; /** * [tDie_2 begin ] stop */ /** * [tDie_2 main ] start */ currentComponent = "tDie_2"; globalMap.put("tDie_2_DIE_PRIORITY", 6); System.err.println(CustomMessage .getProcessError(context.CTX_PRM_NomSource + "__MRJ__ALIMENTATION")); globalMap.put( "tDie_2_DIE_MESSAGE", CustomMessage.getProcessError(context.CTX_PRM_NomSource + "__MRJ__ALIMENTATION")); globalMap.put( "tDie_2_DIE_MESSAGES", CustomMessage.getProcessError(context.CTX_PRM_NomSource + "__MRJ__ALIMENTATION")); currentComponent = "tDie_2"; status = "failure"; errorCode = new Integer(CustomCode.getErrorCode()); globalMap.put("tDie_2_DIE_CODE", errorCode); if (true) { throw new TDieException(); } tos_count_tDie_2++; /** * [tDie_2 main ] stop */ /** * [tDie_2 end ] start */ currentComponent = "tDie_2"; ok_Hash.put("tDie_2", true); end_Hash.put("tDie_2", System.currentTimeMillis()); /** * [tDie_2 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tDie_2 finally ] start */ currentComponent = "tDie_2"; /** * [tDie_2 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tDie_2_SUBPROCESS_STATE", 1); } public void tDie_1Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tDie_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tDie_1 begin ] start */ ok_Hash.put("tDie_1", false); start_Hash.put("tDie_1", System.currentTimeMillis()); currentComponent = "tDie_1"; int tos_count_tDie_1 = 0; /** * [tDie_1 begin ] stop */ /** * [tDie_1 main ] start */ currentComponent = "tDie_1"; globalMap.put("tDie_1_DIE_PRIORITY", 6); System.err .println("Un probl\u00e8me est survenu lors du chargement des param\u00e8tres du fichier de configuration " + context.CTX_PRM_FichierConfiguration); globalMap .put("tDie_1_DIE_MESSAGE", "Un probl\u00e8me est survenu lors du chargement des param\u00e8tres du fichier de configuration " + context.CTX_PRM_FichierConfiguration); globalMap .put("tDie_1_DIE_MESSAGES", "Un probl\u00e8me est survenu lors du chargement des param\u00e8tres du fichier de configuration " + context.CTX_PRM_FichierConfiguration); currentComponent = "tDie_1"; status = "failure"; errorCode = new Integer(CustomCode.getErrorCode()); globalMap.put("tDie_1_DIE_CODE", errorCode); if (true) { throw new TDieException(); } tos_count_tDie_1++; /** * [tDie_1 main ] stop */ /** * [tDie_1 end ] start */ currentComponent = "tDie_1"; ok_Hash.put("tDie_1", true); end_Hash.put("tDie_1", System.currentTimeMillis()); /** * [tDie_1 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tDie_1 finally ] start */ currentComponent = "tDie_1"; /** * [tDie_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tDie_1_SUBPROCESS_STATE", 1); } public void tPostjob_1Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tPostjob_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tPostjob_1 begin ] start */ ok_Hash.put("tPostjob_1", false); start_Hash.put("tPostjob_1", System.currentTimeMillis()); currentComponent = "tPostjob_1"; int tos_count_tPostjob_1 = 0; /** * [tPostjob_1 begin ] stop */ /** * [tPostjob_1 main ] start */ currentComponent = "tPostjob_1"; tos_count_tPostjob_1++; /** * [tPostjob_1 main ] stop */ /** * [tPostjob_1 end ] start */ currentComponent = "tPostjob_1"; ok_Hash.put("tPostjob_1", true); end_Hash.put("tPostjob_1", System.currentTimeMillis()); tJava_2Process(globalMap); /** * [tPostjob_1 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tPostjob_1 finally ] start */ currentComponent = "tPostjob_1"; /** * [tPostjob_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tPostjob_1_SUBPROCESS_STATE", 1); } public void tJava_2Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tJava_2_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tJava_2 begin ] start */ ok_Hash.put("tJava_2", false); start_Hash.put("tJava_2", System.currentTimeMillis()); currentComponent = "tJava_2"; int tos_count_tJava_2 = 0; context.CTX_PRM_FichierStatistique = context.CTX_PRM_RepertoireLog + context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".stat"; context.CTX_PRM_FichierLog = context.CTX_PRM_RepertoireLog + context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".log"; context.CTX_PRM_FichierMetrique = context.CTX_PRM_RepertoireLog + context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".meter"; context.CTX_PRM_FichierLogs = context.CTX_PRM_RepertoireLog + context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".html"; context.CTX_PRM_ArchiveLogs = context.CTX_PRM_RepertoireLog + context.CTX_PRM_NomSource + "_" + context.CTX_PRM_TalendRootPackage + "_" + TalendDate.formatDate("yyyyMMddHHmmss", context.CTX_PRM_DateDebut) + "_" + rootPid + ".zip"; /** * [tJava_2 begin ] stop */ /** * [tJava_2 main ] start */ currentComponent = "tJava_2"; tos_count_tJava_2++; /** * [tJava_2 main ] stop */ /** * [tJava_2 end ] start */ currentComponent = "tJava_2"; ok_Hash.put("tJava_2", true); end_Hash.put("tJava_2", System.currentTimeMillis()); /** * [tJava_2 end ] stop */ }// end the resume if (resumeEntryMethodName == null || globalResumeTicket) { resumeUtil.addLog("CHECKPOINT", "CONNECTION:SUBJOB_OK:tJava_2:OnSubjobOk", "", Thread .currentThread().getId() + "", "", "", "", "", ""); } tRunJob_3Process(globalMap); } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tJava_2 finally ] start */ currentComponent = "tJava_2"; /** * [tJava_2 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tJava_2_SUBPROCESS_STATE", 1); } public static class OUT__GEN_LOGSStruct implements routines.system.IPersistableRow<OUT__GEN_LOGSStruct> { final static byte[] commonByteArrayLock_FIL_GALAXIE_GALAXIE__PCKG = new byte[0]; static byte[] commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[0]; public String key; public String getKey() { return this.key; } public String value; public String getValue() { return this.value; } private String readString(ObjectInputStream dis) throws IOException { String strReturn = null; int length = 0; length = dis.readInt(); if (length == -1) { strReturn = null; } else { if (length > commonByteArray_FIL_GALAXIE_GALAXIE__PCKG.length) { if (length < 1024 && commonByteArray_FIL_GALAXIE_GALAXIE__PCKG.length == 0) { commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[1024]; } else { commonByteArray_FIL_GALAXIE_GALAXIE__PCKG = new byte[2 * length]; } } dis.readFully(commonByteArray_FIL_GALAXIE_GALAXIE__PCKG, 0, length); strReturn = new String( commonByteArray_FIL_GALAXIE_GALAXIE__PCKG, 0, length, utf8Charset); } return strReturn; } private void writeString(String str, ObjectOutputStream dos) throws IOException { if (str == null) { dos.writeInt(-1); } else { byte[] byteArray = str.getBytes(utf8Charset); dos.writeInt(byteArray.length); dos.write(byteArray); } } public void readData(ObjectInputStream dis) { synchronized (commonByteArrayLock_FIL_GALAXIE_GALAXIE__PCKG) { try { int length = 0; this.key = readString(dis); this.value = readString(dis); } catch (IOException e) { throw new RuntimeException(e); } } } public void writeData(ObjectOutputStream dos) { try { // String writeString(this.key, dos); // String writeString(this.value, dos); } catch (IOException e) { throw new RuntimeException(e); } } public String toString() { StringBuilder sb = new StringBuilder(); sb.append(super.toString()); sb.append("["); sb.append("key=" + key); sb.append(",value=" + value); sb.append("]"); return sb.toString(); } /** * Compare keys */ public int compareTo(OUT__GEN_LOGSStruct other) { int returnValue = -1; return returnValue; } private int checkNullsAndCompare(Object object1, Object object2) { int returnValue = 0; if (object1 instanceof Comparable && object2 instanceof Comparable) { returnValue = ((Comparable) object1).compareTo(object2); } else if (object1 != null && object2 != null) { returnValue = compareStrings(object1.toString(), object2.toString()); } else if (object1 == null && object2 != null) { returnValue = 1; } else if (object1 != null && object2 == null) { returnValue = -1; } else { returnValue = 0; } return returnValue; } private int compareStrings(String string1, String string2) { return string1.compareTo(string2); } } public void tRunJob_3Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tRunJob_3_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; OUT__GEN_LOGSStruct OUT__GEN_LOGS = new OUT__GEN_LOGSStruct(); /** * [tContextLoad_2 begin ] start */ ok_Hash.put("tContextLoad_2", false); start_Hash.put("tContextLoad_2", System.currentTimeMillis()); currentComponent = "tContextLoad_2"; int tos_count_tContextLoad_2 = 0; java.util.List<String> assignList_tContextLoad_2 = new java.util.ArrayList<String>(); java.util.List<String> newPropertyList_tContextLoad_2 = new java.util.ArrayList<String>(); java.util.List<String> noAssignList_tContextLoad_2 = new java.util.ArrayList<String>(); int nb_line_tContextLoad_2 = 0; /** * [tContextLoad_2 begin ] stop */ /** * [tRunJob_3 begin ] start */ ok_Hash.put("tRunJob_3", false); start_Hash.put("tRunJob_3", System.currentTimeMillis()); currentComponent = "tRunJob_3"; int tos_count_tRunJob_3 = 0; /** * [tRunJob_3 begin ] stop */ /** * [tRunJob_3 main ] start */ currentComponent = "tRunJob_3"; java.util.List<String> paraList_tRunJob_3 = new java.util.ArrayList<String>(); paraList_tRunJob_3.add("--father_pid=" + pid); paraList_tRunJob_3.add("--root_pid=" + rootPid); paraList_tRunJob_3.add("--father_node=tRunJob_3"); paraList_tRunJob_3.add("--context=RE7"); // for feature:10589 paraList_tRunJob_3.add("--stat_port=" + portStats); if (resuming_logs_dir_path != null) { paraList_tRunJob_3.add("--resuming_logs_dir_path=" + resuming_logs_dir_path); } String childResumePath_tRunJob_3 = ResumeUtil .getChildJobCheckPointPath(resuming_checkpoint_path); String tRunJobName_tRunJob_3 = ResumeUtil .getRighttRunJob(resuming_checkpoint_path); if ("tRunJob_3".equals(tRunJobName_tRunJob_3) && childResumePath_tRunJob_3 != null) { paraList_tRunJob_3 .add("--resuming_checkpoint_path=" + ResumeUtil .getChildJobCheckPointPath(resuming_checkpoint_path)); } paraList_tRunJob_3.add("--parent_part_launcher=JOB:" + jobName + "/NODE:tRunJob_3"); java.util.Map<String, Object> parentContextMap_tRunJob_3 = new java.util.HashMap<String, Object>(); context.synchronizeContext(); java.util.Enumeration<?> propertyNames_tRunJob_3 = context .propertyNames(); while (propertyNames_tRunJob_3.hasMoreElements()) { String key_tRunJob_3 = (String) propertyNames_tRunJob_3 .nextElement(); Object value_tRunJob_3 = (Object) context .get(key_tRunJob_3); paraList_tRunJob_3.add("--context_param " + key_tRunJob_3 + "=" + value_tRunJob_3); } parentContextMap_tRunJob_3.put("CTX_EMAIL_Destinataire", context.CTX_EMAIL_Destinataire); parentContextMap_tRunJob_3.put("CTX_EMAIL_Destinataire_copie", context.CTX_EMAIL_Destinataire_copie); parentContextMap_tRunJob_3.put( "CTX_EMAIL_Destinataire_copie_cachee", context.CTX_EMAIL_Destinataire_copie_cachee); parentContextMap_tRunJob_3.put("CTX_EMAIL_Emetteur", context.CTX_EMAIL_Emetteur); parentContextMap_tRunJob_3.put("CTX_EMAIL_Envoi_active", context.CTX_EMAIL_Envoi_active); parentContextMap_tRunJob_3.put("CTX_EMAIL_Login", context.CTX_EMAIL_Login); parentContextMap_tRunJob_3.put("CTX_EMAIL_Password", context.CTX_EMAIL_Password); parentContextMap_tRunJob_3.put("CTX_EMAIL_Serveur_port", context.CTX_EMAIL_Serveur_port); parentContextMap_tRunJob_3.put("CTX_EMAIL_Serveur_SMTP", context.CTX_EMAIL_Serveur_SMTP); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTAFIL_Database", context.CTX_PGS_COMPTAFIL_Database); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTAFIL_Login", context.CTX_PGS_COMPTAFIL_Login); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTAFIL_Password", context.CTX_PGS_COMPTAFIL_Password); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTAFIL_Port", context.CTX_PGS_COMPTAFIL_Port); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTAFIL_Schema", context.CTX_PGS_COMPTAFIL_Schema); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTAFIL_Server", context.CTX_PGS_COMPTAFIL_Server); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTALIS_Database", context.CTX_PGS_COMPTALIS_Database); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTALIS_Login", context.CTX_PGS_COMPTALIS_Login); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTALIS_Password", context.CTX_PGS_COMPTALIS_Password); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTALIS_Port", context.CTX_PGS_COMPTALIS_Port); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTALIS_Schema", context.CTX_PGS_COMPTALIS_Schema); parentContextMap_tRunJob_3.put("CTX_PGS_COMPTALIS_Server", context.CTX_PGS_COMPTALIS_Server); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_CommitInterval", context.CTX_PGS_CRM_CommitInterval); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_Database", context.CTX_PGS_CRM_Database); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_Login", context.CTX_PGS_CRM_Login); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_Password", context.CTX_PGS_CRM_Password); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_Port", context.CTX_PGS_CRM_Port); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_Schema", context.CTX_PGS_CRM_Schema); parentContextMap_tRunJob_3.put("CTX_PGS_CRM_Server", context.CTX_PGS_CRM_Server); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_CommitInterval", context.CTX_PGS_DSA_CommitInterval); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_Database", context.CTX_PGS_DSA_Database); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_Login", context.CTX_PGS_DSA_Login); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_Password", context.CTX_PGS_DSA_Password); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_Port", context.CTX_PGS_DSA_Port); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_Schema", context.CTX_PGS_DSA_Schema); parentContextMap_tRunJob_3.put("CTX_PGS_DSA_Server", context.CTX_PGS_DSA_Server); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_CommitInterval", context.CTX_PGS_ODS_CommitInterval); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_Database", context.CTX_PGS_ODS_Database); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_Login", context.CTX_PGS_ODS_Login); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_Password", context.CTX_PGS_ODS_Password); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_Port", context.CTX_PGS_ODS_Port); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_Schema", context.CTX_PGS_ODS_Schema); parentContextMap_tRunJob_3.put("CTX_PGS_ODS_Server", context.CTX_PGS_ODS_Server); parentContextMap_tRunJob_3.put("CTX_PRM_ArchiveLogs", context.CTX_PRM_ArchiveLogs); parentContextMap_tRunJob_3.put("CTX_PRM_CEV", context.CTX_PRM_CEV); parentContextMap_tRunJob_3.put("CTX_PRM_CodeRetour", context.CTX_PRM_CodeRetour); parentContextMap_tRunJob_3.put("CTX_PRM_DateDebut", context.CTX_PRM_DateDebut); parentContextMap_tRunJob_3.put("CTX_PRM_DateFin", context.CTX_PRM_DateFin); parentContextMap_tRunJob_3.put("CTX_PRM_Edeal_ASSO_FIL", context.CTX_PRM_Edeal_ASSO_FIL); parentContextMap_tRunJob_3.put("CTX_PRM_Edeal_ASSO_LIS", context.CTX_PRM_Edeal_ASSO_LIS); parentContextMap_tRunJob_3.put("CTX_PRM_EdealBascounter", context.CTX_PRM_EdealBascounter); parentContextMap_tRunJob_3.put("CTX_PRM_EdealBasid", context.CTX_PRM_EdealBasid); parentContextMap_tRunJob_3.put("CTX_PRM_EdealCodeActor", context.CTX_PRM_EdealCodeActor); parentContextMap_tRunJob_3.put("CTX_PRM_EdealIdActor", context.CTX_PRM_EdealIdActor); parentContextMap_tRunJob_3.put("CTX_PRM_EdealLicence", context.CTX_PRM_EdealLicence); parentContextMap_tRunJob_3.put("CTX_PRM_EncryptedPassword", context.CTX_PRM_EncryptedPassword); parentContextMap_tRunJob_3.put("CTX_PRM_Environnement", context.CTX_PRM_Environnement); parentContextMap_tRunJob_3.put("CTX_PRM_EQUALITING", context.CTX_PRM_EQUALITING); parentContextMap_tRunJob_3.put("CTX_PRM_Exec_RES", context.CTX_PRM_Exec_RES); parentContextMap_tRunJob_3.put("CTX_PRM_FichierConfiguration", context.CTX_PRM_FichierConfiguration); parentContextMap_tRunJob_3.put("CTX_PRM_FichierLog", context.CTX_PRM_FichierLog); parentContextMap_tRunJob_3.put("CTX_PRM_FichierLogs", context.CTX_PRM_FichierLogs); parentContextMap_tRunJob_3.put("CTX_PRM_FichierMetrique", context.CTX_PRM_FichierMetrique); parentContextMap_tRunJob_3.put("CTX_PRM_FichierStatistique", context.CTX_PRM_FichierStatistique); parentContextMap_tRunJob_3.put("CTX_PRM_fileEncodage", context.CTX_PRM_fileEncodage); parentContextMap_tRunJob_3.put("CTX_PRM_fileName", context.CTX_PRM_fileName); parentContextMap_tRunJob_3.put("CTX_PRM_IdAudit", context.CTX_PRM_IdAudit); parentContextMap_tRunJob_3.put("CTX_PRM_IdEtape", context.CTX_PRM_IdEtape); parentContextMap_tRunJob_3.put("CTX_PRM_IdEtapeDebut", context.CTX_PRM_IdEtapeDebut); parentContextMap_tRunJob_3.put("CTX_PRM_IdEtapeFin", context.CTX_PRM_IdEtapeFin); parentContextMap_tRunJob_3.put( "CTX_PRM_listOfTableToDisableConstraints", context.CTX_PRM_listOfTableToDisableConstraints); parentContextMap_tRunJob_3.put("CTX_PRM_LKPCursorSize", context.CTX_PRM_LKPCursorSize); parentContextMap_tRunJob_3.put("CTX_PRM_NomAppliSource", context.CTX_PRM_NomAppliSource); parentContextMap_tRunJob_3.put("CTX_PRM_NomSource", context.CTX_PRM_NomSource); parentContextMap_tRunJob_3.put("CTX_PRM_OLAKALA_ERROR", context.CTX_PRM_OLAKALA_ERROR); parentContextMap_tRunJob_3.put("CTX_PRM_OLAKALA_FINISHED", context.CTX_PRM_OLAKALA_FINISHED); parentContextMap_tRunJob_3.put("CTX_PRM_OLAKALA_PROGRESS", context.CTX_PRM_OLAKALA_PROGRESS); parentContextMap_tRunJob_3.put( "CTX_PRM_ProfondeurRetentionLogs", context.CTX_PRM_ProfondeurRetentionLogs); parentContextMap_tRunJob_3.put( "CTX_PRM_ProfondeurRetentionRejets", context.CTX_PRM_ProfondeurRetentionRejets); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireConf", context.CTX_PRM_RepertoireConf); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireData", context.CTX_PRM_RepertoireData); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireDataArchive", context.CTX_PRM_RepertoireDataArchive); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireDataIn", context.CTX_PRM_RepertoireDataIn); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireDataOut", context.CTX_PRM_RepertoireDataOut); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireLog", context.CTX_PRM_RepertoireLog); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireRacine", context.CTX_PRM_RepertoireRacine); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireSql", context.CTX_PRM_RepertoireSql); parentContextMap_tRunJob_3.put("CTX_PRM_RepertoireTmp", context.CTX_PRM_RepertoireTmp); parentContextMap_tRunJob_3.put("CTX_PRM_RESERVIT", context.CTX_PRM_RESERVIT); parentContextMap_tRunJob_3.put("CTX_PRM_SoucheVersion", context.CTX_PRM_SoucheVersion); parentContextMap_tRunJob_3.put("CTX_PRM_SRCCursorSize", context.CTX_PRM_SRCCursorSize); parentContextMap_tRunJob_3.put("CTX_PRM_TalendRootPackage", context.CTX_PRM_TalendRootPackage); parentContextMap_tRunJob_3.put("CTX_PRM_TalendRootPid", context.CTX_PRM_TalendRootPid); Object obj_tRunJob_3 = null; fil_galaxie.util__mrj__gen__logs_0_1.UTIL__MRJ__GEN__LOGS childJob_tRunJob_3 = new fil_galaxie.util__mrj__gen__logs_0_1.UTIL__MRJ__GEN__LOGS(); // pass DataSources java.util.Map<String, routines.system.TalendDataSource> talendDataSources_tRunJob_3 = (java.util.Map<String, routines.system.TalendDataSource>) globalMap .get(KEY_DB_DATASOURCES); if (null != talendDataSources_tRunJob_3) { java.util.Map<String, javax.sql.DataSource> dataSources_tRunJob_3 = new java.util.HashMap<String, javax.sql.DataSource>(); for (java.util.Map.Entry<String, routines.system.TalendDataSource> talendDataSourceEntry_tRunJob_3 : talendDataSources_tRunJob_3 .entrySet()) { dataSources_tRunJob_3.put( talendDataSourceEntry_tRunJob_3.getKey(), talendDataSourceEntry_tRunJob_3.getValue() .getRawDataSource()); } childJob_tRunJob_3.setDataSources(dataSources_tRunJob_3); } childJob_tRunJob_3.parentContextMap = parentContextMap_tRunJob_3; String[][] childReturn_tRunJob_3 = childJob_tRunJob_3 .runJob((String[]) paraList_tRunJob_3 .toArray(new String[paraList_tRunJob_3.size()])); errorCode = childJob_tRunJob_3.getErrorCode(); if (childJob_tRunJob_3.getErrorCode() == null) { globalMap.put( "tRunJob_3_CHILD_RETURN_CODE", childJob_tRunJob_3.getStatus() != null && ("failure").equals(childJob_tRunJob_3 .getStatus()) ? 1 : 0); } else { globalMap.put("tRunJob_3_CHILD_RETURN_CODE", childJob_tRunJob_3.getErrorCode()); } if (childJob_tRunJob_3.getExceptionStackTrace() != null) { globalMap.put("tRunJob_3_CHILD_EXCEPTION_STACKTRACE", childJob_tRunJob_3.getExceptionStackTrace()); } if (childJob_tRunJob_3.getErrorCode() != null || ("failure").equals(childJob_tRunJob_3.getStatus())) { throw new RuntimeException("Child job running failed"); } for (String[] item_tRunJob_3 : childReturn_tRunJob_3) { if (childJob_tRunJob_3.hastBufferOutputComponent() || true) { if (0 < item_tRunJob_3.length) { OUT__GEN_LOGS.key = item_tRunJob_3[0]; } else { OUT__GEN_LOGS.key = null; } if (1 < item_tRunJob_3.length) { OUT__GEN_LOGS.value = item_tRunJob_3[1]; } else { OUT__GEN_LOGS.value = null; } } tos_count_tRunJob_3++; /** * [tRunJob_3 main ] stop */ /** * [tContextLoad_2 main ] start */ currentComponent = "tContextLoad_2"; // //////////////////////// String tmp_key_tContextLoad_2 = null; String key_tContextLoad_2 = null; if (OUT__GEN_LOGS.key != null) { tmp_key_tContextLoad_2 = OUT__GEN_LOGS.key.trim(); if ((tmp_key_tContextLoad_2.startsWith("#") || tmp_key_tContextLoad_2 .startsWith("!"))) { tmp_key_tContextLoad_2 = null; } else { OUT__GEN_LOGS.key = tmp_key_tContextLoad_2; } } if (OUT__GEN_LOGS.key != null) { key_tContextLoad_2 = OUT__GEN_LOGS.key; } String value_tContextLoad_2 = null; if (OUT__GEN_LOGS.value != null) { value_tContextLoad_2 = OUT__GEN_LOGS.value; } if (tmp_key_tContextLoad_2 != null) { try { if (key_tContextLoad_2 != null && "CTX_EMAIL_Destinataire" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Destinataire = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Destinataire_copie" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Destinataire_copie = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Destinataire_copie_cachee" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Destinataire_copie_cachee = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Emetteur" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Emetteur = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Envoi_active" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Envoi_active = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_EMAIL_Login" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Login = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Password" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Password = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Serveur_port" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Serveur_port = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_EMAIL_Serveur_SMTP" .equals(key_tContextLoad_2)) { context.CTX_EMAIL_Serveur_SMTP = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTAFIL_Database" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTAFIL_Database = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTAFIL_Login" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTAFIL_Login = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTAFIL_Password" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTAFIL_Password = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTAFIL_Port" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTAFIL_Port = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTAFIL_Schema" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTAFIL_Schema = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTAFIL_Server" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTAFIL_Server = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTALIS_Database" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTALIS_Database = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTALIS_Login" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTALIS_Login = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTALIS_Password" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTALIS_Password = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTALIS_Port" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTALIS_Port = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTALIS_Schema" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTALIS_Schema = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_COMPTALIS_Server" .equals(key_tContextLoad_2)) { context.CTX_PGS_COMPTALIS_Server = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_CommitInterval" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_CommitInterval = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_Database" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_Database = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_Login" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_Login = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_Password" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_Password = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_Port" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_Port = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_Schema" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_Schema = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_CRM_Server" .equals(key_tContextLoad_2)) { context.CTX_PGS_CRM_Server = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_CommitInterval" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_CommitInterval = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_Database" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_Database = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_Login" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_Login = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_Password" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_Password = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_Port" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_Port = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_Schema" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_Schema = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_DSA_Server" .equals(key_tContextLoad_2)) { context.CTX_PGS_DSA_Server = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_CommitInterval" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_CommitInterval = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_Database" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_Database = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_Login" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_Login = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_Password" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_Password = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_Port" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_Port = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_Schema" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_Schema = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PGS_ODS_Server" .equals(key_tContextLoad_2)) { context.CTX_PGS_ODS_Server = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_ArchiveLogs" .equals(key_tContextLoad_2)) { context.CTX_PRM_ArchiveLogs = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_CEV".equals(key_tContextLoad_2)) { context.CTX_PRM_CEV = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_CodeRetour" .equals(key_tContextLoad_2)) { context.CTX_PRM_CodeRetour = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_DateDebut" .equals(key_tContextLoad_2)) { String context_CTX_PRM_DateDebut_value = context .getProperty("CTX_PRM_DateDebut"); if (context_CTX_PRM_DateDebut_value == null) context_CTX_PRM_DateDebut_value = ""; int context_CTX_PRM_DateDebut_pos = context_CTX_PRM_DateDebut_value .indexOf(";"); String context_CTX_PRM_DateDebut_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateDebut_pos > -1) { context_CTX_PRM_DateDebut_pattern = context_CTX_PRM_DateDebut_value .substring(0, context_CTX_PRM_DateDebut_pos); } context.CTX_PRM_DateDebut = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateDebut_pattern) .parse(value_tContextLoad_2)); } if (key_tContextLoad_2 != null && "CTX_PRM_DateFin" .equals(key_tContextLoad_2)) { String context_CTX_PRM_DateFin_value = context .getProperty("CTX_PRM_DateFin"); if (context_CTX_PRM_DateFin_value == null) context_CTX_PRM_DateFin_value = ""; int context_CTX_PRM_DateFin_pos = context_CTX_PRM_DateFin_value .indexOf(";"); String context_CTX_PRM_DateFin_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateFin_pos > -1) { context_CTX_PRM_DateFin_pattern = context_CTX_PRM_DateFin_value .substring(0, context_CTX_PRM_DateFin_pos); } context.CTX_PRM_DateFin = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateFin_pattern) .parse(value_tContextLoad_2)); } if (key_tContextLoad_2 != null && "CTX_PRM_Edeal_ASSO_FIL" .equals(key_tContextLoad_2)) { context.CTX_PRM_Edeal_ASSO_FIL = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_Edeal_ASSO_LIS" .equals(key_tContextLoad_2)) { context.CTX_PRM_Edeal_ASSO_LIS = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EdealBascounter" .equals(key_tContextLoad_2)) { context.CTX_PRM_EdealBascounter = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EdealBasid" .equals(key_tContextLoad_2)) { context.CTX_PRM_EdealBasid = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EdealCodeActor" .equals(key_tContextLoad_2)) { context.CTX_PRM_EdealCodeActor = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EdealIdActor" .equals(key_tContextLoad_2)) { context.CTX_PRM_EdealIdActor = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EdealLicence" .equals(key_tContextLoad_2)) { context.CTX_PRM_EdealLicence = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EncryptedPassword" .equals(key_tContextLoad_2)) { context.CTX_PRM_EncryptedPassword = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_Environnement" .equals(key_tContextLoad_2)) { context.CTX_PRM_Environnement = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_EQUALITING" .equals(key_tContextLoad_2)) { context.CTX_PRM_EQUALITING = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_Exec_RES" .equals(key_tContextLoad_2)) { context.CTX_PRM_Exec_RES = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_FichierConfiguration" .equals(key_tContextLoad_2)) { context.CTX_PRM_FichierConfiguration = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_FichierLog" .equals(key_tContextLoad_2)) { context.CTX_PRM_FichierLog = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_FichierLogs" .equals(key_tContextLoad_2)) { context.CTX_PRM_FichierLogs = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_FichierMetrique" .equals(key_tContextLoad_2)) { context.CTX_PRM_FichierMetrique = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_FichierStatistique" .equals(key_tContextLoad_2)) { context.CTX_PRM_FichierStatistique = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_fileEncodage" .equals(key_tContextLoad_2)) { context.CTX_PRM_fileEncodage = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_fileName" .equals(key_tContextLoad_2)) { context.CTX_PRM_fileName = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_IdAudit" .equals(key_tContextLoad_2)) { context.CTX_PRM_IdAudit = Long .parseLong(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_IdEtape" .equals(key_tContextLoad_2)) { context.CTX_PRM_IdEtape = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_IdEtapeDebut" .equals(key_tContextLoad_2)) { context.CTX_PRM_IdEtapeDebut = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_IdEtapeFin" .equals(key_tContextLoad_2)) { context.CTX_PRM_IdEtapeFin = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_listOfTableToDisableConstraints" .equals(key_tContextLoad_2)) { context.CTX_PRM_listOfTableToDisableConstraints = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_LKPCursorSize" .equals(key_tContextLoad_2)) { context.CTX_PRM_LKPCursorSize = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_NomAppliSource" .equals(key_tContextLoad_2)) { context.CTX_PRM_NomAppliSource = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_NomSource" .equals(key_tContextLoad_2)) { context.CTX_PRM_NomSource = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_OLAKALA_ERROR" .equals(key_tContextLoad_2)) { context.CTX_PRM_OLAKALA_ERROR = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_OLAKALA_FINISHED" .equals(key_tContextLoad_2)) { context.CTX_PRM_OLAKALA_FINISHED = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_OLAKALA_PROGRESS" .equals(key_tContextLoad_2)) { context.CTX_PRM_OLAKALA_PROGRESS = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_ProfondeurRetentionLogs" .equals(key_tContextLoad_2)) { context.CTX_PRM_ProfondeurRetentionLogs = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_ProfondeurRetentionRejets" .equals(key_tContextLoad_2)) { context.CTX_PRM_ProfondeurRetentionRejets = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireConf" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireConf = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireData" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireData = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireDataArchive" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireDataArchive = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireDataIn" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireDataIn = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireDataOut" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireDataOut = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireLog" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireLog = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireRacine" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireRacine = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireSql" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireSql = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RepertoireTmp" .equals(key_tContextLoad_2)) { context.CTX_PRM_RepertoireTmp = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_RESERVIT" .equals(key_tContextLoad_2)) { context.CTX_PRM_RESERVIT = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_SoucheVersion" .equals(key_tContextLoad_2)) { context.CTX_PRM_SoucheVersion = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_SRCCursorSize" .equals(key_tContextLoad_2)) { context.CTX_PRM_SRCCursorSize = Integer .parseInt(value_tContextLoad_2); } if (key_tContextLoad_2 != null && "CTX_PRM_TalendRootPackage" .equals(key_tContextLoad_2)) { context.CTX_PRM_TalendRootPackage = value_tContextLoad_2; } if (key_tContextLoad_2 != null && "CTX_PRM_TalendRootPid" .equals(key_tContextLoad_2)) { context.CTX_PRM_TalendRootPid = value_tContextLoad_2; } if (context.getProperty(key_tContextLoad_2) != null) { assignList_tContextLoad_2 .add(key_tContextLoad_2); } else { newPropertyList_tContextLoad_2 .add(key_tContextLoad_2); } if (value_tContextLoad_2 == null) { context.setProperty(key_tContextLoad_2, ""); } else { context.setProperty(key_tContextLoad_2, value_tContextLoad_2); } } catch (java.lang.Exception e) { System.err.println("Setting a value for the key \"" + key_tContextLoad_2 + "\" has failed. Error message: " + e.getMessage()); } nb_line_tContextLoad_2++; } // //////////////////////// tos_count_tContextLoad_2++; /** * [tContextLoad_2 main ] stop */ } // C_01 /** * [tRunJob_3 end ] start */ currentComponent = "tRunJob_3"; ok_Hash.put("tRunJob_3", true); end_Hash.put("tRunJob_3", System.currentTimeMillis()); if (true) { tJava_3Process(globalMap); } if (context.CTX_EMAIL_Envoi_active != 1) { tFileDelete_1Process(globalMap); } if (// context.CTX_EMAIL_Envoi_active == 1 true) { tSendMail_1Process(globalMap); } /** * [tRunJob_3 end ] stop */ /** * [tContextLoad_2 end ] start */ currentComponent = "tContextLoad_2"; java.util.Enumeration<?> enu_tContextLoad_2 = context .propertyNames(); while (enu_tContextLoad_2.hasMoreElements()) { String key_tContextLoad_2 = (String) enu_tContextLoad_2 .nextElement(); if (!assignList_tContextLoad_2.contains(key_tContextLoad_2) && !newPropertyList_tContextLoad_2 .contains(key_tContextLoad_2)) { noAssignList_tContextLoad_2.add(key_tContextLoad_2); } } String newPropertyStr_tContextLoad_2 = newPropertyList_tContextLoad_2 .toString(); String newProperty_tContextLoad_2 = newPropertyStr_tContextLoad_2 .substring(1, newPropertyStr_tContextLoad_2.length() - 1); String noAssignStr_tContextLoad_2 = noAssignList_tContextLoad_2 .toString(); String noAssign_tContextLoad_2 = noAssignStr_tContextLoad_2 .substring(1, noAssignStr_tContextLoad_2.length() - 1); globalMap.put("tContextLoad_2_KEY_NOT_INCONTEXT", newProperty_tContextLoad_2); globalMap.put("tContextLoad_2_KEY_NOT_LOADED", noAssign_tContextLoad_2); globalMap.put("tContextLoad_2_NB_LINE", nb_line_tContextLoad_2); List<String> parametersToEncrypt_tContextLoad_2 = new java.util.ArrayList<String>(); parametersToEncrypt_tContextLoad_2.add("CTX_EMAIL_Password"); parametersToEncrypt_tContextLoad_2 .add("CTX_PGS_COMPTAFIL_Password"); parametersToEncrypt_tContextLoad_2 .add("CTX_PGS_COMPTALIS_Password"); parametersToEncrypt_tContextLoad_2.add("CTX_PGS_CRM_Password"); parametersToEncrypt_tContextLoad_2.add("CTX_PGS_DSA_Password"); parametersToEncrypt_tContextLoad_2.add("CTX_PGS_ODS_Password"); resumeUtil.addLog("NODE", "NODE:tContextLoad_2", "", Thread .currentThread().getId() + "", "", "", "", "", resumeUtil.convertToJsonText(context, parametersToEncrypt_tContextLoad_2)); ok_Hash.put("tContextLoad_2", true); end_Hash.put("tContextLoad_2", System.currentTimeMillis()); /** * [tContextLoad_2 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tRunJob_3 finally ] start */ currentComponent = "tRunJob_3"; /** * [tRunJob_3 finally ] stop */ /** * [tContextLoad_2 finally ] start */ currentComponent = "tContextLoad_2"; /** * [tContextLoad_2 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tRunJob_3_SUBPROCESS_STATE", 1); } public void tJava_3Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tJava_3_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tJava_3 begin ] start */ ok_Hash.put("tJava_3", false); start_Hash.put("tJava_3", System.currentTimeMillis()); currentComponent = "tJava_3"; int tos_count_tJava_3 = 0; /** * [tJava_3 begin ] stop */ /** * [tJava_3 main ] start */ currentComponent = "tJava_3"; tos_count_tJava_3++; /** * [tJava_3 main ] stop */ /** * [tJava_3 end ] start */ currentComponent = "tJava_3"; ok_Hash.put("tJava_3", true); end_Hash.put("tJava_3", System.currentTimeMillis()); if (context.CTX_PRM_CodeRetour != null && context.CTX_PRM_CodeRetour > 0 && context.CTX_PRM_CodeRetour < 50) { tWarn_1Process(globalMap); } if (context.CTX_PRM_CodeRetour == null || context.CTX_PRM_CodeRetour >= 50) { tWarn_2Process(globalMap); } /** * [tJava_3 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tJava_3 finally ] start */ currentComponent = "tJava_3"; /** * [tJava_3 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tJava_3_SUBPROCESS_STATE", 1); } public void tWarn_1Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tWarn_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tWarn_1 begin ] start */ ok_Hash.put("tWarn_1", false); start_Hash.put("tWarn_1", System.currentTimeMillis()); currentComponent = "tWarn_1"; int tos_count_tWarn_1 = 0; /** * [tWarn_1 begin ] stop */ /** * [tWarn_1 main ] start */ currentComponent = "tWarn_1"; resumeUtil .addLog("USER_DEF_LOG", "NODE:tWarn_1", "", Thread.currentThread().getId() + "", "WARN", "", "Des alertes ont \u00e9t\u00e9 soulev\u00e9es durant l'ex\u00e9cution. Veuillez consulter les logs afin d'en savoir plus.", "", ""); globalMap .put("tWarn_1_WARN_MESSAGES", "Des alertes ont \u00e9t\u00e9 soulev\u00e9es durant l'ex\u00e9cution. Veuillez consulter les logs afin d'en savoir plus."); globalMap.put("tWarn_1_WARN_PRIORITY", 4); globalMap.put("tWarn_1_WARN_CODE", context.CTX_PRM_CodeRetour); tos_count_tWarn_1++; /** * [tWarn_1 main ] stop */ /** * [tWarn_1 end ] start */ currentComponent = "tWarn_1"; ok_Hash.put("tWarn_1", true); end_Hash.put("tWarn_1", System.currentTimeMillis()); /** * [tWarn_1 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tWarn_1 finally ] start */ currentComponent = "tWarn_1"; /** * [tWarn_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tWarn_1_SUBPROCESS_STATE", 1); } public void tWarn_2Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tWarn_2_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tWarn_2 begin ] start */ ok_Hash.put("tWarn_2", false); start_Hash.put("tWarn_2", System.currentTimeMillis()); currentComponent = "tWarn_2"; int tos_count_tWarn_2 = 0; /** * [tWarn_2 begin ] stop */ /** * [tWarn_2 main ] start */ currentComponent = "tWarn_2"; resumeUtil .addLog("USER_DEF_LOG", "NODE:tWarn_2", "", Thread.currentThread().getId() + "", "WARN", "", "Des erreurs ont \u00e9t\u00e9 soulev\u00e9es durant l'ex\u00e9cution. Veuillez consulter les logs afin d'en savoir plus.", "", ""); globalMap .put("tWarn_2_WARN_MESSAGES", "Des erreurs ont \u00e9t\u00e9 soulev\u00e9es durant l'ex\u00e9cution. Veuillez consulter les logs afin d'en savoir plus."); globalMap.put("tWarn_2_WARN_PRIORITY", 4); globalMap.put("tWarn_2_WARN_CODE", context.CTX_PRM_CodeRetour); tos_count_tWarn_2++; /** * [tWarn_2 main ] stop */ /** * [tWarn_2 end ] start */ currentComponent = "tWarn_2"; ok_Hash.put("tWarn_2", true); end_Hash.put("tWarn_2", System.currentTimeMillis()); /** * [tWarn_2 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tWarn_2 finally ] start */ currentComponent = "tWarn_2"; /** * [tWarn_2 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tWarn_2_SUBPROCESS_STATE", 1); } public void tFileDelete_1Process( final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tFileDelete_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tFileDelete_1 begin ] start */ ok_Hash.put("tFileDelete_1", false); start_Hash.put("tFileDelete_1", System.currentTimeMillis()); currentComponent = "tFileDelete_1"; int tos_count_tFileDelete_1 = 0; /** * [tFileDelete_1 begin ] stop */ /** * [tFileDelete_1 main ] start */ currentComponent = "tFileDelete_1"; class DeleteFoldertFileDelete_1 { /** * delete all the sub-files in 'file' * * @param file */ public boolean delete(java.io.File file) { java.io.File[] files = file.listFiles(); for (int i = 0; i < files.length; i++) { if (files[i].isFile()) { files[i].delete(); } else if (files[i].isDirectory()) { if (!files[i].delete()) { delete(files[i]); } } } deleteDirectory(file); return file.delete(); } /** * delete all the sub-folders in 'file' * * @param file */ private void deleteDirectory(java.io.File file) { java.io.File[] filed = file.listFiles(); for (int i = 0; i < filed.length; i++) { if (filed[i].isDirectory()) { deleteDirectory(filed[i]); } filed[i].delete(); } } } java.io.File file_tFileDelete_1 = new java.io.File( context.CTX_PRM_FichierLogs); if (file_tFileDelete_1.exists() && file_tFileDelete_1.isFile()) { if (file_tFileDelete_1.delete()) { globalMap.put("tFileDelete_1_CURRENT_STATUS", "File deleted."); } else { globalMap.put("tFileDelete_1_CURRENT_STATUS", "No file deleted."); } } else { globalMap.put("tFileDelete_1_CURRENT_STATUS", "File does not exist or is invalid."); } globalMap.put("tFileDelete_1_DELETE_PATH", context.CTX_PRM_FichierLogs); tos_count_tFileDelete_1++; /** * [tFileDelete_1 main ] stop */ /** * [tFileDelete_1 end ] start */ currentComponent = "tFileDelete_1"; ok_Hash.put("tFileDelete_1", true); end_Hash.put("tFileDelete_1", System.currentTimeMillis()); /** * [tFileDelete_1 end ] stop */ }// end the resume } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tFileDelete_1 finally ] start */ currentComponent = "tFileDelete_1"; /** * [tFileDelete_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tFileDelete_1_SUBPROCESS_STATE", 1); } public void tSendMail_1Process(final java.util.Map<String, Object> globalMap) throws TalendException { globalMap.put("tSendMail_1_SUBPROCESS_STATE", 0); final boolean execStat = this.execStat; String iterateId = ""; String currentComponent = ""; java.util.Map<String, Object> resourceMap = new java.util.HashMap<String, Object>(); try { String currentMethodName = new java.lang.Exception() .getStackTrace()[0].getMethodName(); boolean resumeIt = currentMethodName.equals(resumeEntryMethodName); if (resumeEntryMethodName == null || resumeIt || globalResumeTicket) {// start // the // resume globalResumeTicket = true; /** * [tSendMail_1 begin ] start */ ok_Hash.put("tSendMail_1", false); start_Hash.put("tSendMail_1", System.currentTimeMillis()); currentComponent = "tSendMail_1"; int tos_count_tSendMail_1 = 0; /** * [tSendMail_1 begin ] stop */ /** * [tSendMail_1 main ] start */ currentComponent = "tSendMail_1"; String smtpHost_tSendMail_1 = context.CTX_EMAIL_Serveur_SMTP; String smtpPort_tSendMail_1 = context.CTX_EMAIL_Serveur_port; String from_tSendMail_1 = (context.CTX_EMAIL_Emetteur); String to_tSendMail_1 = (context.CTX_EMAIL_Destinataire) .replace(";", ","); String cc_tSendMail_1 = ((context.CTX_EMAIL_Destinataire_copie) == null || "" .equals(context.CTX_EMAIL_Destinataire_copie)) ? null : (context.CTX_EMAIL_Destinataire_copie).replace(";", ","); String bcc_tSendMail_1 = ((context.CTX_EMAIL_Destinataire_copie_cachee) == null || "" .equals(context.CTX_EMAIL_Destinataire_copie_cachee)) ? null : (context.CTX_EMAIL_Destinataire_copie_cachee) .replace(";", ","); String subject_tSendMail_1 = ("[" + context.CTX_PRM_NomSource + "][ALIMENTATION_TALEND][" + (context.CTX_PRM_CodeRetour == 0 ? "SUCCESS" : (context.CTX_PRM_CodeRetour > 0 && context.CTX_PRM_CodeRetour <= 50 ? "SUCCES AVEC REJETS" : "ERREUR")) + "] Fin de l'alimentation " + context.CTX_PRM_NomSource); java.util.List<java.util.Map<String, String>> headers_tSendMail_1 = new java.util.ArrayList<java.util.Map<String, String>>(); java.util.List<String> attachments_tSendMail_1 = new java.util.ArrayList<String>(); java.util.List<String> contentTransferEncoding_tSendMail_1 = new java.util.ArrayList<String>(); attachments_tSendMail_1.add(context.CTX_PRM_FichierLogs); contentTransferEncoding_tSendMail_1.add("DEFAULT"); attachments_tSendMail_1.add(context.CTX_PRM_ArchiveLogs); contentTransferEncoding_tSendMail_1.add("DEFAULT"); String message_tSendMail_1 = (("<p>Bonjour, <br><br>\n\nL'alimentation GALAXIE TALEND est désormais terminée avec succès.<br>\nVeuillez trouver ci-joint l'archive des logs applicatifs rassemblant les différentes informations et éventuellement les erreurs rencontrées durant l'alimentation.\n</p>\n\n<table>\n <thead>\n <tr>\n <th style=\"border : 1px solid\" colspan=\"3\">L'état d'exécution des JOBs d'import</th>\n </tr>\n </thead>\n <tbody>\n <tr>\n <td style=\"border : 1px solid\">CEV Clients</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")).get("CEV_CLIENTS") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">CEV Chéque</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CHEQUE_FID") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">CEV Transactions</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CHEQUE_FID") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RSERVIT Clients</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_CLIENTS") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RSERVIT Resas</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")).get("RESERVIT_RESA") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RESERVIT Dossier</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_DOSSIER") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">MKG Olakala</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")).get("MKG_OLAKALA") + "</td>\n </tr>\n </tbody>\n</table>\n<p>\nCordialement,\n</p>") == null || "" .equals("<p>Bonjour, <br><br>\n\nL'alimentation GALAXIE TALEND est désormais terminée avec succès.<br>\nVeuillez trouver ci-joint l'archive des logs applicatifs rassemblant les différentes informations et éventuellement les erreurs rencontrées durant l'alimentation.\n</p>\n\n<table>\n <thead>\n <tr>\n <th style=\"border : 1px solid\" colspan=\"3\">L'état d'exécution des JOBs d'import</th>\n </tr>\n </thead>\n <tbody>\n <tr>\n <td style=\"border : 1px solid\">CEV Clients</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CLIENTS") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">CEV Chéque</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CHEQUE_FID") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">CEV Transactions</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CHEQUE_FID") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RSERVIT Clients</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_CLIENTS") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RSERVIT Resas</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_RESA") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RESERVIT Dossier</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_DOSSIER") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">MKG Olakala</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("MKG_OLAKALA") + "</td>\n </tr>\n </tbody>\n</table>\n<p>\nCordialement,\n</p>")) ? "\"\"" : ("<p>Bonjour, <br><br>\n\nL'alimentation GALAXIE TALEND est désormais terminée avec succès.<br>\nVeuillez trouver ci-joint l'archive des logs applicatifs rassemblant les différentes informations et éventuellement les erreurs rencontrées durant l'alimentation.\n</p>\n\n<table>\n <thead>\n <tr>\n <th style=\"border : 1px solid\" colspan=\"3\">L'état d'exécution des JOBs d'import</th>\n </tr>\n </thead>\n <tbody>\n <tr>\n <td style=\"border : 1px solid\">CEV Clients</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CLIENTS") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">CEV Chéque</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CHEQUE_FID") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">CEV Transactions</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("CEV_CHEQUE_FID") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RSERVIT Clients</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_CLIENTS") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RSERVIT Resas</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_RESA") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">RESERVIT Dossier</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("RESERVIT_DOSSIER") + "</td>\n </tr>\n <tr>\n <td style=\"border : 1px solid\">MKG Olakala</td>\n <td></td>\n <td style=\"border : 1px solid\">" + (String) ((java.util.Map) globalMap .get("SharedMap_EXE_RES")) .get("MKG_OLAKALA") + "</td>\n </tr>\n </tbody>\n</table>\n<p>\nCordialement,\n</p>"); java.util.Properties props_tSendMail_1 = System.getProperties(); props_tSendMail_1.put("mail.smtp.host", smtpHost_tSendMail_1); props_tSendMail_1.put("mail.smtp.port", smtpPort_tSendMail_1); props_tSendMail_1.put("mail.mime.encodefilename", "true"); try { props_tSendMail_1.put("mail.smtp.auth", "false"); javax.mail.Session session_tSendMail_1 = javax.mail.Session .getInstance(props_tSendMail_1, null); javax.mail.Message msg_tSendMail_1 = new javax.mail.internet.MimeMessage( session_tSendMail_1); msg_tSendMail_1 .setFrom(new javax.mail.internet.InternetAddress( from_tSendMail_1, null)); msg_tSendMail_1.setRecipients( javax.mail.Message.RecipientType.TO, javax.mail.internet.InternetAddress.parse( to_tSendMail_1, false)); if (cc_tSendMail_1 != null) msg_tSendMail_1.setRecipients( javax.mail.Message.RecipientType.CC, javax.mail.internet.InternetAddress.parse( cc_tSendMail_1, false)); if (bcc_tSendMail_1 != null) msg_tSendMail_1.setRecipients( javax.mail.Message.RecipientType.BCC, javax.mail.internet.InternetAddress.parse( bcc_tSendMail_1, false)); msg_tSendMail_1.setSubject(subject_tSendMail_1); for (int i_tSendMail_1 = 0; i_tSendMail_1 < headers_tSendMail_1 .size(); i_tSendMail_1++) { java.util.Map<String, String> header_tSendMail_1 = headers_tSendMail_1 .get(i_tSendMail_1); msg_tSendMail_1.setHeader( header_tSendMail_1.get("KEY"), header_tSendMail_1.get("VALUE")); } msg_tSendMail_1.setSentDate(new Date()); msg_tSendMail_1.setHeader("X-Priority", "3"); // High->1 // Normal->3 // Low->5 javax.mail.Multipart mp_tSendMail_1 = new javax.mail.internet.MimeMultipart(); javax.mail.internet.MimeBodyPart mbpText_tSendMail_1 = new javax.mail.internet.MimeBodyPart(); mbpText_tSendMail_1.setText(message_tSendMail_1, "ISO-8859-15", "html"); mp_tSendMail_1.addBodyPart(mbpText_tSendMail_1); javax.mail.internet.MimeBodyPart mbpFile_tSendMail_1 = null; for (int i_tSendMail_1 = 0; i_tSendMail_1 < attachments_tSendMail_1 .size(); i_tSendMail_1++) { String filename_tSendMail_1 = attachments_tSendMail_1 .get(i_tSendMail_1); javax.activation.FileDataSource fds_tSendMail_1 = null; java.io.File file_tSendMail_1 = new java.io.File( filename_tSendMail_1); if (!file_tSendMail_1.exists()) { continue; } if (file_tSendMail_1.isDirectory()) { java.io.File[] subFiles_tSendMail_1 = file_tSendMail_1 .listFiles(); for (java.io.File subFile_tSendMail_1 : subFiles_tSendMail_1) { if (subFile_tSendMail_1.isFile()) { fds_tSendMail_1 = new javax.activation.FileDataSource( subFile_tSendMail_1 .getAbsolutePath()); mbpFile_tSendMail_1 = new javax.mail.internet.MimeBodyPart(); mbpFile_tSendMail_1 .setDataHandler(new javax.activation.DataHandler( fds_tSendMail_1)); mbpFile_tSendMail_1 .setFileName(javax.mail.internet.MimeUtility .encodeText(fds_tSendMail_1 .getName())); if (contentTransferEncoding_tSendMail_1 .get(i_tSendMail_1) .equalsIgnoreCase("base64")) { mbpFile_tSendMail_1.setHeader( "Content-Transfer-Encoding", "base64"); } mp_tSendMail_1 .addBodyPart(mbpFile_tSendMail_1); } } } else { mbpFile_tSendMail_1 = new javax.mail.internet.MimeBodyPart(); fds_tSendMail_1 = new javax.activation.FileDataSource( filename_tSendMail_1); mbpFile_tSendMail_1 .setDataHandler(new javax.activation.DataHandler( fds_tSendMail_1)); mbpFile_tSendMail_1 .setFileName(javax.mail.internet.MimeUtility .encodeText(fds_tSendMail_1 .getName())); if (contentTransferEncoding_tSendMail_1.get( i_tSendMail_1).equalsIgnoreCase("base64")) { mbpFile_tSendMail_1.setHeader( "Content-Transfer-Encoding", "base64"); } mp_tSendMail_1.addBodyPart(mbpFile_tSendMail_1); } } // -- set the content -- msg_tSendMail_1.setContent(mp_tSendMail_1); // add handlers for main MIME types javax.activation.MailcapCommandMap mc_tSendMail_1 = (javax.activation.MailcapCommandMap) javax.activation.CommandMap .getDefaultCommandMap(); mc_tSendMail_1 .addMailcap("text/html;; x-java-content-handler=com.sun.mail.handlers.text_html"); mc_tSendMail_1 .addMailcap("text/xml;; x-java-content-handler=com.sun.mail.handlers.text_xml"); mc_tSendMail_1 .addMailcap("text/plain;; x-java-content-handler=com.sun.mail.handlers.text_plain"); mc_tSendMail_1 .addMailcap("multipart/*;; x-java-content-handler=com.sun.mail.handlers.multipart_mixed"); mc_tSendMail_1 .addMailcap("message/rfc822;; x-java-content-handler=com.sun.mail.handlers.message_rfc822"); javax.activation.CommandMap .setDefaultCommandMap(mc_tSendMail_1); // -- Send the message -- javax.mail.Transport.send(msg_tSendMail_1); } catch (java.lang.Exception e) { throw (e); } finally { props_tSendMail_1.remove("mail.smtp.host"); props_tSendMail_1.remove("mail.smtp.port"); props_tSendMail_1.remove("mail.mime.encodefilename"); props_tSendMail_1.remove("mail.smtp.auth"); } tos_count_tSendMail_1++; /** * [tSendMail_1 main ] stop */ /** * [tSendMail_1 end ] start */ currentComponent = "tSendMail_1"; ok_Hash.put("tSendMail_1", true); end_Hash.put("tSendMail_1", System.currentTimeMillis()); /** * [tSendMail_1 end ] stop */ }// end the resume if (resumeEntryMethodName == null || globalResumeTicket) { resumeUtil .addLog("CHECKPOINT", "CONNECTION:SUBJOB_OK:tSendMail_1:OnSubjobOk", "", Thread.currentThread().getId() + "", "", "", "", "", ""); } tFileDelete_1Process(globalMap); } catch (java.lang.Exception e) { TalendException te = new TalendException(e, currentComponent, globalMap); throw te; } catch (java.lang.Error error) { throw error; } finally { try { /** * [tSendMail_1 finally ] start */ currentComponent = "tSendMail_1"; /** * [tSendMail_1 finally ] stop */ } catch (java.lang.Exception e) { // ignore } catch (java.lang.Error error) { // ignore } resourceMap = null; } globalMap.put("tSendMail_1_SUBPROCESS_STATE", 1); } public String resuming_logs_dir_path = null; public String resuming_checkpoint_path = null; public String parent_part_launcher = null; private String resumeEntryMethodName = null; private boolean globalResumeTicket = false; public boolean watch = false; // portStats is null, it means don't execute the statistics public Integer portStats = null; public int portTraces = 4334; public String clientHost; public String defaultClientHost = "localhost"; public String contextStr = "RE7"; public boolean isDefaultContext = true; public String pid = "0"; public String rootPid = null; public String fatherPid = null; public String fatherNode = null; public long startTime = 0; public boolean isChildJob = false; public String log4jLevel = ""; private boolean execStat = true; private ThreadLocal<java.util.Map<String, String>> threadLocal = new ThreadLocal<java.util.Map<String, String>>() { protected java.util.Map<String, String> initialValue() { java.util.Map<String, String> threadRunResultMap = new java.util.HashMap<String, String>(); threadRunResultMap.put("errorCode", null); threadRunResultMap.put("status", ""); return threadRunResultMap; }; }; private java.util.Properties context_param = new java.util.Properties(); public java.util.Map<String, Object> parentContextMap = new java.util.HashMap<String, Object>(); public String status = ""; public static void main(String[] args) { final GALAXIE__PCKG GALAXIE__PCKGClass = new GALAXIE__PCKG(); int exitCode = GALAXIE__PCKGClass.runJobInTOS(args); System.exit(exitCode); } public String[][] runJob(String[] args) { int exitCode = runJobInTOS(args); String[][] bufferValue = new String[][] { { Integer.toString(exitCode) } }; return bufferValue; } public boolean hastBufferOutputComponent() { boolean hastBufferOutput = false; return hastBufferOutput; } public int runJobInTOS(String[] args) { // reset status status = ""; String lastStr = ""; for (String arg : args) { if (arg.equalsIgnoreCase("--context_param")) { lastStr = arg; } else if (lastStr.equals("")) { evalParam(arg); } else { evalParam(lastStr + " " + arg); lastStr = ""; } } if (clientHost == null) { clientHost = defaultClientHost; } if (pid == null || "0".equals(pid)) { pid = TalendString.getAsciiRandomString(6); } if (rootPid == null) { rootPid = pid; } if (fatherPid == null) { fatherPid = pid; } else { isChildJob = true; } try { // call job/subjob with an existing context, like: // --context=production. if without this parameter, there will use // the default context instead. java.io.InputStream inContext = GALAXIE__PCKG.class .getClassLoader().getResourceAsStream( "fil_galaxie/galaxie__pckg_0_1/contexts/" + contextStr + ".properties"); if (isDefaultContext && inContext == null) { } else { if (inContext != null) { // defaultProps is in order to keep the original context // value defaultProps.load(inContext); inContext.close(); context = new ContextProperties(defaultProps); } else { // print info and job continue to run, for case: // context_param is not empty. System.err.println("Could not find the context " + contextStr); } } if (!context_param.isEmpty()) { context.putAll(context_param); } context.CTX_EMAIL_Destinataire = (String) context .getProperty("CTX_EMAIL_Destinataire"); context.CTX_EMAIL_Destinataire_copie = (String) context .getProperty("CTX_EMAIL_Destinataire_copie"); context.CTX_EMAIL_Destinataire_copie_cachee = (String) context .getProperty("CTX_EMAIL_Destinataire_copie_cachee"); context.CTX_EMAIL_Emetteur = (String) context .getProperty("CTX_EMAIL_Emetteur"); try { context.CTX_EMAIL_Envoi_active = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_EMAIL_Envoi_active")); } catch (NumberFormatException e) { context.CTX_EMAIL_Envoi_active = null; } context.CTX_EMAIL_Login = (String) context .getProperty("CTX_EMAIL_Login"); String pwd_CTX_EMAIL_Password_value = context .getProperty("CTX_EMAIL_Password"); context.CTX_EMAIL_Password = null; if (pwd_CTX_EMAIL_Password_value != null) { if (context_param.containsKey("CTX_EMAIL_Password")) {// no need // to // decrypt // if it // come // from // program // argument // or // parent // job // runtime context.CTX_EMAIL_Password = pwd_CTX_EMAIL_Password_value; } else if (!pwd_CTX_EMAIL_Password_value.isEmpty()) { try { context.CTX_EMAIL_Password = routines.system.PasswordEncryptUtil .decryptPassword(pwd_CTX_EMAIL_Password_value); context.put("CTX_EMAIL_Password", context.CTX_EMAIL_Password); } catch (java.lang.RuntimeException e) { // do nothing } } } context.CTX_EMAIL_Serveur_port = (String) context .getProperty("CTX_EMAIL_Serveur_port"); context.CTX_EMAIL_Serveur_SMTP = (String) context .getProperty("CTX_EMAIL_Serveur_SMTP"); context.CTX_PGS_COMPTAFIL_Database = (String) context .getProperty("CTX_PGS_COMPTAFIL_Database"); context.CTX_PGS_COMPTAFIL_Login = (String) context .getProperty("CTX_PGS_COMPTAFIL_Login"); String pwd_CTX_PGS_COMPTAFIL_Password_value = context .getProperty("CTX_PGS_COMPTAFIL_Password"); context.CTX_PGS_COMPTAFIL_Password = null; if (pwd_CTX_PGS_COMPTAFIL_Password_value != null) { if (context_param.containsKey("CTX_PGS_COMPTAFIL_Password")) {// no // need // to // decrypt // if // it // come // from // program // argument // or // parent // job // runtime context.CTX_PGS_COMPTAFIL_Password = pwd_CTX_PGS_COMPTAFIL_Password_value; } else if (!pwd_CTX_PGS_COMPTAFIL_Password_value.isEmpty()) { try { context.CTX_PGS_COMPTAFIL_Password = routines.system.PasswordEncryptUtil .decryptPassword(pwd_CTX_PGS_COMPTAFIL_Password_value); context.put("CTX_PGS_COMPTAFIL_Password", context.CTX_PGS_COMPTAFIL_Password); } catch (java.lang.RuntimeException e) { // do nothing } } } context.CTX_PGS_COMPTAFIL_Port = (String) context .getProperty("CTX_PGS_COMPTAFIL_Port"); context.CTX_PGS_COMPTAFIL_Schema = (String) context .getProperty("CTX_PGS_COMPTAFIL_Schema"); context.CTX_PGS_COMPTAFIL_Server = (String) context .getProperty("CTX_PGS_COMPTAFIL_Server"); context.CTX_PGS_COMPTALIS_Database = (String) context .getProperty("CTX_PGS_COMPTALIS_Database"); context.CTX_PGS_COMPTALIS_Login = (String) context .getProperty("CTX_PGS_COMPTALIS_Login"); String pwd_CTX_PGS_COMPTALIS_Password_value = context .getProperty("CTX_PGS_COMPTALIS_Password"); context.CTX_PGS_COMPTALIS_Password = null; if (pwd_CTX_PGS_COMPTALIS_Password_value != null) { if (context_param.containsKey("CTX_PGS_COMPTALIS_Password")) {// no // need // to // decrypt // if // it // come // from // program // argument // or // parent // job // runtime context.CTX_PGS_COMPTALIS_Password = pwd_CTX_PGS_COMPTALIS_Password_value; } else if (!pwd_CTX_PGS_COMPTALIS_Password_value.isEmpty()) { try { context.CTX_PGS_COMPTALIS_Password = routines.system.PasswordEncryptUtil .decryptPassword(pwd_CTX_PGS_COMPTALIS_Password_value); context.put("CTX_PGS_COMPTALIS_Password", context.CTX_PGS_COMPTALIS_Password); } catch (java.lang.RuntimeException e) { // do nothing } } } context.CTX_PGS_COMPTALIS_Port = (String) context .getProperty("CTX_PGS_COMPTALIS_Port"); context.CTX_PGS_COMPTALIS_Schema = (String) context .getProperty("CTX_PGS_COMPTALIS_Schema"); context.CTX_PGS_COMPTALIS_Server = (String) context .getProperty("CTX_PGS_COMPTALIS_Server"); try { context.CTX_PGS_CRM_CommitInterval = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PGS_CRM_CommitInterval")); } catch (NumberFormatException e) { context.CTX_PGS_CRM_CommitInterval = null; } context.CTX_PGS_CRM_Database = (String) context .getProperty("CTX_PGS_CRM_Database"); context.CTX_PGS_CRM_Login = (String) context .getProperty("CTX_PGS_CRM_Login"); String pwd_CTX_PGS_CRM_Password_value = context .getProperty("CTX_PGS_CRM_Password"); context.CTX_PGS_CRM_Password = null; if (pwd_CTX_PGS_CRM_Password_value != null) { if (context_param.containsKey("CTX_PGS_CRM_Password")) {// no // need // to // decrypt // if it // come // from // program // argument // or // parent // job // runtime context.CTX_PGS_CRM_Password = pwd_CTX_PGS_CRM_Password_value; } else if (!pwd_CTX_PGS_CRM_Password_value.isEmpty()) { try { context.CTX_PGS_CRM_Password = routines.system.PasswordEncryptUtil .decryptPassword(pwd_CTX_PGS_CRM_Password_value); context.put("CTX_PGS_CRM_Password", context.CTX_PGS_CRM_Password); } catch (java.lang.RuntimeException e) { // do nothing } } } context.CTX_PGS_CRM_Port = (String) context .getProperty("CTX_PGS_CRM_Port"); context.CTX_PGS_CRM_Schema = (String) context .getProperty("CTX_PGS_CRM_Schema"); context.CTX_PGS_CRM_Server = (String) context .getProperty("CTX_PGS_CRM_Server"); try { context.CTX_PGS_DSA_CommitInterval = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PGS_DSA_CommitInterval")); } catch (NumberFormatException e) { context.CTX_PGS_DSA_CommitInterval = null; } context.CTX_PGS_DSA_Database = (String) context .getProperty("CTX_PGS_DSA_Database"); context.CTX_PGS_DSA_Login = (String) context .getProperty("CTX_PGS_DSA_Login"); String pwd_CTX_PGS_DSA_Password_value = context .getProperty("CTX_PGS_DSA_Password"); context.CTX_PGS_DSA_Password = null; if (pwd_CTX_PGS_DSA_Password_value != null) { if (context_param.containsKey("CTX_PGS_DSA_Password")) {// no // need // to // decrypt // if it // come // from // program // argument // or // parent // job // runtime context.CTX_PGS_DSA_Password = pwd_CTX_PGS_DSA_Password_value; } else if (!pwd_CTX_PGS_DSA_Password_value.isEmpty()) { try { context.CTX_PGS_DSA_Password = routines.system.PasswordEncryptUtil .decryptPassword(pwd_CTX_PGS_DSA_Password_value); context.put("CTX_PGS_DSA_Password", context.CTX_PGS_DSA_Password); } catch (java.lang.RuntimeException e) { // do nothing } } } context.CTX_PGS_DSA_Port = (String) context .getProperty("CTX_PGS_DSA_Port"); context.CTX_PGS_DSA_Schema = (String) context .getProperty("CTX_PGS_DSA_Schema"); context.CTX_PGS_DSA_Server = (String) context .getProperty("CTX_PGS_DSA_Server"); try { context.CTX_PGS_ODS_CommitInterval = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PGS_ODS_CommitInterval")); } catch (NumberFormatException e) { context.CTX_PGS_ODS_CommitInterval = null; } context.CTX_PGS_ODS_Database = (String) context .getProperty("CTX_PGS_ODS_Database"); context.CTX_PGS_ODS_Login = (String) context .getProperty("CTX_PGS_ODS_Login"); String pwd_CTX_PGS_ODS_Password_value = context .getProperty("CTX_PGS_ODS_Password"); context.CTX_PGS_ODS_Password = null; if (pwd_CTX_PGS_ODS_Password_value != null) { if (context_param.containsKey("CTX_PGS_ODS_Password")) {// no // need // to // decrypt // if it // come // from // program // argument // or // parent // job // runtime context.CTX_PGS_ODS_Password = pwd_CTX_PGS_ODS_Password_value; } else if (!pwd_CTX_PGS_ODS_Password_value.isEmpty()) { try { context.CTX_PGS_ODS_Password = routines.system.PasswordEncryptUtil .decryptPassword(pwd_CTX_PGS_ODS_Password_value); context.put("CTX_PGS_ODS_Password", context.CTX_PGS_ODS_Password); } catch (java.lang.RuntimeException e) { // do nothing } } } context.CTX_PGS_ODS_Port = (String) context .getProperty("CTX_PGS_ODS_Port"); context.CTX_PGS_ODS_Schema = (String) context .getProperty("CTX_PGS_ODS_Schema"); context.CTX_PGS_ODS_Server = (String) context .getProperty("CTX_PGS_ODS_Server"); context.CTX_PRM_ArchiveLogs = (String) context .getProperty("CTX_PRM_ArchiveLogs"); context.CTX_PRM_CEV = (String) context.getProperty("CTX_PRM_CEV"); try { context.CTX_PRM_CodeRetour = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_CodeRetour")); } catch (NumberFormatException e) { context.CTX_PRM_CodeRetour = null; } try { String context_CTX_PRM_DateDebut_value = context .getProperty("CTX_PRM_DateDebut"); if (context_CTX_PRM_DateDebut_value == null) { context_CTX_PRM_DateDebut_value = ""; } int context_CTX_PRM_DateDebut_pos = context_CTX_PRM_DateDebut_value .indexOf(";"); String context_CTX_PRM_DateDebut_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateDebut_pos > -1) { context_CTX_PRM_DateDebut_pattern = context_CTX_PRM_DateDebut_value .substring(0, context_CTX_PRM_DateDebut_pos); context_CTX_PRM_DateDebut_value = context_CTX_PRM_DateDebut_value .substring(context_CTX_PRM_DateDebut_pos + 1); } context.CTX_PRM_DateDebut = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateDebut_pattern) .parse(context_CTX_PRM_DateDebut_value)); } catch (ParseException e) { context.CTX_PRM_DateDebut = null; } try { String context_CTX_PRM_DateFin_value = context .getProperty("CTX_PRM_DateFin"); if (context_CTX_PRM_DateFin_value == null) { context_CTX_PRM_DateFin_value = ""; } int context_CTX_PRM_DateFin_pos = context_CTX_PRM_DateFin_value .indexOf(";"); String context_CTX_PRM_DateFin_pattern = "yyyy-MM-dd HH:mm:ss"; if (context_CTX_PRM_DateFin_pos > -1) { context_CTX_PRM_DateFin_pattern = context_CTX_PRM_DateFin_value .substring(0, context_CTX_PRM_DateFin_pos); context_CTX_PRM_DateFin_value = context_CTX_PRM_DateFin_value .substring(context_CTX_PRM_DateFin_pos + 1); } context.CTX_PRM_DateFin = (java.util.Date) (new java.text.SimpleDateFormat( context_CTX_PRM_DateFin_pattern) .parse(context_CTX_PRM_DateFin_value)); } catch (ParseException e) { context.CTX_PRM_DateFin = null; } context.CTX_PRM_Edeal_ASSO_FIL = (String) context .getProperty("CTX_PRM_Edeal_ASSO_FIL"); context.CTX_PRM_Edeal_ASSO_LIS = (String) context .getProperty("CTX_PRM_Edeal_ASSO_LIS"); context.CTX_PRM_EdealBascounter = (String) context .getProperty("CTX_PRM_EdealBascounter"); context.CTX_PRM_EdealBasid = (String) context .getProperty("CTX_PRM_EdealBasid"); context.CTX_PRM_EdealCodeActor = (String) context .getProperty("CTX_PRM_EdealCodeActor"); context.CTX_PRM_EdealIdActor = (String) context .getProperty("CTX_PRM_EdealIdActor"); context.CTX_PRM_EdealLicence = (String) context .getProperty("CTX_PRM_EdealLicence"); try { context.CTX_PRM_EncryptedPassword = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_EncryptedPassword")); } catch (NumberFormatException e) { context.CTX_PRM_EncryptedPassword = null; } context.CTX_PRM_Environnement = (String) context .getProperty("CTX_PRM_Environnement"); context.CTX_PRM_EQUALITING = (String) context .getProperty("CTX_PRM_EQUALITING"); context.CTX_PRM_Exec_RES = (Object) context .getProperty("CTX_PRM_Exec_RES"); context.CTX_PRM_FichierConfiguration = (String) context .getProperty("CTX_PRM_FichierConfiguration"); context.CTX_PRM_FichierLog = (String) context .getProperty("CTX_PRM_FichierLog"); context.CTX_PRM_FichierLogs = (String) context .getProperty("CTX_PRM_FichierLogs"); context.CTX_PRM_FichierMetrique = (String) context .getProperty("CTX_PRM_FichierMetrique"); context.CTX_PRM_FichierStatistique = (String) context .getProperty("CTX_PRM_FichierStatistique"); context.CTX_PRM_fileEncodage = (String) context .getProperty("CTX_PRM_fileEncodage"); context.CTX_PRM_fileName = (String) context .getProperty("CTX_PRM_fileName"); try { context.CTX_PRM_IdAudit = routines.system.ParserUtils .parseTo_Long(context.getProperty("CTX_PRM_IdAudit")); } catch (NumberFormatException e) { context.CTX_PRM_IdAudit = null; } try { context.CTX_PRM_IdEtape = routines.system.ParserUtils .parseTo_Integer(context.getProperty("CTX_PRM_IdEtape")); } catch (NumberFormatException e) { context.CTX_PRM_IdEtape = null; } try { context.CTX_PRM_IdEtapeDebut = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_IdEtapeDebut")); } catch (NumberFormatException e) { context.CTX_PRM_IdEtapeDebut = null; } try { context.CTX_PRM_IdEtapeFin = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_IdEtapeFin")); } catch (NumberFormatException e) { context.CTX_PRM_IdEtapeFin = null; } context.CTX_PRM_listOfTableToDisableConstraints = (String) context .getProperty("CTX_PRM_listOfTableToDisableConstraints"); try { context.CTX_PRM_LKPCursorSize = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_LKPCursorSize")); } catch (NumberFormatException e) { context.CTX_PRM_LKPCursorSize = null; } context.CTX_PRM_NomAppliSource = (String) context .getProperty("CTX_PRM_NomAppliSource"); context.CTX_PRM_NomSource = (String) context .getProperty("CTX_PRM_NomSource"); context.CTX_PRM_OLAKALA_ERROR = (String) context .getProperty("CTX_PRM_OLAKALA_ERROR"); context.CTX_PRM_OLAKALA_FINISHED = (String) context .getProperty("CTX_PRM_OLAKALA_FINISHED"); context.CTX_PRM_OLAKALA_PROGRESS = (String) context .getProperty("CTX_PRM_OLAKALA_PROGRESS"); try { context.CTX_PRM_ProfondeurRetentionLogs = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_ProfondeurRetentionLogs")); } catch (NumberFormatException e) { context.CTX_PRM_ProfondeurRetentionLogs = null; } try { context.CTX_PRM_ProfondeurRetentionRejets = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_ProfondeurRetentionRejets")); } catch (NumberFormatException e) { context.CTX_PRM_ProfondeurRetentionRejets = null; } context.CTX_PRM_RepertoireConf = (String) context .getProperty("CTX_PRM_RepertoireConf"); context.CTX_PRM_RepertoireData = (String) context .getProperty("CTX_PRM_RepertoireData"); context.CTX_PRM_RepertoireDataArchive = (String) context .getProperty("CTX_PRM_RepertoireDataArchive"); context.CTX_PRM_RepertoireDataIn = (String) context .getProperty("CTX_PRM_RepertoireDataIn"); context.CTX_PRM_RepertoireDataOut = (String) context .getProperty("CTX_PRM_RepertoireDataOut"); context.CTX_PRM_RepertoireLog = (String) context .getProperty("CTX_PRM_RepertoireLog"); context.CTX_PRM_RepertoireRacine = (String) context .getProperty("CTX_PRM_RepertoireRacine"); context.CTX_PRM_RepertoireSql = (String) context .getProperty("CTX_PRM_RepertoireSql"); context.CTX_PRM_RepertoireTmp = (String) context .getProperty("CTX_PRM_RepertoireTmp"); context.CTX_PRM_RESERVIT = (String) context .getProperty("CTX_PRM_RESERVIT"); context.CTX_PRM_SoucheVersion = (String) context .getProperty("CTX_PRM_SoucheVersion"); try { context.CTX_PRM_SRCCursorSize = routines.system.ParserUtils .parseTo_Integer(context .getProperty("CTX_PRM_SRCCursorSize")); } catch (NumberFormatException e) { context.CTX_PRM_SRCCursorSize = null; } context.CTX_PRM_TalendRootPackage = (String) context .getProperty("CTX_PRM_TalendRootPackage"); context.CTX_PRM_TalendRootPid = (String) context .getProperty("CTX_PRM_TalendRootPid"); } catch (java.io.IOException ie) { System.err.println("Could not load context " + contextStr); ie.printStackTrace(); } // get context value from parent directly if (parentContextMap != null && !parentContextMap.isEmpty()) { if (parentContextMap.containsKey("CTX_EMAIL_Destinataire")) { context.CTX_EMAIL_Destinataire = (String) parentContextMap .get("CTX_EMAIL_Destinataire"); } if (parentContextMap.containsKey("CTX_EMAIL_Destinataire_copie")) { context.CTX_EMAIL_Destinataire_copie = (String) parentContextMap .get("CTX_EMAIL_Destinataire_copie"); } if (parentContextMap .containsKey("CTX_EMAIL_Destinataire_copie_cachee")) { context.CTX_EMAIL_Destinataire_copie_cachee = (String) parentContextMap .get("CTX_EMAIL_Destinataire_copie_cachee"); } if (parentContextMap.containsKey("CTX_EMAIL_Emetteur")) { context.CTX_EMAIL_Emetteur = (String) parentContextMap .get("CTX_EMAIL_Emetteur"); } if (parentContextMap.containsKey("CTX_EMAIL_Envoi_active")) { context.CTX_EMAIL_Envoi_active = (Integer) parentContextMap .get("CTX_EMAIL_Envoi_active"); } if (parentContextMap.containsKey("CTX_EMAIL_Login")) { context.CTX_EMAIL_Login = (String) parentContextMap .get("CTX_EMAIL_Login"); } if (parentContextMap.containsKey("CTX_EMAIL_Password")) { context.CTX_EMAIL_Password = (java.lang.String) parentContextMap .get("CTX_EMAIL_Password"); } if (parentContextMap.containsKey("CTX_EMAIL_Serveur_port")) { context.CTX_EMAIL_Serveur_port = (String) parentContextMap .get("CTX_EMAIL_Serveur_port"); } if (parentContextMap.containsKey("CTX_EMAIL_Serveur_SMTP")) { context.CTX_EMAIL_Serveur_SMTP = (String) parentContextMap .get("CTX_EMAIL_Serveur_SMTP"); } if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Database")) { context.CTX_PGS_COMPTAFIL_Database = (String) parentContextMap .get("CTX_PGS_COMPTAFIL_Database"); } if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Login")) { context.CTX_PGS_COMPTAFIL_Login = (String) parentContextMap .get("CTX_PGS_COMPTAFIL_Login"); } if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Password")) { context.CTX_PGS_COMPTAFIL_Password = (java.lang.String) parentContextMap .get("CTX_PGS_COMPTAFIL_Password"); } if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Port")) { context.CTX_PGS_COMPTAFIL_Port = (String) parentContextMap .get("CTX_PGS_COMPTAFIL_Port"); } if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Schema")) { context.CTX_PGS_COMPTAFIL_Schema = (String) parentContextMap .get("CTX_PGS_COMPTAFIL_Schema"); } if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Server")) { context.CTX_PGS_COMPTAFIL_Server = (String) parentContextMap .get("CTX_PGS_COMPTAFIL_Server"); } if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Database")) { context.CTX_PGS_COMPTALIS_Database = (String) parentContextMap .get("CTX_PGS_COMPTALIS_Database"); } if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Login")) { context.CTX_PGS_COMPTALIS_Login = (String) parentContextMap .get("CTX_PGS_COMPTALIS_Login"); } if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Password")) { context.CTX_PGS_COMPTALIS_Password = (java.lang.String) parentContextMap .get("CTX_PGS_COMPTALIS_Password"); } if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Port")) { context.CTX_PGS_COMPTALIS_Port = (String) parentContextMap .get("CTX_PGS_COMPTALIS_Port"); } if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Schema")) { context.CTX_PGS_COMPTALIS_Schema = (String) parentContextMap .get("CTX_PGS_COMPTALIS_Schema"); } if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Server")) { context.CTX_PGS_COMPTALIS_Server = (String) parentContextMap .get("CTX_PGS_COMPTALIS_Server"); } if (parentContextMap.containsKey("CTX_PGS_CRM_CommitInterval")) { context.CTX_PGS_CRM_CommitInterval = (Integer) parentContextMap .get("CTX_PGS_CRM_CommitInterval"); } if (parentContextMap.containsKey("CTX_PGS_CRM_Database")) { context.CTX_PGS_CRM_Database = (String) parentContextMap .get("CTX_PGS_CRM_Database"); } if (parentContextMap.containsKey("CTX_PGS_CRM_Login")) { context.CTX_PGS_CRM_Login = (String) parentContextMap .get("CTX_PGS_CRM_Login"); } if (parentContextMap.containsKey("CTX_PGS_CRM_Password")) { context.CTX_PGS_CRM_Password = (java.lang.String) parentContextMap .get("CTX_PGS_CRM_Password"); } if (parentContextMap.containsKey("CTX_PGS_CRM_Port")) { context.CTX_PGS_CRM_Port = (String) parentContextMap .get("CTX_PGS_CRM_Port"); } if (parentContextMap.containsKey("CTX_PGS_CRM_Schema")) { context.CTX_PGS_CRM_Schema = (String) parentContextMap .get("CTX_PGS_CRM_Schema"); } if (parentContextMap.containsKey("CTX_PGS_CRM_Server")) { context.CTX_PGS_CRM_Server = (String) parentContextMap .get("CTX_PGS_CRM_Server"); } if (parentContextMap.containsKey("CTX_PGS_DSA_CommitInterval")) { context.CTX_PGS_DSA_CommitInterval = (Integer) parentContextMap .get("CTX_PGS_DSA_CommitInterval"); } if (parentContextMap.containsKey("CTX_PGS_DSA_Database")) { context.CTX_PGS_DSA_Database = (String) parentContextMap .get("CTX_PGS_DSA_Database"); } if (parentContextMap.containsKey("CTX_PGS_DSA_Login")) { context.CTX_PGS_DSA_Login = (String) parentContextMap .get("CTX_PGS_DSA_Login"); } if (parentContextMap.containsKey("CTX_PGS_DSA_Password")) { context.CTX_PGS_DSA_Password = (java.lang.String) parentContextMap .get("CTX_PGS_DSA_Password"); } if (parentContextMap.containsKey("CTX_PGS_DSA_Port")) { context.CTX_PGS_DSA_Port = (String) parentContextMap .get("CTX_PGS_DSA_Port"); } if (parentContextMap.containsKey("CTX_PGS_DSA_Schema")) { context.CTX_PGS_DSA_Schema = (String) parentContextMap .get("CTX_PGS_DSA_Schema"); } if (parentContextMap.containsKey("CTX_PGS_DSA_Server")) { context.CTX_PGS_DSA_Server = (String) parentContextMap .get("CTX_PGS_DSA_Server"); } if (parentContextMap.containsKey("CTX_PGS_ODS_CommitInterval")) { context.CTX_PGS_ODS_CommitInterval = (Integer) parentContextMap .get("CTX_PGS_ODS_CommitInterval"); } if (parentContextMap.containsKey("CTX_PGS_ODS_Database")) { context.CTX_PGS_ODS_Database = (String) parentContextMap .get("CTX_PGS_ODS_Database"); } if (parentContextMap.containsKey("CTX_PGS_ODS_Login")) { context.CTX_PGS_ODS_Login = (String) parentContextMap .get("CTX_PGS_ODS_Login"); } if (parentContextMap.containsKey("CTX_PGS_ODS_Password")) { context.CTX_PGS_ODS_Password = (java.lang.String) parentContextMap .get("CTX_PGS_ODS_Password"); } if (parentContextMap.containsKey("CTX_PGS_ODS_Port")) { context.CTX_PGS_ODS_Port = (String) parentContextMap .get("CTX_PGS_ODS_Port"); } if (parentContextMap.containsKey("CTX_PGS_ODS_Schema")) { context.CTX_PGS_ODS_Schema = (String) parentContextMap .get("CTX_PGS_ODS_Schema"); } if (parentContextMap.containsKey("CTX_PGS_ODS_Server")) { context.CTX_PGS_ODS_Server = (String) parentContextMap .get("CTX_PGS_ODS_Server"); } if (parentContextMap.containsKey("CTX_PRM_ArchiveLogs")) { context.CTX_PRM_ArchiveLogs = (String) parentContextMap .get("CTX_PRM_ArchiveLogs"); } if (parentContextMap.containsKey("CTX_PRM_CEV")) { context.CTX_PRM_CEV = (String) parentContextMap .get("CTX_PRM_CEV"); } if (parentContextMap.containsKey("CTX_PRM_CodeRetour")) { context.CTX_PRM_CodeRetour = (Integer) parentContextMap .get("CTX_PRM_CodeRetour"); } if (parentContextMap.containsKey("CTX_PRM_DateDebut")) { context.CTX_PRM_DateDebut = (java.util.Date) parentContextMap .get("CTX_PRM_DateDebut"); } if (parentContextMap.containsKey("CTX_PRM_DateFin")) { context.CTX_PRM_DateFin = (java.util.Date) parentContextMap .get("CTX_PRM_DateFin"); } if (parentContextMap.containsKey("CTX_PRM_Edeal_ASSO_FIL")) { context.CTX_PRM_Edeal_ASSO_FIL = (String) parentContextMap .get("CTX_PRM_Edeal_ASSO_FIL"); } if (parentContextMap.containsKey("CTX_PRM_Edeal_ASSO_LIS")) { context.CTX_PRM_Edeal_ASSO_LIS = (String) parentContextMap .get("CTX_PRM_Edeal_ASSO_LIS"); } if (parentContextMap.containsKey("CTX_PRM_EdealBascounter")) { context.CTX_PRM_EdealBascounter = (String) parentContextMap .get("CTX_PRM_EdealBascounter"); } if (parentContextMap.containsKey("CTX_PRM_EdealBasid")) { context.CTX_PRM_EdealBasid = (String) parentContextMap .get("CTX_PRM_EdealBasid"); } if (parentContextMap.containsKey("CTX_PRM_EdealCodeActor")) { context.CTX_PRM_EdealCodeActor = (String) parentContextMap .get("CTX_PRM_EdealCodeActor"); } if (parentContextMap.containsKey("CTX_PRM_EdealIdActor")) { context.CTX_PRM_EdealIdActor = (String) parentContextMap .get("CTX_PRM_EdealIdActor"); } if (parentContextMap.containsKey("CTX_PRM_EdealLicence")) { context.CTX_PRM_EdealLicence = (String) parentContextMap .get("CTX_PRM_EdealLicence"); } if (parentContextMap.containsKey("CTX_PRM_EncryptedPassword")) { context.CTX_PRM_EncryptedPassword = (Integer) parentContextMap .get("CTX_PRM_EncryptedPassword"); } if (parentContextMap.containsKey("CTX_PRM_Environnement")) { context.CTX_PRM_Environnement = (String) parentContextMap .get("CTX_PRM_Environnement"); } if (parentContextMap.containsKey("CTX_PRM_EQUALITING")) { context.CTX_PRM_EQUALITING = (String) parentContextMap .get("CTX_PRM_EQUALITING"); } if (parentContextMap.containsKey("CTX_PRM_Exec_RES")) { context.CTX_PRM_Exec_RES = (Object) parentContextMap .get("CTX_PRM_Exec_RES"); } if (parentContextMap.containsKey("CTX_PRM_FichierConfiguration")) { context.CTX_PRM_FichierConfiguration = (String) parentContextMap .get("CTX_PRM_FichierConfiguration"); } if (parentContextMap.containsKey("CTX_PRM_FichierLog")) { context.CTX_PRM_FichierLog = (String) parentContextMap .get("CTX_PRM_FichierLog"); } if (parentContextMap.containsKey("CTX_PRM_FichierLogs")) { context.CTX_PRM_FichierLogs = (String) parentContextMap .get("CTX_PRM_FichierLogs"); } if (parentContextMap.containsKey("CTX_PRM_FichierMetrique")) { context.CTX_PRM_FichierMetrique = (String) parentContextMap .get("CTX_PRM_FichierMetrique"); } if (parentContextMap.containsKey("CTX_PRM_FichierStatistique")) { context.CTX_PRM_FichierStatistique = (String) parentContextMap .get("CTX_PRM_FichierStatistique"); } if (parentContextMap.containsKey("CTX_PRM_fileEncodage")) { context.CTX_PRM_fileEncodage = (String) parentContextMap .get("CTX_PRM_fileEncodage"); } if (parentContextMap.containsKey("CTX_PRM_fileName")) { context.CTX_PRM_fileName = (String) parentContextMap .get("CTX_PRM_fileName"); } if (parentContextMap.containsKey("CTX_PRM_IdAudit")) { context.CTX_PRM_IdAudit = (Long) parentContextMap .get("CTX_PRM_IdAudit"); } if (parentContextMap.containsKey("CTX_PRM_IdEtape")) { context.CTX_PRM_IdEtape = (Integer) parentContextMap .get("CTX_PRM_IdEtape"); } if (parentContextMap.containsKey("CTX_PRM_IdEtapeDebut")) { context.CTX_PRM_IdEtapeDebut = (Integer) parentContextMap .get("CTX_PRM_IdEtapeDebut"); } if (parentContextMap.containsKey("CTX_PRM_IdEtapeFin")) { context.CTX_PRM_IdEtapeFin = (Integer) parentContextMap .get("CTX_PRM_IdEtapeFin"); } if (parentContextMap .containsKey("CTX_PRM_listOfTableToDisableConstraints")) { context.CTX_PRM_listOfTableToDisableConstraints = (String) parentContextMap .get("CTX_PRM_listOfTableToDisableConstraints"); } if (parentContextMap.containsKey("CTX_PRM_LKPCursorSize")) { context.CTX_PRM_LKPCursorSize = (Integer) parentContextMap .get("CTX_PRM_LKPCursorSize"); } if (parentContextMap.containsKey("CTX_PRM_NomAppliSource")) { context.CTX_PRM_NomAppliSource = (String) parentContextMap .get("CTX_PRM_NomAppliSource"); } if (parentContextMap.containsKey("CTX_PRM_NomSource")) { context.CTX_PRM_NomSource = (String) parentContextMap .get("CTX_PRM_NomSource"); } if (parentContextMap.containsKey("CTX_PRM_OLAKALA_ERROR")) { context.CTX_PRM_OLAKALA_ERROR = (String) parentContextMap .get("CTX_PRM_OLAKALA_ERROR"); } if (parentContextMap.containsKey("CTX_PRM_OLAKALA_FINISHED")) { context.CTX_PRM_OLAKALA_FINISHED = (String) parentContextMap .get("CTX_PRM_OLAKALA_FINISHED"); } if (parentContextMap.containsKey("CTX_PRM_OLAKALA_PROGRESS")) { context.CTX_PRM_OLAKALA_PROGRESS = (String) parentContextMap .get("CTX_PRM_OLAKALA_PROGRESS"); } if (parentContextMap.containsKey("CTX_PRM_ProfondeurRetentionLogs")) { context.CTX_PRM_ProfondeurRetentionLogs = (Integer) parentContextMap .get("CTX_PRM_ProfondeurRetentionLogs"); } if (parentContextMap .containsKey("CTX_PRM_ProfondeurRetentionRejets")) { context.CTX_PRM_ProfondeurRetentionRejets = (Integer) parentContextMap .get("CTX_PRM_ProfondeurRetentionRejets"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireConf")) { context.CTX_PRM_RepertoireConf = (String) parentContextMap .get("CTX_PRM_RepertoireConf"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireData")) { context.CTX_PRM_RepertoireData = (String) parentContextMap .get("CTX_PRM_RepertoireData"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireDataArchive")) { context.CTX_PRM_RepertoireDataArchive = (String) parentContextMap .get("CTX_PRM_RepertoireDataArchive"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireDataIn")) { context.CTX_PRM_RepertoireDataIn = (String) parentContextMap .get("CTX_PRM_RepertoireDataIn"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireDataOut")) { context.CTX_PRM_RepertoireDataOut = (String) parentContextMap .get("CTX_PRM_RepertoireDataOut"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireLog")) { context.CTX_PRM_RepertoireLog = (String) parentContextMap .get("CTX_PRM_RepertoireLog"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireRacine")) { context.CTX_PRM_RepertoireRacine = (String) parentContextMap .get("CTX_PRM_RepertoireRacine"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireSql")) { context.CTX_PRM_RepertoireSql = (String) parentContextMap .get("CTX_PRM_RepertoireSql"); } if (parentContextMap.containsKey("CTX_PRM_RepertoireTmp")) { context.CTX_PRM_RepertoireTmp = (String) parentContextMap .get("CTX_PRM_RepertoireTmp"); } if (parentContextMap.containsKey("CTX_PRM_RESERVIT")) { context.CTX_PRM_RESERVIT = (String) parentContextMap .get("CTX_PRM_RESERVIT"); } if (parentContextMap.containsKey("CTX_PRM_SoucheVersion")) { context.CTX_PRM_SoucheVersion = (String) parentContextMap .get("CTX_PRM_SoucheVersion"); } if (parentContextMap.containsKey("CTX_PRM_SRCCursorSize")) { context.CTX_PRM_SRCCursorSize = (Integer) parentContextMap .get("CTX_PRM_SRCCursorSize"); } if (parentContextMap.containsKey("CTX_PRM_TalendRootPackage")) { context.CTX_PRM_TalendRootPackage = (String) parentContextMap .get("CTX_PRM_TalendRootPackage"); } if (parentContextMap.containsKey("CTX_PRM_TalendRootPid")) { context.CTX_PRM_TalendRootPid = (String) parentContextMap .get("CTX_PRM_TalendRootPid"); } } // Resume: init the resumeUtil resumeEntryMethodName = ResumeUtil .getResumeEntryMethodName(resuming_checkpoint_path); resumeUtil = new ResumeUtil(resuming_logs_dir_path, isChildJob, rootPid); resumeUtil.initCommonInfo(pid, rootPid, fatherPid, projectName, jobName, contextStr, jobVersion); List<String> parametersToEncrypt = new java.util.ArrayList<String>(); parametersToEncrypt.add("CTX_EMAIL_Password"); parametersToEncrypt.add("CTX_PGS_COMPTAFIL_Password"); parametersToEncrypt.add("CTX_PGS_COMPTALIS_Password"); parametersToEncrypt.add("CTX_PGS_CRM_Password"); parametersToEncrypt.add("CTX_PGS_DSA_Password"); parametersToEncrypt.add("CTX_PGS_ODS_Password"); // Resume: jobStart resumeUtil.addLog("JOB_STARTED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "", "", "", "", resumeUtil.convertToJsonText(context, parametersToEncrypt)); java.util.concurrent.ConcurrentHashMap<Object, Object> concurrentHashMap = new java.util.concurrent.ConcurrentHashMap<Object, Object>(); globalMap.put("concurrentHashMap", concurrentHashMap); long startUsedMemory = Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory(); long endUsedMemory = 0; long end = 0; startTime = System.currentTimeMillis(); this.globalResumeTicket = true;// to run tPreJob this.globalResumeTicket = false;// to run others jobs try { errorCode = null; tJava_1Process(globalMap); if (!"failure".equals(status)) { status = "end"; } } catch (TalendException e_tJava_1) { globalMap.put("tJava_1_SUBPROCESS_STATE", -1); e_tJava_1.printStackTrace(); } this.globalResumeTicket = true;// to run tPostJob try { errorCode = null; tPostjob_1Process(globalMap); if (!"failure".equals(status)) { status = "end"; } } catch (TalendException e_tPostjob_1) { globalMap.put("tPostjob_1_SUBPROCESS_STATE", -1); e_tPostjob_1.printStackTrace(); } end = System.currentTimeMillis(); if (watch) { System.out.println((end - startTime) + " milliseconds"); } endUsedMemory = Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory(); if (false) { System.out.println((endUsedMemory - startUsedMemory) + " bytes memory increase when running : GALAXIE__PCKG"); } int returnCode = 0; if (errorCode == null) { returnCode = status != null && status.equals("failure") ? 1 : 0; } else { returnCode = errorCode.intValue(); } resumeUtil.addLog("JOB_ENDED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "", "" + returnCode, "", "", ""); return returnCode; } // only for OSGi env public void destroy() { } private java.util.Map<String, Object> getSharedConnections4REST() { java.util.Map<String, Object> connections = new java.util.HashMap<String, Object>(); return connections; } private void evalParam(String arg) { if (arg.startsWith("--resuming_logs_dir_path")) { resuming_logs_dir_path = arg.substring(25); } else if (arg.startsWith("--resuming_checkpoint_path")) { resuming_checkpoint_path = arg.substring(27); } else if (arg.startsWith("--parent_part_launcher")) { parent_part_launcher = arg.substring(23); } else if (arg.startsWith("--watch")) { watch = true; } else if (arg.startsWith("--stat_port=")) { String portStatsStr = arg.substring(12); if (portStatsStr != null && !portStatsStr.equals("null")) { portStats = Integer.parseInt(portStatsStr); } } else if (arg.startsWith("--trace_port=")) { portTraces = Integer.parseInt(arg.substring(13)); } else if (arg.startsWith("--client_host=")) { clientHost = arg.substring(14); } else if (arg.startsWith("--context=")) { contextStr = arg.substring(10); isDefaultContext = false; } else if (arg.startsWith("--father_pid=")) { fatherPid = arg.substring(13); } else if (arg.startsWith("--root_pid=")) { rootPid = arg.substring(11); } else if (arg.startsWith("--father_node=")) { fatherNode = arg.substring(14); } else if (arg.startsWith("--pid=")) { pid = arg.substring(6); } else if (arg.startsWith("--context_param")) { String keyValue = arg.substring(16); int index = -1; if (keyValue != null && (index = keyValue.indexOf('=')) > -1) { if (fatherPid == null) { context_param.put(keyValue.substring(0, index), replaceEscapeChars(keyValue.substring(index + 1))); } else { // the subjob won't escape the especial chars context_param.put(keyValue.substring(0, index), keyValue.substring(index + 1)); } } } else if (arg.startsWith("--log4jLevel=")) { log4jLevel = arg.substring(13); } } private final String[][] escapeChars = { { "\\\\", "\\" }, { "\\n", "\n" }, { "\\'", "\'" }, { "\\r", "\r" }, { "\\f", "\f" }, { "\\b", "\b" }, { "\\t", "\t" } }; private String replaceEscapeChars(String keyValue) { if (keyValue == null || ("").equals(keyValue.trim())) { return keyValue; } StringBuilder result = new StringBuilder(); int currIndex = 0; while (currIndex < keyValue.length()) { int index = -1; // judege if the left string includes escape chars for (String[] strArray : escapeChars) { index = keyValue.indexOf(strArray[0], currIndex); if (index >= 0) { result.append(keyValue.substring(currIndex, index + strArray[0].length()).replace(strArray[0], strArray[1])); currIndex = index + strArray[0].length(); break; } } // if the left string doesn't include escape chars, append the left // into the result if (index < 0) { result.append(keyValue.substring(currIndex)); currIndex = currIndex + keyValue.length(); } } return result.toString(); } public Integer getErrorCode() { return errorCode; } public String getStatus() { return status; } ResumeUtil resumeUtil = null; } /************************************************************************************************ * 261296 characters generated by Talend Open Studio for Data Integration on the * 26 mars 2020 14:29:04 CET ************************************************************************************************/
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de