?? combopooleddatasource.java
字號(hào):
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(); }}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -