package fr.su.referentielappro.services.data.impl;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.List;

import fr.su.apv.dao.AbsDao;
import fr.su.out.osj.sutools.exception.fonctionnelle.AbsSuException;
import fr.su.out.osj.sutools.exception.fonctionnelle.SuFonctionnelleServiceException;
import fr.su.referentielappro.objects.business.be.GrpEntrepotsBE;
import fr.su.referentielappro.objects.business.be.ResultatGroupeEntrepotBE;
import fr.su.referentielappro.services.data.itf.GrpEntrepotsIDAO;

public class GrpEntrepotsDAO extends AbsDao implements GrpEntrepotsIDAO {

    public static void main(String[] args) throws AbsSuException, SQLException {
        GrpEntrepotsDAO a = new GrpEntrepotsDAO();
        a.listerGrpEntrepots();
    }

    private static final String DB_DRIVER = "com.ibm.as400.access.AS400JDBCDriver";
    private static final String DB_CONNECTION = "jdbc:as400://suo2;date format=iso;prompt=false;naming=system;trace=false;";
    private static final String DB_USER = "APPROWEB2";
    private static final String DB_PASSWORD = "APPROWEB2";

    /*
     * (non-Javadoc)
     *
     * @see fr.su.referentielappro.services.data.itf.GrpEntrepotsIDAO#listerGrpEntrepots()
     */
    @Override
    public List<GrpEntrepotsBE> listerGrpEntrepots()
            throws AbsSuException, SuFonctionnelleServiceException, SQLException {

        Connection dbConnection = getDBConnection();
        CallableStatement callStatement = null;

        callStatement = dbConnection.prepareCall("CALL GESCOMC.AKP026SQ(?,?,?,?,?)");
        callStatement.setString(1, "4");
        callStatement.setString(2, "");
        callStatement.setString(3, "");
        callStatement.setString(4, "CLPROUST");
        callStatement.setInt(5, 0);
        // callStatement.registerOutParameter(1, ResultSet.TYPE_FORWARD_ONLY);
        callStatement.registerOutParameter(1, Types.CHAR);
        callStatement.registerOutParameter(2, Types.CHAR);
        callStatement.registerOutParameter(3, Types.CHAR);
        callStatement.registerOutParameter(4, Types.CHAR);
        callStatement.registerOutParameter(5, Types.INTEGER);
        callStatement.execute();

        ResultSet rs = callStatement.getResultSet();

        while (rs.next()) {
            System.out.println(rs.getString("IDGRPEN"));
            System.out.println(rs.getString("LBGRPEN"));
        }

        ResultatGroupeEntrepotBE resultatgroupeBE = null;

        return resultatgroupeBE.getListeGroupeEntrepotBE();

    }

    private static Connection getDBConnection() {

        Connection dbConnection = null;

        try {

            Class.forName(DB_DRIVER);

        } catch (ClassNotFoundException e) {

            System.out.println(e.getMessage());

        }

        try {

            dbConnection = DriverManager.getConnection(DB_CONNECTION, DB_USER, DB_PASSWORD);
            return dbConnection;

        } catch (SQLException e) {

            System.out.println(e.getMessage());

        }

        return dbConnection;

    }
}