combopooleddatasource.java

c3p0数据库连接池实现源码

    public int getMaxStatementsPerConnection()
    { return wcpds.getMaxStatementsPerConnection(); }
	
    public void setMaxStatementsPerConnection( int maxStatementsPerConnection )
    { 
	synchronized ( pbds )
	    {
		wcpds.setMaxStatementsPerConnection( maxStatementsPerConnection ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getMinPoolSize()
    { return wcpds.getMinPoolSize(); }
	
    public void setMinPoolSize( int minPoolSize )
    { 
	synchronized ( pbds )
	    {
		wcpds.setMinPoolSize( minPoolSize ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public String getOverrideDefaultUser()
    { return wcpds.getOverrideDefaultUser(); }
	
    public void setOverrideDefaultUser(String overrideDefaultUser)
    { 
	synchronized ( pbds )
	    {
		wcpds.setOverrideDefaultUser( overrideDefaultUser ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public String getOverrideDefaultPassword()
    { return wcpds.getOverrideDefaultPassword(); }
	
    public void setOverrideDefaultPassword(String overrideDefaultPassword)
    { 
	synchronized ( pbds )
	    {
		wcpds.setOverrideDefaultPassword( overrideDefaultPassword ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public int getPropertyCycle()
    { return wcpds.getPropertyCycle(); }
	
    public void setPropertyCycle( int propertyCycle )
    { 
	synchronized ( pbds )
	    {
		wcpds.setPropertyCycle( propertyCycle ); 
		pbds.resetPoolManager( false );
	    }
    }
    
    public boolean isBreakAfterAcquireFailure()
    { return wcpds.isBreakAfterAcquireFailure(); }
    
    public void setBreakAfterAcquireFailure( boolean breakAfterAcquireFailure )
    { 
	synchronized ( pbds )
	    {
		wcpds.setBreakAfterAcquireFailure( breakAfterAcquireFailure ); 
		pbds.resetPoolManager( false );
	    }
    }
    
    public boolean isTestConnectionOnCheckout()
    { return wcpds.isTestConnectionOnCheckout(); }
	
    public void setTestConnectionOnCheckout( boolean testConnectionOnCheckout )
    { 
	synchronized ( pbds )
	    {
		wcpds.setTestConnectionOnCheckout( testConnectionOnCheckout ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public boolean isTestConnectionOnCheckin()
    { return wcpds.isTestConnectionOnCheckin(); }
	
    public void setTestConnectionOnCheckin( boolean testConnectionOnCheckin )
    { 
	synchronized ( pbds )
	    {
		wcpds.setTestConnectionOnCheckin( testConnectionOnCheckin ); 
		pbds.resetPoolManager( false );
	    }
    }
	
    public boolean isUsesTraditionalReflectiveProxies()
    { return wcpds.isUsesTraditionalReflectiveProxies(); }
	
    public void setUsesTraditionalReflectiveProxies( boolean usesTraditionalReflectiveProxies )
    { 
	synchronized ( pbds )
	    {
		wcpds.setUsesTraditionalReflectiveProxies( usesTraditionalReflectiveProxies ); 
		pbds.resetPoolManager( false );
	    }
    }

    public String getPreferredTestQuery()
    { return wcpds.getPreferredTestQuery(); }
	
    public void setPreferredTestQuery( String preferredTestQuery )
    { 
	synchronized ( pbds )
	    {
		wcpds.setPreferredTestQuery( preferredTestQuery ); 
		pbds.resetPoolManager( false );
	    }
    }

    public String getUserOverridesAsString()
    { return wcpds.getUserOverridesAsString(); }
	
    public void setUserOverridesAsString( String userOverridesAsString ) throws PropertyVetoException
    { 
	synchronized ( pbds )
	    {
		wcpds.setUserOverridesAsString( userOverridesAsString ); 
		pbds.resetPoolManager( false );
	    }
    }

    // PoolBackedDataSource properties (count: 2)
    public String getDataSourceName()
    { return pbds.getDataSourceName(); }
	
    public void setDataSourceName( String name )
    { pbds.setDataSourceName( name ); }

    public int getNumHelperThreads()
    { return pbds.getNumHelperThreads(); }
	
    public void setNumHelperThreads( int numHelperThreads )
    { pbds.setNumHelperThreads( numHelperThreads ); }


    // identity tokens
    public String getIdentityToken()
    { return identityToken; }
	
    public void setIdentityToken(String identityToken)
    { this.identityToken = identityToken; }
	
    // shared properties (count: 1)
    public String getFactoryClassLocation()
    {
	return dmds.getFactoryClassLocation();
    }
    
    public void setFactoryClassLocation( String factoryClassLocation )
    {
	synchronized ( pbds )
	    {
		synchronized ( wcpds )
		    {
			synchronized( dmds )
			    {
				dmds.setFactoryClassLocation( factoryClassLocation );
				wcpds.setFactoryClassLocation( factoryClassLocation );
				pbds.setFactoryClassLocation( factoryClassLocation );
			    }
		    }
	    }
    }


    final static JavaBeanReferenceMaker referenceMaker = new JavaBeanReferenceMaker();
    
    static
    {
	referenceMaker.setFactoryClassName( C3P0JavaBeanObjectFactory.class.getName() );

	// DriverManagerDataSource properties (count: 4)
	referenceMaker.addReferenceProperty("description");
	referenceMaker.addReferenceProperty("driverClass");
	referenceMaker.addReferenceProperty("jdbcUrl");
	referenceMaker.addReferenceProperty("properties");

	// WrapperConnectionPoolDataSource properties (count: 22)
	referenceMaker.addReferenceProperty("checkoutTimeout");
	referenceMaker.addReferenceProperty("acquireIncrement");
	referenceMaker.addReferenceProperty("acquireRetryAttempts");
	referenceMaker.addReferenceProperty("acquireRetryDelay");
	referenceMaker.addReferenceProperty("autoCommitOnClose");
	referenceMaker.addReferenceProperty("connectionTesterClassName");
	referenceMaker.addReferenceProperty("forceIgnoreUnresolvedTransactions");
	referenceMaker.addReferenceProperty("idleConnectionTestPeriod");
	referenceMaker.addReferenceProperty("initialPoolSize");
	referenceMaker.addReferenceProperty("maxIdleTime");
	referenceMaker.addReferenceProperty("maxPoolSize");
	referenceMaker.addReferenceProperty("maxStatements");
	referenceMaker.addReferenceProperty("maxStatementsPerConnection");
	referenceMaker.addReferenceProperty("minPoolSize");
	referenceMaker.addReferenceProperty("propertyCycle");
	referenceMaker.addReferenceProperty("breakAfterAcquireFailure");
	referenceMaker.addReferenceProperty("testConnectionOnCheckout");
	referenceMaker.addReferenceProperty("testConnectionOnCheckin");
	referenceMaker.addReferenceProperty("usesTraditionalReflectiveProxies");
	referenceMaker.addReferenceProperty("preferredTestQuery");
	referenceMaker.addReferenceProperty("automaticTestTable");
	referenceMaker.addReferenceProperty("userOverridesAsString");

	// PoolBackedDataSource properties (count: 2)
	referenceMaker.addReferenceProperty("dataSourceName");
	referenceMaker.addReferenceProperty("numHelperThreads");

	// identity token
	referenceMaker.addReferenceProperty("identityToken");

	// shared properties (count: 1)
	referenceMaker.addReferenceProperty("factoryClassLocation");
    }
    
    public Reference getReference() throws NamingException
    { 
	synchronized ( pbds )
	    {
		synchronized ( wcpds )
		    {
			synchronized( dmds )
			    {
				//System.err.println("ComboPooledDataSource.getReference()!!!!");
				//new Exception("PRINT-STACK-TRACE").printStackTrace();
				//javax.naming.Reference out = referenceMaker.createReference( this ); 
				//System.err.println(out);
				//return out;

				return referenceMaker.createReference( this ); 
			    }
		    }
	    }
    }

    // DataSource implementation
    public Connection getConnection() throws SQLException
    { return pbds.getConnection(); }

    public Connection getConnection(String username, String password) throws SQLException
    { return pbds.getConnection( username, password );  }

    public PrintWriter getLogWriter() throws SQLException
    { return pbds.getLogWriter(); }

    public void setLogWriter(PrintWriter out) throws SQLException
    { pbds.setLogWriter( out ); }

    public int getLoginTimeout() throws SQLException
    { return pbds.getLoginTimeout(); }

    public void setLoginTimeout(int seconds) throws SQLException
    { pbds.setLoginTimeout( seconds ); }

    //implementation of com.mchange.v2.c3p0.PoolingDataSource
    public int getNumConnections() throws SQLException
    { return pbds.getNumConnections(); }

    public int getNumIdleConnections() throws SQLException
    { return pbds.getNumIdleConnections(); }

    public int getNumBusyConnections() throws SQLException
    { return pbds.getNumBusyConnections(); }

    public int getNumUnclosedOrphanedConnections() throws SQLException
    { return pbds.getNumUnclosedOrphanedConnections(); }

    public int getNumConnectionsDefaultUser() throws SQLException
    { return pbds.getNumConnectionsDefaultUser(); }

    public int getNumIdleConnectionsDefaultUser() throws SQLException
    { return pbds.getNumIdleConnectionsDefaultUser(); }

    public int getNumBusyConnectionsDefaultUser() throws SQLException
    { return pbds.getNumBusyConnectionsDefaultUser(); }

    public int getNumUnclosedOrphanedConnectionsDefaultUser() throws SQLException
    { return pbds.getNumUnclosedOrphanedConnectionsDefaultUser(); }

    public void softResetDefaultUser() throws SQLException
    { pbds.softResetDefaultUser();}

    public int getNumConnections(String username, String password) throws SQLException
    { return pbds.getNumConnections( username, password ); }

    public int getNumIdleConnections(String username, String password) throws SQLException
    { return pbds.getNumIdleConnections( username, password ); }

    public int getNumBusyConnections(String username, String password) throws SQLException
    { return pbds.getNumBusyConnections( username, password ); }

    public int getNumUnclosedOrphanedConnections(String username, String password) throws SQLException
    { return pbds.getNumUnclosedOrphanedConnections( username, password ); }

    public void softReset(String username, String password) throws SQLException
    { pbds.softReset( username, password );}

    public int getNumBusyConnectionsAllUsers() throws SQLException
    { return pbds.getNumBusyConnectionsAllUsers(); }

    public int getNumIdleConnectionsAllUsers() throws SQLException
    { return pbds.getNumIdleConnectionsAllUsers(); }

    public int getNumConnectionsAllUsers() throws SQLException
    { return pbds.getNumConnectionsAllUsers(); }

    public int getNumUnclosedOrphanedConnectionsAllUsers() throws SQLException
    { return pbds.getNumUnclosedOrphanedConnectionsAllUsers(); }

    public void softResetAllUsers() throws SQLException
    { pbds.softResetAllUsers();}

    public int getNumUserPools() throws SQLException
    { return pbds.getNumUserPools(); }


    public Collection getAllUsers() throws SQLException
    { return pbds.getAllUsers(); }

    public void hardReset() throws SQLException
    { pbds.hardReset(); }

    public void close() throws SQLException
    { pbds.close(); }

    public void close( boolean force_destroy ) throws SQLException
    { pbds.close( force_destroy ); }

    public String toString()
    {
	StringBuffer sb = new StringBuffer(255);
	sb.append( super.toString() );
	sb.append("[ ");
	try { BeansUtils.appendPropNamesAndValues(sb, this, TO_STRING_IGNORE_PROPS); }
	catch (Exception e)
	    { sb.append( e.toString() ); }
	sb.append(" ]");

// 	Map userOverrides = wcpds.getUserOverrides();
// 	if (userOverrides != null)
// 	    sb.append("; userOverrides: " + userOverrides.toString());

	return sb.toString();
    }
}