From b44d53ddefa9ba723fefba0624e469640c0e3745 Mon Sep 17 00:00:00 2001 From: wenshao Date: Tue, 6 Sep 2011 14:29:49 +0000 Subject: [PATCH] rename git-svn-id: http://code.alibabatech.com/svn/druid/trunk@663 b9813039-fb51-4c41-a8b9-e21c2acb5095 --- .../druid/pool/DruidDataSourceC3P0Wrap.java | 415 ------------------ .../pool/DruidDataSourceC3P0WrapMBean.java | 48 -- 2 files changed, 463 deletions(-) delete mode 100644 src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0Wrap.java delete mode 100644 src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0WrapMBean.java diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0Wrap.java b/src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0Wrap.java deleted file mode 100644 index 10713af105..0000000000 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0Wrap.java +++ /dev/null @@ -1,415 +0,0 @@ -package com.alibaba.druid.pool; - -import java.io.PrintWriter; -import java.sql.Connection; -import java.sql.SQLException; - -import javax.sql.DataSource; - -public class DruidDataSourceC3P0Wrap implements DataSource, DruidDataSourceC3P0WrapMBean { - - private DruidDataSource dataSource; - - public DruidDataSourceC3P0Wrap(){ - dataSource = new DruidDataSource(); - } - - @Override - public PrintWriter getLogWriter() throws SQLException { - return dataSource.getLogWriter(); - } - - @Override - public void setLogWriter(PrintWriter out) throws SQLException { - dataSource.setLogWriter(out); - } - - @Override - public void setLoginTimeout(int seconds) throws SQLException { - dataSource.setLoginTimeout(seconds); - } - - @Override - public int getLoginTimeout() throws SQLException { - return dataSource.getLoginTimeout(); - } - - @SuppressWarnings("unchecked") - @Override - public T unwrap(Class iface) throws SQLException { - if (iface == DruidDataSourceC3P0Wrap.class) { - return (T) this; - } - - return dataSource.unwrap(iface); - } - - @Override - public boolean isWrapperFor(Class iface) throws SQLException { - if (iface == DruidDataSourceC3P0Wrap.class) { - return true; - } - - return dataSource.isWrapperFor(iface); - } - - @Override - public Connection getConnection() throws SQLException { - return dataSource.getConnection(); - } - - @Override - public Connection getConnection(String username, String password) throws SQLException { - return dataSource.getConnection(username, password); - } - - public String getUser() { - return dataSource.getUsername(); - } - - public void setUser(String user) { - dataSource.setUsername(user); - } - - public String getPassword() { - return dataSource.getPassword(); - } - - public void setPassword(String password) { - dataSource.setPassword(password); - } - - public int getCheckoutTimeout() { - return (int) dataSource.getMaxWait(); - } - - public void setCheckoutTimeout(int checkoutTimeout) { - dataSource.setMaxWait(checkoutTimeout); - } - - public boolean isAutoCommitOnClose() { - return dataSource.isDefaultAutoCommit(); - } - - public void setAutoCommitOnClose(boolean autoCommitOnClose) { - this.dataSource.setDefaultAutoCommit(autoCommitOnClose); - } - - public int getIdleConnectionTestPeriod() { - return (int) dataSource.getTimeBetweenEvictionRunsMillis(); - } - - public void setIdleConnectionTestPeriod(int idleConnectionTestPeriod) { - dataSource.setTimeBetweenEvictionRunsMillis(idleConnectionTestPeriod); - } - - public int getInitialPoolSize() { - return dataSource.getInitialSize(); - } - - public void setInitialPoolSize(int initialPoolSize) { - dataSource.setInitialSize(initialPoolSize); - } - - public int getMaxIdleTime() { - return (int) dataSource.getMinEvictableIdleTimeMillis(); - } - - public void setMaxIdleTime(int maxIdleTime) { - dataSource.setMinEvictableIdleTimeMillis(maxIdleTime); - } - - public int getMaxPoolSize() { - return dataSource.getMaxActive(); - } - - public void setMaxPoolSize(int maxPoolSize) { - dataSource.setMaxActive(maxPoolSize); - } - - public int getMinPoolSize() { - return dataSource.getMinIdle(); - } - - public void setMinPoolSize(int minPoolSize) { - dataSource.setMinIdle(minPoolSize); - } - - public boolean isTestConnectionOnCheckout() { - return dataSource.isTestOnBorrow(); - } - - public void setTestConnectionOnCheckout(boolean testConnectionOnCheckout) { - dataSource.setTestOnBorrow(testConnectionOnCheckout); - } - - public boolean isTestConnectionOnCheckin() { - return dataSource.isTestOnReturn(); - } - - public void setTestConnectionOnCheckin(boolean testConnectionOnCheckin) { - dataSource.setTestOnReturn(testConnectionOnCheckin); - } - - public String getPreferredTestQuery() { - return dataSource.getValidationQuery(); - } - - public void setPreferredTestQuery(String preferredTestQuery) { - dataSource.setValidationQuery(preferredTestQuery); - } - - public String getDataSourceName() { - return dataSource.getName(); - } - - public int getNumConnections() { - return dataSource.getActiveCount() + dataSource.getPoolingCount(); - } - - public int getNumIdleConnections() { - return dataSource.getPoolingCount(); - } - - public int getNumBusyConnections() { - return dataSource.getActiveCount(); - } - - public int getNumUnclosedOrphanedConnections() { - return 0; - } - - public int getNumConnectionsDefaultUser() { - return getNumConnections(); - } - - public int getNumIdleConnectionsDefaultUser() { - return getNumIdleConnections(); - } - - public int getNumBusyConnectionsDefaultUser() { - return getNumBusyConnections(); - } - - // ///////////////// - - @Override - public boolean isEnable() { - return dataSource.isEnable(); - } - - @Override - public void shrink() { - dataSource.shrink(); - } - - @Override - public int getWaitThreadCount() { - return dataSource.getWaitThreadCount(); - } - - @Override - public int getLockQueueLength() { - return dataSource.getLockQueueLength(); - } - - @Override - public void close() { - dataSource.close(); - } - - // /////////////// - - private int maxStatementsPerConnection; - private String overrideDefaultUser; - private String overrideDefaultPassword; - private int propertyCycle; - private boolean breakAfterAcquireFailure; - private boolean usesTraditionalReflectiveProxies; - private String userOverridesAsString; - private int maxAdministrativeTaskTime; - private int maxIdleTimeExcessConnections; - private int maxConnectionAge; - private String connectionCustomizerClassName; - private int unreturnedConnectionTimeout; - private boolean debugUnreturnedConnectionStackTraces; - private String factoryClassLocation; - private int acquireIncrement = 1; - private int acquireRetryDelay; - private int acquireRetryAttempts; - - private String connectionTesterClassName; - private String automaticTestTable; - private int maxStatements; - - public int getMaxStatements() { - return maxStatements; - } - - public void setMaxStatements(int maxStatements) { - this.maxStatements = maxStatements; - } - - public int getMaxStatementsPerConnection() { - return maxStatementsPerConnection; - } - - public void setMaxStatementsPerConnection(int maxStatementsPerConnection) { - this.maxStatementsPerConnection = maxStatementsPerConnection; - } - - public String getConnectionTesterClassName() { - return connectionTesterClassName; - } - - public void setConnectionTesterClassName(String connectionTesterClassName) { - this.connectionTesterClassName = connectionTesterClassName; - } - - public String getAutomaticTestTable() { - return automaticTestTable; - } - - public void setAutomaticTestTable(String automaticTestTable) { - this.automaticTestTable = automaticTestTable; - } - - private boolean forceIgnoreUnresolvedTransactions; - - public boolean isForceIgnoreUnresolvedTransactions() { - return forceIgnoreUnresolvedTransactions; - } - - public void setForceIgnoreUnresolvedTransactions(boolean forceIgnoreUnresolvedTransactions) { - this.forceIgnoreUnresolvedTransactions = forceIgnoreUnresolvedTransactions; - } - - public boolean isUsesTraditionalReflectiveProxies() { - return usesTraditionalReflectiveProxies; - } - - public void setUsesTraditionalReflectiveProxies(boolean usesTraditionalReflectiveProxies) { - this.usesTraditionalReflectiveProxies = usesTraditionalReflectiveProxies; - } - - public String getUserOverridesAsString() { - return userOverridesAsString; - } - - public void setUserOverridesAsString(String userOverridesAsString) { - this.userOverridesAsString = userOverridesAsString; - } - - public int getMaxAdministrativeTaskTime() { - return maxAdministrativeTaskTime; - } - - public void setMaxAdministrativeTaskTime(int maxAdministrativeTaskTime) { - this.maxAdministrativeTaskTime = maxAdministrativeTaskTime; - } - - public int getMaxIdleTimeExcessConnections() { - return maxIdleTimeExcessConnections; - } - - public void setMaxIdleTimeExcessConnections(int maxIdleTimeExcessConnections) { - this.maxIdleTimeExcessConnections = maxIdleTimeExcessConnections; - } - - public int getMaxConnectionAge() { - return maxConnectionAge; - } - - public void setMaxConnectionAge(int maxConnectionAge) { - this.maxConnectionAge = maxConnectionAge; - } - - public String getConnectionCustomizerClassName() { - return connectionCustomizerClassName; - } - - public void setConnectionCustomizerClassName(String connectionCustomizerClassName) { - this.connectionCustomizerClassName = connectionCustomizerClassName; - } - - public int getUnreturnedConnectionTimeout() { - return unreturnedConnectionTimeout; - } - - public void setUnreturnedConnectionTimeout(int unreturnedConnectionTimeout) { - this.unreturnedConnectionTimeout = unreturnedConnectionTimeout; - } - - public boolean isDebugUnreturnedConnectionStackTraces() { - return debugUnreturnedConnectionStackTraces; - } - - public void setDebugUnreturnedConnectionStackTraces(boolean debugUnreturnedConnectionStackTraces) { - this.debugUnreturnedConnectionStackTraces = debugUnreturnedConnectionStackTraces; - } - - public String getFactoryClassLocation() { - return factoryClassLocation; - } - - public void setFactoryClassLocation(String factoryClassLocation) { - this.factoryClassLocation = factoryClassLocation; - } - - public int getAcquireIncrement() { - return acquireIncrement; - } - - public void setAcquireIncrement(int acquireIncrement) { - this.acquireIncrement = acquireIncrement; - } - - public int getAcquireRetryAttempts() { - return acquireRetryAttempts; - } - - public void setAcquireRetryAttempts(int acquireRetryAttempts) { - this.acquireRetryAttempts = acquireRetryAttempts; - } - - public int getAcquireRetryDelay() { - return acquireRetryDelay; - } - - public void setAcquireRetryDelay(int acquireRetryDelay) { - this.acquireRetryDelay = acquireRetryDelay; - } - - public String getOverrideDefaultUser() { - return overrideDefaultUser; - } - - public void setOverrideDefaultUser(String overrideDefaultUser) { - this.overrideDefaultUser = overrideDefaultUser; - } - - public String getOverrideDefaultPassword() { - return overrideDefaultPassword; - } - - public void setOverrideDefaultPassword(String overrideDefaultPassword) { - this.overrideDefaultPassword = overrideDefaultPassword; - } - - public int getPropertyCycle() { - return propertyCycle; - } - - public void setPropertyCycle(int propertyCycle) { - this.propertyCycle = propertyCycle; - } - - public boolean isBreakAfterAcquireFailure() { - return breakAfterAcquireFailure; - } - - public void setBreakAfterAcquireFailure(boolean breakAfterAcquireFailure) { - this.breakAfterAcquireFailure = breakAfterAcquireFailure; - } - -} diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0WrapMBean.java b/src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0WrapMBean.java deleted file mode 100644 index ba3908fcba..0000000000 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSourceC3P0WrapMBean.java +++ /dev/null @@ -1,48 +0,0 @@ -package com.alibaba.druid.pool; - -public interface DruidDataSourceC3P0WrapMBean { - - String getUser(); - - int getCheckoutTimeout(); - - boolean isAutoCommitOnClose(); - - int getIdleConnectionTestPeriod(); - - int getInitialPoolSize(); - - int getMaxIdleTime(); - - int getMaxPoolSize(); - - int getMinPoolSize(); - - boolean isTestConnectionOnCheckout(); - - boolean isTestConnectionOnCheckin(); - - String getPreferredTestQuery(); - - int getNumIdleConnections(); - - int getNumConnections(); - - String getDataSourceName(); - - int getNumBusyConnections(); - - // ////////// - - boolean isEnable(); - - void shrink(); - - String toString(); - - int getWaitThreadCount(); - - int getLockQueueLength(); - - void close(); -}