D-Net

package eu.dnetlib.openaire.user.store;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.util.Properties;

import org.apache.commons.dbcp.BasicDataSource;

/**

 * Created by sofia on 5/8/2016.

 */

public class JDBCConnector {

    private final static JDBCConnector INSTANCE = new JDBCConnector();

    public static synchronized JDBCConnector v() { return INSTANCE; }

    private final String username;

    private final String password;

    private final String dbUrl;

    private final String driver;

    private JDBCConnector()

    {

        try {

            // Read properties file

            InputStream stream = getClass().getClassLoader()

                    .getResourceAsStream("src/main/resources/config/postgresql.db.properties");

            Properties prop = new Properties();

            prop.load(stream);

            driver = prop.getProperty("driver");

            dbUrl = prop.getProperty("url");

            username = prop.getProperty("username");

            password = prop.getProperty("password");

            // Test for Driver's  existence

            Class.forName(driver);

            // Test Connection

            newConnection().close();

            BasicDataSource bds = new BasicDataSource();

            bds.setDriverClassName(driver);

            bds.setUrl(dbUrl);

            bds.setUsername(username);

            bds.setPassword(password);

            bds.setMaxIdle(10);

            bds.setMaxActive(100);

            bds.setMaxWait(10000);

            bds.setValidationQuery("select 1");

            bds.setTestOnBorrow(true);

            bds.setTestWhileIdle(true);

            bds.setTimeBetweenEvictionRunsMillis(1200000);

            bds.setMinEvictableIdleTimeMillis(1800000);

            bds.setNumTestsPerEvictionRun(5);

            bds.setDefaultAutoCommit(false);

        } catch (ClassNotFoundException | IOException | SQLException exc) {

            throw new RuntimeException(exc);

        }

    }

    private Connection newConnection()

            throws SQLException

    {

        return DriverManager.getConnection(dbUrl, username, password);

    }

}