import org.apache.commons.dbcp.datasources.SharedPoolDataSource; //导入依赖的package包/类
/**
 * 
 */
public DbcpResourceFactory(final String dataSourceName, 
        final String driverClass, 
        final String url, 
        final String userName, 
        final String password,
        final int maxActive,
        final int maxIdle) throws PoolException{
    try {
       connectionPoolDataSource = AccessController.doPrivileged( new PrivilegedExceptionAction<ConnectionPoolDataSource>() {
            public ConnectionPoolDataSource run() throws Exception {
                //Using the generic connection pool adapter from DBCP, todo, look how to use the connection pool datasource provided by each driver
                DriverAdapterCPDS adapter = new DriverAdapterCPDS();
                adapter.setMaxActive( maxActive );
                adapter.setMaxIdle( maxIdle );
                adapter.setUrl( url );
                adapter.setUser( userName );
                adapter.setPassword( password );
                adapter.setDriver( driverClass );
                SharedPoolDataSource tds = new SharedPoolDataSource();
                tds.setConnectionPoolDataSource( adapter );
                tds.setMaxActive( maxActive );
                
                ds = tds;
                return adapter;
            }
        });
    } catch (Exception e) {
        // "Unable to initialize the shared connection pool DataSource"
        String msg = com.ibm.xsp.extlib.relational.RelationalResourceHandler.getSpecialAudienceString("DbcpPoolDataSource.Unabletoinitializethesharedconnec");//$NON-NLS-1$
        throw new PoolException( e, msg);
    }
}
 

import org.apache.commons.dbcp.datasources.SharedPoolDataSource; //导入依赖的package包/类
@Override
public void close()
{
  // TODO : This method is untested
  if (this.dataSource instanceof SharedPoolDataSource)
  {
    try
    {
      ((SharedPoolDataSource)this.dataSource).close();
    }
    catch (Exception e)
    {
      if (e instanceof SQLException)
      {
        Database.throwDatabaseException((SQLException)e);
      }
      else
      {
        throw new RuntimeException(e);
      }
    }
  }
  else
  {
    throw new UnsupportedOperationException("Close method is not yet implemented for SQLServer");
  }
}
 

import org.apache.commons.dbcp.datasources.SharedPoolDataSource; //导入依赖的package包/类
public static Connection getConnection( ServletContext servContext ) throws Exception
{
	if( !loaded )
	{
		String dbdriver = ConfigUtils.get("DBDriver");
		ConfigUtils.clear("DBDriver");
		String dbuser = ConfigUtils.get("DBUser");
		ConfigUtils.clear("DBUser");
		String dbpass = ConfigUtils.get("DBPass");
		ConfigUtils.clear("DBPass");
		String dburl = ConfigUtils.get("DBUrl");
		ConfigUtils.clear("DBUrl");

		try
		{
			DriverAdapterCPDS cpds = new DriverAdapterCPDS();
			cpds.setDriver(dbdriver);
			cpds.setUrl(dburl);
			
			Properties info = new Properties();
			info.put("user", dbuser);
			info.put("password", dbpass);
			cpds.setConnectionProperties(info);
			
			SharedPoolDataSource tds = new SharedPoolDataSource();
			tds.setConnectionPoolDataSource(cpds);
			
			/// TODO: Complete it with other parameters, also, benchmark
			/// Configuring other stuff
			tds.setValidationQuery("SELECT 1 FROM DUAL");
			tds.setTestOnBorrow(true);
			tds.setTestWhileIdle(true);
			tds.setDefaultTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
			
			String maxwait = ConfigUtils.get("DB.MaxWait");
			String maxtotal = ConfigUtils.get("DB.MaxTotal");
			String minidle = ConfigUtils.get("DB.MinIdle");
			String maxidle = ConfigUtils.get("DB.MaxIdle");
			String waiteviction = ConfigUtils.get("DB.WaitEviction");
			String numtesteviction =  ConfigUtils.get("DB.NumTestEviction");
			/// In case something hasn't been set
			if( maxwait == null ) maxwait = "1000";
			if( maxtotal == null ) maxtotal = "1000";
			if( minidle == null ) minidle = "1";
			if( maxidle == null ) maxidle = "1000";
			if( waiteviction == null ) waiteviction = "60000";
			if( numtesteviction == null ) numtesteviction = "10";
			
			tds.setMaxWait(Integer.decode(maxwait));
			tds.setMaxActive(Integer.decode(maxtotal));
			tds.setMaxIdle(Integer.decode(maxidle));
			tds.setTimeBetweenEvictionRunsMillis(Integer.decode(waiteviction));
			tds.setNumTestsPerEvictionRun(Integer.decode(numtesteviction));
			
			ds = tds;
		}
		catch( Exception e )
		{
			e.printStackTrace();
		}
		loaded = true;
	}
	return ds.getConnection();
}
 

import org.apache.commons.dbcp.datasources.SharedPoolDataSource; //导入依赖的package包/类
/**
 * Initializes datasource to point to SQL Server
 */
@Inject
public SQLServer()
{
  super();

  this.nextSequenceNumberLock       = new ReentrantLock();
  this.objectSequenceTableName      = "object_seq_table";
  this.transactionSequenceTableName = "transaction_seq_table";

  // The container is not providing a pooled datasource
  if (this.dataSource == null)
  {
    JtdsDataSource serverDataSource = new JtdsDataSource();
    serverDataSource.setServerName(DatabaseProperties.getServerName());
    serverDataSource.setPortNumber(DatabaseProperties.getPort());
    serverDataSource.setDatabaseName(DatabaseProperties.getDatabaseName());
    serverDataSource.setUser(DatabaseProperties.getUser());
    serverDataSource.setPassword(DatabaseProperties.getPassword());

    int maxDbConnections = DatabaseProperties.getMaxConnections() - 1;

    if (maxDbConnections < 2)
    {
      maxDbConnections = 2;
    }

    boolean pooling = DatabaseProperties.getConnectionPooling();
    if (pooling)
    {
      SharedPoolDataSource sharedPoolDataSource = new SharedPoolDataSource();
      sharedPoolDataSource.setConnectionPoolDataSource(serverDataSource);
      sharedPoolDataSource.setMaxActive(maxDbConnections);
      sharedPoolDataSource.setTestOnBorrow(true);
      sharedPoolDataSource.setValidationQuery("SELECT 1");
      this.dataSource = sharedPoolDataSource;
    }
    else
    {
      this.dataSource = serverDataSource;
    }
  }
}
 

import org.apache.commons.dbcp.datasources.SharedPoolDataSource; //导入依赖的package包/类
/**
 * Test SharedPoolDataSource bind and lookup
 * 
 * @throws Exception
 */
public void testSharedPoolDataSourceBind() throws Exception {
    SharedPoolDataSource dataSource = new SharedPoolDataSource();
    checkBind(dataSource);      
}