You are not logged in.

#1 2008-02-25 15:31:45

JMSou
Member
7 posts

Java error on a tOracleInput_1

Hello, i've a java error with a simple job (cf. image). I receveid the following messages :

        Exception in component tOracleInput_1
        java.sql.SQLException: Dépassement numérique
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:125)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:162)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:227)
    at oracle.jdbc.driver.NumberCommonAccessor.throwOverflow(NumberCommonAccessor.java:6797)
    at oracle.jdbc.driver.NumberCommonAccessor.getInt(NumberCommonAccessor.java:106)
    at oracle.jdbc.driver.OracleResultSetImpl.getInt(OracleResultSetImpl.java:489)
    at migration_stic_carcois.essaixml.essaiXml.tOracleInput_1Process(essaiXml.java:721)
    at migration_stic_carcois.essaixml.essaiXml.runJobInTOS(essaiXml.java:1510)
    at migration_stic_carcois.essaixml.essaiXml.main(essaiXml.java:1429)

The generated code was :
// ============================================================================
//
// Copyright (c) 2005-2007, Talend Inc.
//
// This source code has been automatically generated by Talend Open Studio
// / JobDesigner (CodeGenerator version 2.3.0.r8623).
// You can find more information about Talend products at www.talend.com.
// You may distribute this code under the terms of the GNU LGPL license
// (http://www.gnu.org/licenses/lgpl.html).
//
// ============================================================================
package migration_stic_carcois.essaixml;

import routines.DataOperation;
import routines.Mathematical;
import routines.Numeric;
import routines.Relational;
import routines.StringHandling;
import routines.TalendDataGenerator;
import routines.TalendDate;
import routines.TalendString;
import routines.system.*;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.math.BigDecimal;

/**
* Job: essaiXml Purpose: <br>
* Description: <br>
*
* @author jean-michel.souchard@interieur.gouv.fr
* @version 0.1
* @status
*/
public class essaiXml {
    // create and load default properties
    private static java.util.Properties defaultProps = new java.util.Properties();

    // create application properties with default
    private static class ContextProperties extends java.util.Properties {

        public ContextProperties(java.util.Properties properties) {
            super(properties);
        }

        public ContextProperties() {
            super();
        }
    }

    private static ContextProperties context = new ContextProperties();
    private static final String jobName = "essaiXml";
    private static final String projectName = "MIGRATION_STIC_CARCOIS";
    public static Integer errorCode = null;
    private static String currentComponent = "";
    private static final java.util.Map<String, Long> start_Hash = new java.util.HashMap<String, Long>();
    private static final java.util.Map<String, Long> end_Hash = new java.util.HashMap<String, Long>();
    private static final java.util.Map<String, Boolean> ok_Hash = new java.util.HashMap<String, Boolean>();
    private static final java.util.Map<String, Object> globalMap = new java.util.HashMap<String, Object>();
    public static final java.util.List<String[]> globalBuffer = new java.util.ArrayList<String[]>();

    private class TalendException extends Exception {
        private Exception e = null;
        private essaiXml c = null;

        private TalendException(essaiXml c, Exception e) {
            this.e = e;
            this.c = c;
        }

        @Override
        public void printStackTrace() {
            if (!(e instanceof TalendException || e instanceof TDieException)) {
                globalMap.put(currentComponent + "_ERROR_MESSAGE", e
                        .getMessage());
                System.err
                        .println("Exception in component " + currentComponent);
            }
            if (!(e instanceof TDieException)) {
                e.printStackTrace();
            }
            if (!(e instanceof TalendException)) {
                try {
                    for (java.lang.reflect.Method m : this.getClass()
                            .getEnclosingClass().getMethods()) {
                        if (m.getName().compareTo(currentComponent + "_error") == 0) {
                            m.invoke(c, new Object[] { e });
                            break;
                        }
                    }

                } catch (java.lang.SecurityException e) {
                    this.e.printStackTrace();
                } catch (java.lang.IllegalArgumentException e) {
                    this.e.printStackTrace();
                } catch (java.lang.IllegalAccessException e) {
                    this.e.printStackTrace();
                } catch (java.lang.reflect.InvocationTargetException e) {
                    this.e.printStackTrace();
                }
            }
        }
    }

    public void tOracleInput_1_error(Exception exception)
            throws TalendException {
        end_Hash.put("tOracleInput_1", System.currentTimeMillis());
        tOracleInput_1_onSubJobError(exception);
    }

    public void tMap_1_error(Exception exception) throws TalendException {
        end_Hash.put("tMap_1", System.currentTimeMillis());
        tOracleInput_1_onSubJobError(exception);
    }

    public void tAdvancedFileOutputXML_1_error(Exception exception)
            throws TalendException {
        end_Hash.put("tAdvancedFileOutputXML_1", System.currentTimeMillis());
        tOracleInput_1_onSubJobError(exception);
    }

    public void tOracleInput_1_onSubJobError(Exception exception)
            throws TalendException {
    }

    private class row2Struct {
        private static final int DEFAULT_HASHCODE = 1;
        private static final int PRIME = 31;
        private int hashCode = DEFAULT_HASHCODE;
        public boolean hashCodeDirty = true;

        int NLVPROC;

        Integer NLVPROCI;

        int CSVPR;

        int NUPR;

        String POS;

        int CTYPR;

        java.util.Date DOUV;

        java.util.Date DCLO;

        Integer CISSP;

        int CNAPR;

        Integer CSAIS;

        Integer CCADJ1;

        Integer CCADJ2;

        String PRSP;

        Integer DHM;

        String TDC;

        Integer EVP;

        Integer EMP;

        Integer EIN;

        Integer EOR;

        Integer EOJ;

        Integer EOB;

        Integer EOD;

        Integer EOL;

        Integer EOE;

        Integer EOG;

        Integer EOO;

        Integer EOH;

        Integer EOT;

        Integer EDR;

        Integer EDJ;

        Integer EDB;

        Integer EDD;

        Integer EDL;

        Integer EDE;

        Integer EDG;

        Integer EDO;

        Integer EDH;

        Integer EDT;

        @Override
        public int hashCode() {
            if (this.hashCodeDirty) {
                final int prime = PRIME;
                int result = DEFAULT_HASHCODE;

                result = prime * result + (int) this.NLVPROC;

                this.hashCode = result;
                this.hashCodeDirty = false;
            }
            return this.hashCode;
        }

        @Override
        public boolean equals(Object obj) {
            if (this == obj)
                return true;
            if (obj == null)
                return false;
            if (getClass() != obj.getClass())
                return false;
            final row2Struct other = (row2Struct) obj;

            if (this.NLVPROC != other.NLVPROC)
                return false;

            return true;
        }

    }

    private class row1Struct {

        int NLVPROC;

        Integer NLVPROCI;

        int CSVPR;

        int NUPR;

        String POS;

        int CTYPR;

        java.util.Date DOUV;

        java.util.Date DCLO;

        Integer CISSP;

        int CNAPR;

        Integer CSAIS;

        Integer CCADJ1;

        Integer CCADJ2;

        String PRSP;

        Integer DHM;

        String TDC;

        Integer EVP;

        Integer EMP;

        Integer EIN;

        Integer EOR;

        Integer EOJ;

        Integer EOB;

        Integer EOD;

        Integer EOL;

        Integer EOE;

        Integer EOG;

        Integer EOO;

        Integer EOH;

        Integer EOT;

        Integer EDR;

        Integer EDJ;

        Integer EDB;

        Integer EDD;

        Integer EDL;

        Integer EDE;

        Integer EDG;

        Integer EDO;

        Integer EDH;

        Integer EDT;

    }

    public void tOracleInput_1Process() throws TalendException {
        try {

            row1Struct row1 = new row1Struct();
            row2Struct row2 = new row2Struct();

            /**
             * [tAdvancedFileOutputXML_1 begin ] start
             */

            ok_Hash.put("tAdvancedFileOutputXML_1", false);
            start_Hash.put("tAdvancedFileOutputXML_1", System
                    .currentTimeMillis());
            currentComponent = "tAdvancedFileOutputXML_1";

            int nb_line_tAdvancedFileOutputXML_1 = 0;
            org.dom4j.Document doc_tAdvancedFileOutputXML_1 = org.dom4j.DocumentHelper
                    .createDocument();
            boolean needRoot_tAdvancedFileOutputXML_1 = true;
            String fileName_tAdvancedFileOutputXML_1 = "C:/Documents and Settings/SOUCHARD.DTI/Mes documents/DSIC/BI/carcois/xml/gen_ETL/stic.xml";
            java.io.File createFiletAdvancedFileOutputXML_1 = new java.io.File(
                    fileName_tAdvancedFileOutputXML_1);
            if (!createFiletAdvancedFileOutputXML_1.exists()) {
                (new java.io.File(fileName_tAdvancedFileOutputXML_1.substring(
                        0, fileName_tAdvancedFileOutputXML_1.lastIndexOf("/"))))
                        .mkdirs();
            }

            class NestXMLTool_tAdvancedFileOutputXML_1 {
                public void parseAndAdd(org.dom4j.Element nestRoot, String value) {
                    try {
                        org.dom4j.Document doc4Str = org.dom4j.DocumentHelper
                                .parseText("<root>" + value + "</root>");
                        nestRoot.setContent(doc4Str.getRootElement().content());
                    } catch (Exception e) {
                        e.printStackTrace();
                        nestRoot.setText(value);
                    }
                }

                public void replaceDefaultNameSpace(org.dom4j.Element nestRoot) {
                    if (nestRoot != null) {
                        for (org.dom4j.Element tmp : (java.util.List<org.dom4j.Element>) nestRoot
                                .elements()) {
                            if (tmp.getQName().getNamespace().getURI().equals(
                                    "")
                                    && tmp.getQName().getNamespace()
                                            .getPrefix().equals("")) {
                                tmp.setQName(org.dom4j.DocumentHelper
                                        .createQName(tmp.getName(), nestRoot
                                                .getQName().getNamespace()));
                            }
                            replaceDefaultNameSpace(tmp);
                        }
                    }
                }
            }
            NestXMLTool_tAdvancedFileOutputXML_1 nestXMLTool_tAdvancedFileOutputXML_1 = new NestXMLTool_tAdvancedFileOutputXML_1();

            // sort group root element for judgement of group
            java.util.List<org.dom4j.Element> groupRootList_tAdvancedFileOutputXML_1 = new java.util.ArrayList<org.dom4j.Element>();

            org.dom4j.Element root4Group_tAdvancedFileOutputXML_1 = null;

            org.dom4j.io.OutputFormat format_tAdvancedFileOutputXML_1 = org.dom4j.io.OutputFormat
                    .createPrettyPrint();
            format_tAdvancedFileOutputXML_1.setEncoding("ISO-8859-15");

            /**
             * [tAdvancedFileOutputXML_1 begin ] stop
             */

            /**
             * [tMap_1 begin ] start
             */

            ok_Hash.put("tMap_1", false);
            start_Hash.put("tMap_1", System.currentTimeMillis());
            currentComponent = "tMap_1";

            // ###############################
            // # Lookup's keys initialization
            // ###############################

            // ###############################
            // # Vars initialization
            // ###############################

            // ###############################
            // # Outputs initialization
            row2Struct row2_tmp = new row2Struct();
            // ###############################

            /**
             * [tMap_1 begin ] stop
             */

            /**
             * [tOracleInput_1 begin ] start
             */

            ok_Hash.put("tOracleInput_1", false);
            start_Hash.put("tOracleInput_1", System.currentTimeMillis());
            currentComponent = "tOracleInput_1";

            int nb_line_tOracleInput_1 = 0;
            java.sql.Connection conn_tOracleInput_1 = null;
            java.lang.Class.forName("oracle.jdbc.driver.OracleDriver");

            String url_tOracleInput_1 = null;

            url_tOracleInput_1 = "jdbc:oracle:thin:@" + "as72" + ":" + "1521"
                    + ":" + "estc";

            String dbUser_tOracleInput_1 = "stic";
            String dbPwd_tOracleInput_1 = "stic";

            conn_tOracleInput_1 = java.sql.DriverManager.getConnection(
                    url_tOracleInput_1, dbUser_tOracleInput_1,
                    dbPwd_tOracleInput_1);

            java.sql.Statement stmt_tOracleInput_1 = conn_tOracleInput_1
                    .createStatement();
            java.sql.ResultSet rs_tOracleInput_1 = stmt_tOracleInput_1
                    .executeQuery("SELECT STIC.STICAPRC.NLVPROC, STIC.STICAPRC.NLVPROCI, STIC.STICAPRC.CSVPR, STIC.STICAPRC.NUPR,  STIC.STICAPRC.POS, STIC.STICAPRC.CTYPR, STIC.STICAPRC.DOUV, STIC.STICAPRC.DCLO,  STIC.STICAPRC.CISSP, STIC.STICAPRC.CNAPR, STIC.STICAPRC.CSAIS, STIC.STICAPRC.CCADJ1,  STIC.STICAPRC.CCADJ2, STIC.STICAPRC.PRSP, STIC.STICAPRC.DHM, STIC.STICAPRC.TDC, STIC.STICAPRC.EVP,  STIC.STICAPRC.EMP, STIC.STICAPRC.EIN, STIC.STICAPRC.EOR, STIC.STICAPRC.EOJ, STIC.STICAPRC.EOB,  STIC.STICAPRC.EOD, STIC.STICAPRC.EOL, STIC.STICAPRC.EOE, STIC.STICAPRC.EOG, STIC.STICAPRC.EOO,  STIC.STICAPRC.EOH, STIC.STICAPRC.EOT, STIC.STICAPRC.EDR, STIC.STICAPRC.EDJ, STIC.STICAPRC.EDB,  STIC.STICAPRC.EDD, STIC.STICAPRC.EDL, STIC.STICAPRC.EDE, STIC.STICAPRC.EDG, STIC.STICAPRC.EDO,  STIC.STICAPRC.EDH, STIC.STICAPRC.EDT  FROM STIC.STICAPRC");
            java.sql.ResultSetMetaData rsmd_tOracleInput_1 = rs_tOracleInput_1
                    .getMetaData();
            int colQtyInRs_tOracleInput_1 = rsmd_tOracleInput_1
                    .getColumnCount();

            globalMap
                    .put(
                            "tOracleInput_1_QUERY",
                            "SELECT STIC.STICAPRC.NLVPROC, STIC.STICAPRC.NLVPROCI, STIC.STICAPRC.CSVPR, STIC.STICAPRC.NUPR,  STIC.STICAPRC.POS, STIC.STICAPRC.CTYPR, STIC.STICAPRC.DOUV, STIC.STICAPRC.DCLO,  STIC.STICAPRC.CISSP, STIC.STICAPRC.CNAPR, STIC.STICAPRC.CSAIS, STIC.STICAPRC.CCADJ1,  STIC.STICAPRC.CCADJ2, STIC.STICAPRC.PRSP, STIC.STICAPRC.DHM, STIC.STICAPRC.TDC, STIC.STICAPRC.EVP,  STIC.STICAPRC.EMP, STIC.STICAPRC.EIN, STIC.STICAPRC.EOR, STIC.STICAPRC.EOJ, STIC.STICAPRC.EOB,  STIC.STICAPRC.EOD, STIC.STICAPRC.EOL, STIC.STICAPRC.EOE, STIC.STICAPRC.EOG, STIC.STICAPRC.EOO,  STIC.STICAPRC.EOH, STIC.STICAPRC.EOT, STIC.STICAPRC.EDR, STIC.STICAPRC.EDJ, STIC.STICAPRC.EDB,  STIC.STICAPRC.EDD, STIC.STICAPRC.EDL, STIC.STICAPRC.EDE, STIC.STICAPRC.EDG, STIC.STICAPRC.EDO,  STIC.STICAPRC.EDH, STIC.STICAPRC.EDT  FROM STIC.STICAPRC");

            while (rs_tOracleInput_1.next()) {
                nb_line_tOracleInput_1++;

                if (colQtyInRs_tOracleInput_1 < 1) {

                    row1.NLVPROC = 0;

                } else {

                    if (rs_tOracleInput_1.getObject(1) != null) {
                        row1.NLVPROC = rs_tOracleInput_1.getInt(1);
                    } else {

                        throw new RuntimeException(
                                "Null value in non-Nullable column");
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 2) {

                    row1.NLVPROCI = null;

                } else {

                    if (rs_tOracleInput_1.getObject(2) != null) {
                        row1.NLVPROCI = rs_tOracleInput_1.getInt(2);
                    } else {

                        row1.NLVPROCI = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 3) {

                    row1.CSVPR = 0;

                } else {

                    if (rs_tOracleInput_1.getObject(3) != null) {
                        row1.CSVPR = rs_tOracleInput_1.getInt(3);
                    } else {

                        throw new RuntimeException(
                                "Null value in non-Nullable column");
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 4) {

                    row1.NUPR = 0;

                } else {

                    if (rs_tOracleInput_1.getObject(4) != null) {
                        row1.NUPR = rs_tOracleInput_1.getInt(4);
                    } else {

                        throw new RuntimeException(
                                "Null value in non-Nullable column");
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 5) {

                    row1.POS = null;

                } else {

                    if (rs_tOracleInput_1.getObject(5) != null) {
                        row1.POS = rs_tOracleInput_1.getString(5);
                    } else {

                        throw new RuntimeException(
                                "Null value in non-Nullable column");
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 6) {

                    row1.CTYPR = 0;

                } else {

                    if (rs_tOracleInput_1.getObject(6) != null) {
                        row1.CTYPR = rs_tOracleInput_1.getInt(6);
                    } else {

                        throw new RuntimeException(
                                "Null value in non-Nullable column");
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 7) {

                    row1.DOUV = null;

                } else {

                    if (rs_tOracleInput_1.getTimestamp(7) != null) {
                        row1.DOUV = new java.util.Date(rs_tOracleInput_1
                                .getTimestamp(7).getTime());
                    } else {
                        row1.DOUV = null;
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 8) {

                    row1.DCLO = null;

                } else {

                    if (rs_tOracleInput_1.getTimestamp(8) != null) {
                        row1.DCLO = new java.util.Date(rs_tOracleInput_1
                                .getTimestamp(8).getTime());
                    } else {
                        row1.DCLO = null;
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 9) {

                    row1.CISSP = null;

                } else {

                    if (rs_tOracleInput_1.getObject(9) != null) {
                        row1.CISSP = rs_tOracleInput_1.getInt(9);
                    } else {

                        row1.CISSP = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 10) {

                    row1.CNAPR = 0;

                } else {

                    if (rs_tOracleInput_1.getObject(10) != null) {
                        row1.CNAPR = rs_tOracleInput_1.getInt(10);
                    } else {

                        throw new RuntimeException(
                                "Null value in non-Nullable column");
                    }

                }

                if (colQtyInRs_tOracleInput_1 < 11) {

                    row1.CSAIS = null;

                } else {

                    if (rs_tOracleInput_1.getObject(11) != null) {
                        row1.CSAIS = rs_tOracleInput_1.getInt(11);
                    } else {

                        row1.CSAIS = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 12) {

                    row1.CCADJ1 = null;

                } else {

                    if (rs_tOracleInput_1.getObject(12) != null) {
                        row1.CCADJ1 = rs_tOracleInput_1.getInt(12);
                    } else {

                        row1.CCADJ1 = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 13) {

                    row1.CCADJ2 = null;

                } else {

                    if (rs_tOracleInput_1.getObject(13) != null) {
                        row1.CCADJ2 = rs_tOracleInput_1.getInt(13);
                    } else {

                        row1.CCADJ2 = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 14) {

                    row1.PRSP = null;

                } else {

                    if (rs_tOracleInput_1.getObject(14) != null) {
                        row1.PRSP = rs_tOracleInput_1.getString(14);
                    } else {

                        row1.PRSP = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 15) {

                    row1.DHM = null;

                } else {

                    if (rs_tOracleInput_1.getObject(15) != null) {
                        row1.DHM = rs_tOracleInput_1.getInt(15);
                    } else {

                        row1.DHM = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 16) {

                    row1.TDC = null;

                } else {

                    if (rs_tOracleInput_1.getObject(16) != null) {
                        row1.TDC = rs_tOracleInput_1.getString(16);
                    } else {

                        row1.TDC = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 17) {

                    row1.EVP = null;

                } else {

                    if (rs_tOracleInput_1.getObject(17) != null) {
                        row1.EVP = rs_tOracleInput_1.getInt(17);
                    } else {

                        row1.EVP = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 18) {

                    row1.EMP = null;

                } else {

                    if (rs_tOracleInput_1.getObject(18) != null) {
                        row1.EMP = rs_tOracleInput_1.getInt(18);
                    } else {

                        row1.EMP = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 19) {

                    row1.EIN = null;

                } else {

                    if (rs_tOracleInput_1.getObject(19) != null) {
                        row1.EIN = rs_tOracleInput_1.getInt(19);
                    } else {

                        row1.EIN = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 20) {

                    row1.EOR = null;

                } else {

                    if (rs_tOracleInput_1.getObject(20) != null) {
                        row1.EOR = rs_tOracleInput_1.getInt(20);
                    } else {

                        row1.EOR = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 21) {

                    row1.EOJ = null;

                } else {

                    if (rs_tOracleInput_1.getObject(21) != null) {
                        row1.EOJ = rs_tOracleInput_1.getInt(21);
                    } else {

                        row1.EOJ = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 22) {

                    row1.EOB = null;

                } else {

                    if (rs_tOracleInput_1.getObject(22) != null) {
                        row1.EOB = rs_tOracleInput_1.getInt(22);
                    } else {

                        row1.EOB = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 23) {

                    row1.EOD = null;

                } else {

                    if (rs_tOracleInput_1.getObject(23) != null) {
                        row1.EOD = rs_tOracleInput_1.getInt(23);
                    } else {

                        row1.EOD = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 24) {

                    row1.EOL = null;

                } else {

                    if (rs_tOracleInput_1.getObject(24) != null) {
                        row1.EOL = rs_tOracleInput_1.getInt(24);
                    } else {

                        row1.EOL = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 25) {

                    row1.EOE = null;

                } else {

                    if (rs_tOracleInput_1.getObject(25) != null) {
                        row1.EOE = rs_tOracleInput_1.getInt(25);
                    } else {

                        row1.EOE = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 26) {

                    row1.EOG = null;

                } else {

                    if (rs_tOracleInput_1.getObject(26) != null) {
                        row1.EOG = rs_tOracleInput_1.getInt(26);
                    } else {

                        row1.EOG = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 27) {

                    row1.EOO = null;

                } else {

                    if (rs_tOracleInput_1.getObject(27) != null) {
                        row1.EOO = rs_tOracleInput_1.getInt(27);
                    } else {

                        row1.EOO = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 28) {

                    row1.EOH = null;

                } else {

                    if (rs_tOracleInput_1.getObject(28) != null) {
                        row1.EOH = rs_tOracleInput_1.getInt(28);
                    } else {

                        row1.EOH = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 29) {

                    row1.EOT = null;

                } else {

                    if (rs_tOracleInput_1.getObject(29) != null) {
                        row1.EOT = rs_tOracleInput_1.getInt(29);
                    } else {

                        row1.EOT = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 30) {

                    row1.EDR = null;

                } else {

                    if (rs_tOracleInput_1.getObject(30) != null) {
                        row1.EDR = rs_tOracleInput_1.getInt(30);
                    } else {

                        row1.EDR = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 31) {

                    row1.EDJ = null;

                } else {

                    if (rs_tOracleInput_1.getObject(31) != null) {
                        row1.EDJ = rs_tOracleInput_1.getInt(31);
                    } else {

                        row1.EDJ = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 32) {

                    row1.EDB = null;

                } else {

                    if (rs_tOracleInput_1.getObject(32) != null) {
                        row1.EDB = rs_tOracleInput_1.getInt(32);
                    } else {

                        row1.EDB = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 33) {

                    row1.EDD = null;

                } else {

                    if (rs_tOracleInput_1.getObject(33) != null) {
                        row1.EDD = rs_tOracleInput_1.getInt(33);
                    } else {

                        row1.EDD = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 34) {

                    row1.EDL = null;

                } else {

                    if (rs_tOracleInput_1.getObject(34) != null) {
                        row1.EDL = rs_tOracleInput_1.getInt(34);
                    } else {

                        row1.EDL = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 35) {

                    row1.EDE = null;

                } else {

                    if (rs_tOracleInput_1.getObject(35) != null) {
                        row1.EDE = rs_tOracleInput_1.getInt(35);
                    } else {

                        row1.EDE = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 36) {

                    row1.EDG = null;

                } else {

                    if (rs_tOracleInput_1.getObject(36) != null) {
                        row1.EDG = rs_tOracleInput_1.getInt(36);
                    } else {

                        row1.EDG = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 37) {

                    row1.EDO = null;

                } else {

                    if (rs_tOracleInput_1.getObject(37) != null) {
                        row1.EDO = rs_tOracleInput_1.getInt(37);
                    } else {

                        row1.EDO = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 38) {

                    row1.EDH = null;

                } else {

                    if (rs_tOracleInput_1.getObject(38) != null) {
                        row1.EDH = rs_tOracleInput_1.getInt(38);
                    } else {

                        row1.EDH = null;

                    }

                }

                if (colQtyInRs_tOracleInput_1 < 39) {

                    row1.EDT = null;

                } else {

                    if (rs_tOracleInput_1.getObject(39) != null) {
                        row1.EDT = rs_tOracleInput_1.getInt(39);
                    } else {

                        row1.EDT = null;

                    }

                }

                /**
                 * [tOracleInput_1 begin ] stop
                 */
                /**
                 * [tOracleInput_1 main ] start
                 */

                currentComponent = "tOracleInput_1";

                /**
                 * [tOracleInput_1 main ] stop
                 */
                /**
                 * [tMap_1 main ] start
                 */

                currentComponent = "tMap_1";

                boolean rejectedInnerJoin_tMap_1 = false;

                if (

                !(

                (row1.NLVPROC == 1)

                )

                ) {
                    continue;
                }

                // ###############################
                // # Input tables (lookups)

                // ###############################

                { // start of Var scope

                    // ###############################
                    // # Vars tables
                    // ###############################

                    // ###############################
                    // # Output tables
                    row2 = null;

                    // # Output table : 'row2'
                    row2_tmp.NLVPROC = row1.NLVPROC;
                    row2_tmp.NLVPROCI = row1.NLVPROCI;
                    row2_tmp.CSVPR = row1.CSVPR;
                    row2_tmp.NUPR = row1.NUPR;
                    row2_tmp.POS = row1.POS;
                    row2_tmp.CTYPR = row1.CTYPR;
                    row2_tmp.DOUV = row1.DOUV;
                    row2_tmp.DCLO = row1.DCLO;
                    row2_tmp.CISSP = row1.CISSP;
                    row2_tmp.CNAPR = row1.CNAPR;
                    row2_tmp.CSAIS = row1.CSAIS;
                    row2_tmp.CCADJ1 = row1.CCADJ1;
                    row2_tmp.CCADJ2 = row1.CCADJ2;
                    row2_tmp.PRSP = row1.PRSP;
                    row2_tmp.DHM = row1.DHM;
                    row2_tmp.TDC = row1.TDC;
                    row2_tmp.EVP = row1.EVP;
                    row2_tmp.EMP = row1.EMP;
                    row2_tmp.EIN = row1.EIN;
                    row2_tmp.EOR = row1.EOR;
                    row2_tmp.EOJ = row1.EOJ;
                    row2_tmp.EOB = row1.EOB;
                    row2_tmp.EOD = row1.EOD;
                    row2_tmp.EOL = row1.EOL;
                    row2_tmp.EOE = row1.EOE;
                    row2_tmp.EOG = row1.EOG;
                    row2_tmp.EOO = row1.EOO;
                    row2_tmp.EOH = row1.EOH;
                    row2_tmp.EOT = row1.EOT;
                    row2_tmp.EDR = row1.EDR;
                    row2_tmp.EDJ = row1.EDJ;
                    row2_tmp.EDB = row1.EDB;
                    row2_tmp.EDD = row1.EDD;
                    row2_tmp.EDL = row1.EDL;
                    row2_tmp.EDE = row1.EDE;
                    row2_tmp.EDG = row1.EDG;
                    row2_tmp.EDO = row1.EDO;
                    row2_tmp.EDH = row1.EDH;
                    row2_tmp.EDT = row1.EDT;
                    row2 = row2_tmp;
                    // ###############################

                } // end of Var scope

                rejectedInnerJoin_tMap_1 = false;

                /**
                 * [tMap_1 main ] stop
                 */
                // Start of branch "row2"
                if (row2 != null) {

                    /**
                     * [tAdvancedFileOutputXML_1 main ] start
                     */

                    currentComponent = "tAdvancedFileOutputXML_1";

                    /**
                     * [tAdvancedFileOutputXML_1 main ] stop
                     */

                } // End of branch "row2"

                /**
                 * [tOracleInput_1 end ] start
                 */

                currentComponent = "tOracleInput_1";

            }
            stmt_tOracleInput_1.close();

            conn_tOracleInput_1.close();

            globalMap.put("tOracleInput_1_NB_LINE", nb_line_tOracleInput_1);

            ok_Hash.put("tOracleInput_1", true);
            end_Hash.put("tOracleInput_1", System.currentTimeMillis());

            /**
             * [tOracleInput_1 end ] stop
             */
            /**
             * [tMap_1 end ] start
             */

            currentComponent = "tMap_1";

            // ###############################
            // # Lookup hashes releasing

            ok_Hash.put("tMap_1", true);
            end_Hash.put("tMap_1", System.currentTimeMillis());

            /**
             * [tMap_1 end ] stop
             */
            /**
             * [tAdvancedFileOutputXML_1 end ] start
             */

            currentComponent = "tAdvancedFileOutputXML_1";

            java.io.FileOutputStream stream_tAdvancedFileOutputXML_1 = new java.io.FileOutputStream(
                    fileName_tAdvancedFileOutputXML_1);
            org.dom4j.io.XMLWriter output_tAdvancedFileOutputXML_1 = new org.dom4j.io.XMLWriter(
                    stream_tAdvancedFileOutputXML_1,
                    format_tAdvancedFileOutputXML_1);
            nestXMLTool_tAdvancedFileOutputXML_1
                    .replaceDefaultNameSpace(doc_tAdvancedFileOutputXML_1
                            .getRootElement());
            output_tAdvancedFileOutputXML_1.write(doc_tAdvancedFileOutputXML_1);
            output_tAdvancedFileOutputXML_1.close();
            globalMap.put("tAdvancedFileOutputXML_1_NB_LINE",
                    nb_line_tAdvancedFileOutputXML_1);

            ok_Hash.put("tAdvancedFileOutputXML_1", true);
            end_Hash
                    .put("tAdvancedFileOutputXML_1", System.currentTimeMillis());

            /**
             * [tAdvancedFileOutputXML_1 end ] stop
             */

        } catch (Exception e) {

            throw new TalendException(this, e);
        }

    }

    public static boolean watch = false;
    public static int portStats = 3334;
    public static int portTraces = 4334;
    public static String clientHost;
    public static String defaultClientHost = "localhost";
    public static String contextStr = "Default";
    public static String pid = "0";
    public static String rootPid = null;
    public static String fatherPid = null;

    private static java.util.Properties context_param = new java.util.Properties();

    public static String status = "";

    public static void main(String[] args) {

        int exitCode = runJobInTOS(args);

        globalBuffer.clear();

        System.exit(exitCode);
    }

    public static String[][] runJob(String[] args) {

        int exitCode = runJobInTOS(args);
        String[][] bufferValue = new String[][] { { Integer.toString(exitCode) } };

        globalBuffer.clear();

        return bufferValue;
    }

    public static synchronized int runJobInTOS(String[] args) {

        init();

        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;
        }

        pid = TalendString.getAsciiRandomString(6);
        if (rootPid == null) {
            rootPid = pid;
        }
        if (fatherPid == null) {
            fatherPid = pid;
        }

        try {
            java.io.InputStream inContext = essaiXml.class
                    .getClassLoader()
                    .getResourceAsStream(
                            "migration_stic_carcois/essaixml/contexts/Default.properties");
            if (inContext != null) {
                defaultProps.load(inContext);
                inContext.close();
                context = new ContextProperties(defaultProps);
            }

            if (contextStr.compareTo("Default") != 0) {
                inContext = essaiXml.class.getClassLoader()
                        .getResourceAsStream(
                                "migration_stic_carcois/essaixml/contexts/"
                                        + contextStr + ".properties");
                if (inContext != null) {
                    context.load(inContext);
                    inContext.close();
                }
            }

            if (!context_param.isEmpty()) {
                context.putAll(context_param);
            }

        } catch (java.io.IOException ie) {
            System.err.println("Could not load context " + contextStr);
            ie.printStackTrace();
        }

        long startUsedMemory = Runtime.getRuntime().totalMemory()
                - Runtime.getRuntime().freeMemory();
        long endUsedMemory = 0;
        long end = 0;
        long start = System.currentTimeMillis();
        final essaiXml essaiXmlClass = new essaiXml();
        try {
            errorCode = null;
            essaiXmlClass.tOracleInput_1Process();
            status = "end";
        } catch (TalendException e_tOracleInput_1) {
            status = "failure";
            e_tOracleInput_1.printStackTrace();

        } finally {
        }
        end = System.currentTimeMillis();
        if (watch) {
            System.out.println((end - start) + " milliseconds");
        }

        endUsedMemory = Runtime.getRuntime().totalMemory()
                - Runtime.getRuntime().freeMemory();
        if (false) {
            System.out.println((endUsedMemory - startUsedMemory)
                    + " bytes memory increase when running : essaiXml");
        }

        reset();

        if (errorCode == null) {
            return status != null && status.equals("failure") ? 1 : 0;
        } else {
            return errorCode.intValue();
        }
    }

    public static void evalParam(String arg) {
        if (arg.startsWith("--watch")) {
            watch = true;
        } else if (arg.startsWith("--stat_port=")) {
            portStats = Integer.parseInt(arg.substring(12));
        } 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);
        } else if (arg.startsWith("--father_pid=")) {
            fatherPid = arg.substring(13);
        } else if (arg.startsWith("--root_pid=")) {
            rootPid = arg.substring(11);
        } else if (arg.startsWith("--context_param")) {
            String keyValue = arg.substring(16);
            int index = -1;
            if (keyValue != null && (index = keyValue.indexOf('=')) > -1) {
                context_param.put(keyValue.substring(0, index), keyValue
                        .substring(index + 1));
            }
        }

    }

    private static void init() {
        errorCode = null;
        status = "";
    }

    private static void reset() {

        defaultProps.clear();
        context.clear();
        currentComponent = "";
        start_Hash.clear();
        end_Hash.clear();
        ok_Hash.clear();
        globalMap.clear();
        watch = false;
        portStats = 3334;
        portTraces = 4334;
        clientHost = null;
        defaultClientHost = "localhost";
        contextStr = "Default";
        pid = "0";
        rootPid = null;
        fatherPid = null;
        context_param.clear();
        System.gc();
    }
}
/*******************************************************************************
* 34512 characters generated by Talend OpenStudio on the 25 février 2008
* 14:44:18 CET
******************************************************************************/
What is the problem ? (It's my first job with Oracle : I've already use SqlServer and PostgreSQL)

Last edited by JMSou (2008-02-25 15:32:48)

Offline

#2 2008-02-25 16:44:49

JMSou
Member
7 posts

Re: Java error on a tOracleInput_1

I find the problem : it's the column DHM with int(16) which is too long...

Offline

Board footer