D-Net

package eu.dnetlib.openaire.user.store;

import org.apache.commons.dbcp.BasicDataSource;

import javax.sql.DataSource;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.util.Properties;

/**

 * Created by sofia on 31/10/2016.

 */

public class DataSourceConnector

{

    private final static DataSourceConnector INSTANCE = new DataSourceConnector();

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

    private final String username;

    private final String password;

    private final String dbUrl;

    private final String driver;

    private static boolean driverLoad = false;

    private final DataSource datasource;

    private DataSourceConnector()

    {

        try {

            // Read properties file for database connection

            InputStream streamSQL = getClass()

                    .getResourceAsStream("/config/migration2.postgresql.db.properties");

            Properties propSQL = new Properties();

            propSQL.load(streamSQL);

            driver = propSQL.getProperty("openaire.db.driverClassName");

            dbUrl = propSQL.getProperty("openaire.db.url");

            username = propSQL.getProperty("openaire.db.username");

            password = propSQL.getProperty("openaire.db.password");

//            System.out.println("Username: " + username);

//            System.out.println("password: " + password);

//            System.out.println("driver: " + driver);

//            System.out.println("Url: " + dbUrl);

            // Test for Driver's  existence

            Class.forName(driver);

            driverLoad=true;

            // Test Connection

            getConnection().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(true);

            this.datasource = bds;

        } catch (ClassNotFoundException | IOException | SQLException exc) {

            throw new RuntimeException(exc);

        }

    }

    public Connection getConnection()

            throws SQLException

    {

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

        //return DriverManager.getConnection("jdbc:postgresql://localhost:5433/MigrationUser?user=postgres&password=mypassword");

    }

    public DataSource getDatasource() {

        return datasource;

    }

    public static void main(String[] args) throws SQLException {

        v().getConnection().close();

    }

}