TestDBConnector

package py.com.personal.tasacion.roaming.servicios.comunes;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import org.apache.ibatis.mapping.Environment;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.apache.ibatis.transaction.TransactionFactory;
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
import org.slf4j.Logger;

import py.com.personal.bc.common.utils.props.ApplicationProperties;
import py.com.personal.bc.mybatis.utils.DBConnector;
import py.com.personal.bc.mybatis.utils.MapperPackagesUtil;
import py.com.personal.bc.shared.mybatis.mapper.DireccionPrestadoraMapper;

import javax.annotation.PostConstruct;
import javax.inject.Inject;


public class TestDBConnector implements DBConnector {

    private SqlSessionFactory factory;

    @Inject
    ApplicationProperties appProps;

    @Inject
    MapperPackagesUtil mapperPackagesUtil;

    @Inject
    Logger logger;

    @PostConstruct
    public void init() {
        try {
            configureAtlasFactory();
        } catch (Exception e) {
            logger.error("No se ha podido inicializar la conexion a Atlas, se cierra la aplicacion", e);
            System.exit(0);
        }

    }

    public void configureAtlasFactory() throws Exception {


        logger.info("Iniciando conexion a BD Atlas");
        ComboPooledDataSource cpds = new ComboPooledDataSource();
        cpds.setDriverClass("org.postgresql.Driver");
        String jdbcUrl = "jdbc:postgresql://" + appProps.get(TestProperties.KEYS.DB_HOST) + ":" +
                appProps.get(TestProperties.KEYS.DB_PORT) + "/"
                + appProps.get(TestProperties.KEYS.DB_NAME);
        logger.info("JDBC_URL: {}. DB_USER: {}", jdbcUrl, appProps.get(TestProperties.KEYS.DB_USER));
        cpds.setJdbcUrl(jdbcUrl);

        if (appProps.get(TestProperties.KEYS.DB_USER) != null) {
            cpds.setUser(appProps.get(TestProperties.KEYS.DB_USER));
        }
        String passwd = appProps.get(TestProperties.KEYS.DB_PASSWORD);
        if (passwd != null && !passwd.trim().equals("")) {
            cpds.setPassword(passwd);
        }

        TransactionFactory transactionFactory = new JdbcTransactionFactory();
        Environment environment = new Environment("development", transactionFactory, cpds);

        Configuration configuration = new Configuration(environment);
        //mapperPackagesUtil.addMappersToConfiguration(configuration);
        configuration.addMappers(DireccionPrestadoraMapper.class.getPackage().getName());
        factory = new SqlSessionFactoryBuilder().build(configuration);
        logger.info("Pool de conexiones a Atlas inicializado");

    }

    @Override
    public SqlSession getSqlSession() {
        return factory.openSession();
    }

}