ConnectorPool.java

package database;

import java.sql.Connection;
import java.io.PrintStream;
import org.apache.commons.dbcp.ConnectionFactory;
import org.apache.commons.dbcp.DriverManagerConnectionFactory;
import org.apache.commons.dbcp.PoolableConnectionFactory;
import org.apache.commons.dbcp.PoolingDataSource;
import org.apache.commons.pool.impl.GenericObjectPool;

public class ConnectorPool implements IConnector{
	private String driverName;
	private String fullPath;
	private String user;
	private String password;
	PoolingDataSource poolDataSource;
	private PrintStream outError;
	
	public void setOutError(PrintStream out){
		this.outError=out;
	}
	
	private void outError(Object information){
		PrintStream currentOut=(this.outError==null)?System.out: this.outError;
		currentOut.print("ConnectionPool");
		currentOut.print(" ERROR ");
		currentOut.println(information);
	}
	
	
	/** ñîçäàòü îáúåêò, êîòîðûé ñîäåðæèò POOL ñîåäèíåíèé ñ áàçîé äàííûõ 
	 * @param driverName - èìÿ äðàéâåðà äëÿ ñîåäèíåíèÿ ñ JDBC
	 * @param fullPath - ïîëíûé URL ê áàçå äàííûõ 
	 * @param userName - User Name
	 * @param password - Password
	 * @throws Exception - åñëè ïðîèçîøëà êàêàÿ-ëèáî îøèáêà âî âðåìÿ ïîïûòêè ñîåäèíåíèÿ ñ áàçîé äàííûõ
	 * */
	public ConnectorPool(String driverName, String fullPath, String userName, String password) throws Exception {
		this.driverName=driverName;
		this.fullPath=fullPath;
		this.user=userName;
		this.password=password;
		if(initPool()==false){
			throw new Exception("init Error");
		}
	}
	
	private boolean initPool() throws ClassNotFoundException {
		Class.forName(driverName);
		String connectionString = fullPath;
		GenericObjectPool connectionPool = new GenericObjectPool(null);
		ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(connectionString, user, password);
		new PoolableConnectionFactory(connectionFactory, 
									  connectionPool, 
									  null,
							          null, 
							          false, 
							          false);
		poolDataSource= new PoolingDataSource(connectionPool);		
		return true;
	}
	
	@Override
	public Connection getConnection() {
		try{
			return poolDataSource.getConnection();
		}catch(Exception ex){
			outError("getConnection Exception:"+ex.getMessage());
			return null;
		}
		 
	}

	@Override
	public Connection getConnection(String user, String password){
		try{
			return poolDataSource.getConnection(user,password);
		}catch(Exception ex){
			outError("getConnection Exception:"+ex.getMessage());
			return null;
		}
	}
	 
}