D-Net

package eu.dnetlib.data.mapreduce.hbase.lodImport.utils;

import java.beans.PropertyVetoException;

import java.io.IOException;

import java.sql.SQLException;

import org.apache.log4j.Logger;

import com.jolbox.bonecp.BoneCP;

import com.jolbox.bonecp.BoneCPConfig;

import com.jolbox.bonecp.BoneCPDataSource;

public class DB  {

	 private Logger log = Logger.getLogger(DB.class);

	 private BoneCPDataSource ds;

	 private BoneCP connectionPool;

	 public DB(){

	 }

//	 public DB(String conLine, String username, String password, String minCpart, String maxCpart, String part) throws IOException, SQLException, PropertyVetoException {

//	        try {

//	            // load the database driver (make sure this is in your classpath!)

//	            Class.forName("virtuoso.jdbc4.Driver");

//	        } catch (Exception e) {

//	        	log.error(e.getMessage(), e);

//	            return;

//	        }

//

//	        try {

//	        	

////	        	Will have to read Iterable via an external File (oozie Configuration maybe)

//	        	

//	            // setup the connection pool using BoneCP Configuration

//	            BoneCPConfig config = new BoneCPConfig();

//	            // jdbc url specific to the virtuoso, eg jdbc:mysql://127.0.0.1/yourdb

//	            config.setJdbcUrl(conLine);

//	            config.setUsername(username);

//	            config.setPassword(password);

//	            config.setMinConnectionsPerPartition(Integer.parseInt(minCpart));

//	            config.setMaxConnectionsPerPartition(Integer.parseInt(maxCpart));

//	            config.setPartitionCount(Integer.parseInt(part));

//	            // setup the connection pool

//	            connectionPool = new BoneCP(config);

//	        } catch (Exception e) {

//	        	log.error(e.getMessage(), e);

//	            return;

//	        }

//

//	    }

	 public BoneCPDataSource getDatasource(String conLine, String username, String password, String minCpart, String maxCpart, String part) throws IOException, SQLException, PropertyVetoException {

		 try {

//	            // load the database driver (make sure this is in your classpath!)

	            Class.forName("virtuoso.jdbc4.Driver");

	        } catch (Exception e) {

	        	log.error(e.getMessage(), e);

	        }

		 BoneCPConfig config = new BoneCPConfig();

         config.setJdbcUrl(conLine);

         config.setUsername(username);

         config.setPassword(password);

         config.setMinConnectionsPerPartition(Integer.parseInt(minCpart));

         config.setMaxConnectionsPerPartition(Integer.parseInt(maxCpart));

         config.setPartitionCount(Integer.parseInt(part));

         config.setPoolStrategy("CACHED");

	  	ds = new BoneCPDataSource(config); 

        return ds;

	    }

	 public  BoneCP getConnectionPool(String conLine, String username, String password, String minCpart, String maxCpart, String part) throws IOException, SQLException, PropertyVetoException {

		 try {

//	            // load the database driver (make sure this is in your classpath!)

	            Class.forName("virtuoso.jdbc4.Driver");

	        } catch (Exception e) {

	        	log.error(e.getMessage(), e);

	        }

		 BoneCPConfig config = new BoneCPConfig();

         config.setJdbcUrl(conLine);

         config.setUsername(username);

         config.setPassword(password);

         config.setMinConnectionsPerPartition(Integer.parseInt(minCpart));

         config.setMaxConnectionsPerPartition(Integer.parseInt(maxCpart));

         config.setPartitionCount(Integer.parseInt(part));

        connectionPool = new BoneCP(config);

        return connectionPool;

	    }

	 public void closeConnectionPool() throws SQLException {

	        connectionPool.shutdown();

	    }

	 public void closeDatasource() throws SQLException {

	        ds.close();

	    }

}