source: ether_eccad/trunk/ECCAD_INTERFACE/WEB-INF/src/org/medias/eccad/persistance/jdbc/SGBD_jdbc.java @ 68

package org.medias.eccad.persistance.jdbc;

import java.sql.Connection;
import java.sql.SQLException;


import org.medias.eccad.helpers.LoggerPerso;
import org.medias.eccad.persistance.InfoConnectBean;
import org.postgresql.ds.PGPoolingDataSource;

public class SGBD_jdbc {
        private Connection con;
        private static PGPoolingDataSource pooling = null;
        private InfoConnectBean info;
        
        public SGBD_jdbc(InfoConnectBean n_info) {
                con = null;
                LoggerPerso.log(SGBD_jdbc.class, LoggerPerso.DEBUG, "construction connection");
                if (pooling == null) {
                        info = n_info;
                        LoggerPerso.log(SGBD_jdbc.class, LoggerPerso.DEBUG, "creation pooling :: " + info);
                        pooling = new PGPoolingDataSource();
                        pooling.setDatabaseName(info.getDb_name());
                        pooling.setServerName(info.getDb_url());
                        //pooling.setMaxConnections(1);
                        pooling.setPassword(info.getDb_passwd());
                        pooling.setUser(info.getDb_login());
                        pooling.setPortNumber(Integer.parseInt(info.getDb_port()));
                        pooling.setDataSourceName(info.getDb_name());
                }
        }
        
        
        /**
         * Se connecte à la base de données en mode auto-comit false
         * @param info le bean contenant les informations de connexion
         * @throws SQLException si la connexion échoue
         */
        public Connection connexion() throws SQLException {
                ////system.out.println("CONNEXION");
                con = pooling.getConnection();
                con.setAutoCommit(false);
                return con;
        }
        
        /**
         * Assure la deconnexion à la base de données
         * en cas d'erreur une entrée est saisie dans le log
         *
         */
        public void deconnexion() {
                try {
                        con.close();
                        //pooling.close();
                } catch (SQLException e) {
                        e.printStackTrace();
                        LoggerPerso.log(SGBD_jdbc.class, LoggerPerso.ERROR, "erreur lors de la deconnexion", e);
                }
        }
        
        /**
         * Permet de valider une transaction qui s'est déroulée correctement
         * en cas de problÚme une RunTimeException est lancée
         */
        public void valider_transaction() {
                try {
                        con.commit();
                } catch (SQLException e) {
                        e.printStackTrace();
                        throw new RuntimeException("erreur fatale sgbd validation de transaction");
                }
        }
        
        /**
         * Permet d'annuler une transaction
         * en cas de problÚme une RunTimeException est lancée
         */
        public void annuler_transaction() {
                try {
                        con.rollback();
                } catch (SQLException e) {
                        e.printStackTrace();
                        throw new RuntimeException("erreur fatale sgbd annulation de transaction");
                }
        }       
        
        public InfoConnectBean getInfo() {
                return info;
        }

        public void setInfo(InfoConnectBean info) {
                this.info = info;
        }
}