combopooleddatasource.java

c3p0数据库连接池实现源码

/*
 * Distributed as part of c3p0 v.0.9.1-pre6
 *
 * Copyright (C) 2005 Machinery For Change, Inc.
 *
 * Author: Steve Waldman <[e-mail]>
 *
 * This library is free software; you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License version 2.1, as 
 * published by the Free Software Foundation.
 *
 * This software is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this software; see the file LICENSE.  If not, write to the
 * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307, USA.
 */


package com.mchange.v2.c3p0;

import java.beans.*;
import java.io.*;
import java.sql.*;
import java.util.*;
import javax.naming.*;
import com.mchange.v2.log.*;
import com.mchange.v2.naming.*;
import com.mchange.v2.c3p0.impl.*;

import com.mchange.v2.beans.BeansUtils;
import com.mchange.v2.c3p0.cfg.C3P0Config;

// WrapperConnectionPoolDataSource properties -- count: 24
//
// 	("checkoutTimeout");
// 	("acquireIncrement");
// 	("acquireRetryAttempts");
// 	("acquireRetryDelay");
// 	("autoCommitOnClose");
// 	("connectionTesterClassName");
// 	("forceIgnoreUnresolvedTransactions");
// 	("idleConnectionTestPeriod");
// 	("initialPoolSize");
// 	("maxIdleTime");
// 	("maxPoolSize");
// 	("maxStatements");
// 	("maxStatementsPerConnection");
// 	("minPoolSize");
// 	("propertyCycle");
// 	("breakAfterAcquireFailure");
// 	("testConnectionOnCheckout");
// 	("testConnectionOnCheckin");
// 	("usesTraditionalReflectiveProxies");
// 	("preferredTestQuery");
// 	("automaticTestTable");
// 	("userOverridesAsString");
// 	("overrideDefaultUser");
// 	("overrideDefaultPassword");


/**
 * <p>For the meaning of most of these properties, please see {@link PoolConfig}!</p>
 */
public final class ComboPooledDataSource extends IdentityTokenResolvable implements PooledDataSource, Serializable, Referenceable
{
    final static MLogger logger = MLog.getLogger( ComboPooledDataSource.class );

    final static Set TO_STRING_IGNORE_PROPS = new HashSet( Arrays.asList( new String[] { 
									      "connection",
									      "logWriter",
									      "loginTimeout",
									      "numBusyConnections",
									      "numBusyConnectionsAllUsers",
									      "numBusyConnectionsDefaultUser",
									      "numConnections",
									      "numConnectionsAllUsers",
									      "numConnectionsDefaultUser",
									      "numIdleConnections",
									      "numIdleConnectionsAllUsers",
									      "numIdleConnectionsDefaultUser",
									      "numUnclosedOrphanedConnections",
									      "numUnclosedOrphanedConnectionsAllUsers",
									      "numUnclosedOrphanedConnectionsDefaultUser",
									      "numUserPools",
									      "overrideDefaultUser",
									      "overrideDefaultPassword",
									      "password",
									      "reference",
									      "user",
									      "userOverridesAsString"
									  } ) );

    // not reassigned post-ctor; mutable elements protected by their own locks
    // when (very rarely) necessery, we sync pbds -> wcpds -> dmds
    DriverManagerDataSource         dmds;
    WrapperConnectionPoolDataSource wcpds;
    PoolBackedDataSource            pbds;

    String identityToken;

    {
	// System.err.println("...Initializing ComboPooledDataSource.");

	dmds  = new DriverManagerDataSource();
	wcpds = new WrapperConnectionPoolDataSource();
	pbds  = new PoolBackedDataSource( this ); 

	wcpds.setNestedDataSource( dmds );
	pbds.setConnectionPoolDataSource( wcpds );

	this.identityToken = C3P0ImplUtils.identityToken( this );
	C3P0Registry.register( this );
    }

    public ComboPooledDataSource()
    {}

    public ComboPooledDataSource(String configName)
    {
	try
	    {
		if (configName != null)
		    {
			C3P0Config.bindNamedConfigToBean( this, configName ); 
			if ( this.getDataSourceName().equals( this.getIdentityToken() ) ) //dataSourceName has not been specified in config
			    this.setDataSourceName( configName );
		    }
	    }
	catch (Exception e)
	    {
		if (logger.isLoggable( MLevel.WARNING ))
		    logger.log( MLevel.WARNING, 
				"Error binding ComboPooledDataSource to named-config '" + configName + 
				"'. Some default-config values may be used.", 
				e);
	    }
    }

    // DriverManagerDataSourceProperties  (count: 4)
    public String getDescription()
    { return dmds.getDescription(); }
	
    public void setDescription( String description )
    { dmds.setDescription( description ); }
	
    public String getDriverClass()
    { return dmds.getDriverClass(); }
	
    public void setDriverClass( String driverClass ) throws PropertyVetoException
    { 
	dmds.setDriverClass( driverClass ); 
// 	System.err.println("setting driverClass: " + driverClass); 
    }
	
    public String getJdbcUrl()
    {  
// 	System.err.println("getting jdbcUrl: " + dmds.getJdbcUrl()); 
	return dmds.getJdbcUrl(); 
    }
	
    public void setJdbcUrl( String jdbcUrl )
    { 
	dmds.setJdbcUrl( jdbcUrl ); 
// 	System.err.println("setting jdbcUrl: " + jdbcUrl + " [dmds@" + C3P0ImplUtils.identityToken( dmds ) + "]"); 
// 	if (jdbcUrl == null)
// 	    new Exception("*** NULL SETTER ***").printStackTrace();
    }
	
    public Properties getProperties()
    { 
	//System.err.println("getting properties: " + dmds.getProperties()); 
	return dmds.getProperties(); 
    }
	
    public void setProperties( Properties properties )
    { 
	dmds.setProperties( properties ); 
	//System.err.println("setting properties: " + properties); 
    }
	
    // DriverManagerDataSource "virtual properties" based on properties
    public String getUser()
    { return dmds.getUser(); }
	
    public void setUser( String user )
    { dmds.setUser( user ); }
	
    public String getPassword()
    { return dmds.getPassword(); }
	
    public void setPassword( String password )
    { dmds.setPassword( password ); }

    // WrapperConnectionPoolDataSource properties (count: 21)
    public int getCheckoutTimeout()
    { return wcpds.getCheckoutTimeout(); }
	
    public void setCheckoutTimeout( int checkoutTimeout )
    { 
	synchronized ( pbds )
	    {
		wcpds.setCheckoutTimeout( checkoutTimeout ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getAcquireIncrement()
    { return wcpds.getAcquireIncrement(); }
	
    public void setAcquireIncrement( int acquireIncrement )
    { 
	synchronized ( pbds )
	    {
		wcpds.setAcquireIncrement( acquireIncrement ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getAcquireRetryAttempts()
    { return wcpds.getAcquireRetryAttempts(); }
	
    public void setAcquireRetryAttempts( int acquireRetryAttempts )
    { 
	synchronized ( pbds )
	    {
		wcpds.setAcquireRetryAttempts( acquireRetryAttempts ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getAcquireRetryDelay()
    { return wcpds.getAcquireRetryDelay(); }
	
    public void setAcquireRetryDelay( int acquireRetryDelay )
    { 
	synchronized ( pbds )
	    {
		wcpds.setAcquireRetryDelay( acquireRetryDelay ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public boolean isAutoCommitOnClose()
    { return wcpds.isAutoCommitOnClose(); }

    public void setAutoCommitOnClose( boolean autoCommitOnClose )
    { 
	synchronized ( pbds )
	    {
		wcpds.setAutoCommitOnClose( autoCommitOnClose ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public String getConnectionTesterClassName()
    { return wcpds.getConnectionTesterClassName(); }
	
    public void setConnectionTesterClassName( String connectionTesterClassName ) throws PropertyVetoException
    { 
	synchronized ( pbds )
	    {
		wcpds.setConnectionTesterClassName( connectionTesterClassName ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public String getAutomaticTestTable()
    { return wcpds.getAutomaticTestTable(); }
	
    public void setAutomaticTestTable( String automaticTestTable )
    { 
	synchronized ( pbds )
	    {
		wcpds.setAutomaticTestTable( automaticTestTable ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public boolean isForceIgnoreUnresolvedTransactions()
    { return wcpds.isForceIgnoreUnresolvedTransactions(); }
	
    public void setForceIgnoreUnresolvedTransactions( boolean forceIgnoreUnresolvedTransactions )
    { 
	synchronized ( pbds )
	    {
		wcpds.setForceIgnoreUnresolvedTransactions( forceIgnoreUnresolvedTransactions ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getIdleConnectionTestPeriod()
    { return wcpds.getIdleConnectionTestPeriod(); }
	
    public void setIdleConnectionTestPeriod( int idleConnectionTestPeriod )
    { 
	synchronized ( pbds )
	    {
		wcpds.setIdleConnectionTestPeriod( idleConnectionTestPeriod ); 
		pbds.resetPoolManager( false );
	    }
    }
    
    public int getInitialPoolSize()
    { return wcpds.getInitialPoolSize(); }
	
    public void setInitialPoolSize( int initialPoolSize )
    { 
	synchronized ( pbds )
	    {
		wcpds.setInitialPoolSize( initialPoolSize ); 
		pbds.resetPoolManager( false );
	    }
    }

    public int getMaxIdleTime()
    { return wcpds.getMaxIdleTime(); }
	
    public void setMaxIdleTime( int maxIdleTime )
    { 
	synchronized ( pbds )
	    {
		wcpds.setMaxIdleTime( maxIdleTime ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getMaxPoolSize()
    { return wcpds.getMaxPoolSize(); }
	
    public void setMaxPoolSize( int maxPoolSize )
    { 
	synchronized ( pbds )
	    {
		wcpds.setMaxPoolSize( maxPoolSize ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getMaxStatements()
    { return wcpds.getMaxStatements(); }
	
    public void setMaxStatements( int maxStatements )
    { 
	synchronized ( pbds )
	    {
		wcpds.setMaxStatements( maxStatements ); 
		pbds.resetPoolManager( false );
	    }
    }