tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fha...@apache.org
Subject svn commit: r757705 - in /tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool: DataSource.java DataSourceFactory.java DataSourceProxy.java interceptor/SlowQueryReportJmx.java
Date Tue, 24 Mar 2009 10:35:06 GMT
Author: fhanik
Date: Tue Mar 24 10:35:04 2009
New Revision: 757705

URL: http://svn.apache.org/viewvc?rev=757705&view=rev
Log:
Setup datasource so that one can extend it more easily

Modified:
    tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSource.java
    tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceFactory.java
    tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceProxy.java
    tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/SlowQueryReportJmx.java

Modified: tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSource.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSource.java?rev=757705&r1=757704&r2=757705&view=diff
==============================================================================
--- tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSource.java (original)
+++ tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSource.java Tue Mar
24 10:35:04 2009
@@ -25,4 +25,12 @@
  */
 public class DataSource extends DataSourceProxy implements javax.sql.DataSource {
 
+    public DataSource() {
+        super();
+    }
+
+    public DataSource(PoolProperties poolProperties) {
+        super(poolProperties);
+    }
+    
 }

Modified: tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceFactory.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceFactory.java?rev=757705&r1=757704&r2=757705&view=diff
==============================================================================
--- tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceFactory.java
(original)
+++ tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceFactory.java
Tue Mar 24 10:35:04 2009
@@ -18,6 +18,7 @@
 
 
 import java.io.ByteArrayInputStream;
+import java.io.IOException;
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
@@ -187,27 +188,19 @@
 
         return createDataSource(properties);
     }
-
-    /**
-     * Creates and configures a {@link BasicDataSource} instance based on the
-     * given properties.
-     *
-     * @param properties the datasource configuration properties
-     * @throws Exception if an error occurs creating the data source
-     */
-    public static DataSource createDataSource(Properties properties) throws Exception {
-        org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
-
+    
+    public static PoolProperties parsePoolProperties(Properties properties) throws IOException{
+        PoolProperties poolProperties = new PoolProperties();
         String value = null;
 
         value = properties.getProperty(PROP_DEFAULTAUTOCOMMIT);
         if (value != null) {
-            dataSource.getPoolProperties().setDefaultAutoCommit(Boolean.valueOf(value));
+            poolProperties.setDefaultAutoCommit(Boolean.valueOf(value));
         }
 
         value = properties.getProperty(PROP_DEFAULTREADONLY);
         if (value != null) {
-            dataSource.getPoolProperties().setDefaultReadOnly(Boolean.valueOf(value));
+            poolProperties.setDefaultReadOnly(Boolean.valueOf(value));
         }
 
         value = properties.getProperty(PROP_DEFAULTTRANSACTIONISOLATION);
@@ -233,123 +226,122 @@
                     level = UNKNOWN_TRANSACTIONISOLATION;
                 }
             }
-            dataSource.getPoolProperties().setDefaultTransactionIsolation(level);
+            poolProperties.setDefaultTransactionIsolation(level);
         }
 
         value = properties.getProperty(PROP_DEFAULTCATALOG);
         if (value != null) {
-            dataSource.getPoolProperties().setDefaultCatalog(value);
+            poolProperties.setDefaultCatalog(value);
         }
 
         value = properties.getProperty(PROP_DRIVERCLASSNAME);
         if (value != null) {
-            dataSource.getPoolProperties().setDriverClassName(value);
+            poolProperties.setDriverClassName(value);
         }
 
         value = properties.getProperty(PROP_MAXACTIVE);
         if (value != null) {
-            dataSource.getPoolProperties().setMaxActive(Integer.parseInt(value));
+            poolProperties.setMaxActive(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_MAXIDLE);
         if (value != null) {
-            dataSource.getPoolProperties().setMaxIdle(Integer.parseInt(value));
+            poolProperties.setMaxIdle(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_MINIDLE);
         if (value != null) {
-            dataSource.getPoolProperties().setMinIdle(Integer.parseInt(value));
+            poolProperties.setMinIdle(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_INITIALSIZE);
         if (value != null) {
-            dataSource.getPoolProperties().setInitialSize(Integer.parseInt(value));
+            poolProperties.setInitialSize(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_MAXWAIT);
         if (value != null) {
-            dataSource.getPoolProperties().setMaxWait(Integer.parseInt(value));
+            poolProperties.setMaxWait(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_TESTONBORROW);
         if (value != null) {
-            dataSource.getPoolProperties().setTestOnBorrow(Boolean.valueOf(value).booleanValue());
+            poolProperties.setTestOnBorrow(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_TESTONRETURN);
         if (value != null) {
-            dataSource.getPoolProperties().setTestOnReturn(Boolean.valueOf(value).booleanValue());
+            poolProperties.setTestOnReturn(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_TESTONCONNECT);
         if (value != null) {
-            dataSource.getPoolProperties().setTestOnConnect(Boolean.valueOf(value).booleanValue());
+            poolProperties.setTestOnConnect(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_TIMEBETWEENEVICTIONRUNSMILLIS);
         if (value != null) {
-            dataSource.getPoolProperties().setTimeBetweenEvictionRunsMillis(Integer.parseInt(value));
+            poolProperties.setTimeBetweenEvictionRunsMillis(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_NUMTESTSPEREVICTIONRUN);
         if (value != null) {
-            dataSource.getPoolProperties().setNumTestsPerEvictionRun(Integer.parseInt(value));
+            poolProperties.setNumTestsPerEvictionRun(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_MINEVICTABLEIDLETIMEMILLIS);
         if (value != null) {
-            dataSource.getPoolProperties().setMinEvictableIdleTimeMillis(Integer.parseInt(value));
+            poolProperties.setMinEvictableIdleTimeMillis(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_TESTWHILEIDLE);
         if (value != null) {
-            dataSource.getPoolProperties().setTestWhileIdle(Boolean.valueOf(value).booleanValue());
+            poolProperties.setTestWhileIdle(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_PASSWORD);
         if (value != null) {
-            dataSource.getPoolProperties().setPassword(value);
+            poolProperties.setPassword(value);
         }
 
         value = properties.getProperty(PROP_URL);
         if (value != null) {
-            dataSource.getPoolProperties().setUrl(value);
+            poolProperties.setUrl(value);
         }
 
         value = properties.getProperty(PROP_USERNAME);
         if (value != null) {
-            dataSource.getPoolProperties().setUsername(value);
+            poolProperties.setUsername(value);
         }
 
         value = properties.getProperty(PROP_VALIDATIONQUERY);
         if (value != null) {
-            dataSource.getPoolProperties().setValidationQuery(value);
+            poolProperties.setValidationQuery(value);
         }
 
         value = properties.getProperty(PROP_VALIDATIONINTERVAL);
         if (value != null) {
-            dataSource.getPoolProperties().setValidationInterval(Long.parseLong(value));
+            poolProperties.setValidationInterval(Long.parseLong(value));
         }
 
         value = properties.getProperty(PROP_ACCESSTOUNDERLYINGCONNECTIONALLOWED);
         if (value != null) {
-            dataSource.getPoolProperties().
-                setAccessToUnderlyingConnectionAllowed(Boolean.valueOf(value).booleanValue());
+            poolProperties.setAccessToUnderlyingConnectionAllowed(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_REMOVEABANDONED);
         if (value != null) {
-            dataSource.getPoolProperties().setRemoveAbandoned(Boolean.valueOf(value).booleanValue());
+            poolProperties.setRemoveAbandoned(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_REMOVEABANDONEDTIMEOUT);
         if (value != null) {
-            dataSource.getPoolProperties().setRemoveAbandonedTimeout(Integer.parseInt(value));
+            poolProperties.setRemoveAbandonedTimeout(Integer.parseInt(value));
         }
 
         value = properties.getProperty(PROP_LOGABANDONED);
         if (value != null) {
-            dataSource.getPoolProperties().setLogAbandoned(Boolean.valueOf(value).booleanValue());
+            poolProperties.setLogAbandoned(Boolean.valueOf(value).booleanValue());
         }
 
         value = properties.getProperty(PROP_POOLPREPAREDSTATEMENTS);
@@ -365,38 +357,52 @@
         value = properties.getProperty(PROP_CONNECTIONPROPERTIES);
         if (value != null) {
             Properties p = getProperties(value);
-            dataSource.getPoolProperties().setDbProperties(p);
+            poolProperties.setDbProperties(p);
         } else {
-            dataSource.getPoolProperties().setDbProperties(new Properties());
+            poolProperties.setDbProperties(new Properties());
         }
 
-        dataSource.getPoolProperties().getDbProperties().setProperty("user",dataSource.getPoolProperties().getUsername());
-        dataSource.getPoolProperties().getDbProperties().setProperty("password",dataSource.getPoolProperties().getPassword());
+        poolProperties.getDbProperties().setProperty("user",poolProperties.getUsername());
+        poolProperties.getDbProperties().setProperty("password",poolProperties.getPassword());
 
         value = properties.getProperty(PROP_INITSQL);
         if (value != null) {
-            dataSource.getPoolProperties().setInitSQL(value);
+            poolProperties.setInitSQL(value);
         }
 
         value = properties.getProperty(PROP_INTERCEPTORS);
         if (value != null) {
-            dataSource.getPoolProperties().setJdbcInterceptors(value);
+            poolProperties.setJdbcInterceptors(value);
         }
 
         value = properties.getProperty(PROP_JMX_ENABLED);
         if (value != null) {
-            dataSource.getPoolProperties().setJmxEnabled(Boolean.parseBoolean(value));
+            poolProperties.setJmxEnabled(Boolean.parseBoolean(value));
         }
         
         value = properties.getProperty(PROP_FAIR_QUEUE);
         if (value != null) {
-            dataSource.getPoolProperties().setFairQueue(Boolean.parseBoolean(value));
+            poolProperties.setFairQueue(Boolean.parseBoolean(value));
         }
         
         value = properties.getProperty(PROP_USE_EQUALS);
         if (value != null) {
-            dataSource.getPoolProperties().setUseEquals(Boolean.parseBoolean(value));
+            poolProperties.setUseEquals(Boolean.parseBoolean(value));
         }
+        return poolProperties;
+        
+    }
+
+    /**
+     * Creates and configures a {@link BasicDataSource} instance based on the
+     * given properties.
+     *
+     * @param properties the datasource configuration properties
+     * @throws Exception if an error occurs creating the data source
+     */
+    public static DataSource createDataSource(Properties properties) throws Exception {
+        PoolProperties poolProperties = DataSourceFactory.parsePoolProperties(properties);
+        org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource(poolProperties);
         
         //initialize the pool itself
         dataSource.createPool();
@@ -418,11 +424,10 @@
      * @return Properties
      * @throws Exception
      */
-    static protected Properties getProperties(String propText) throws Exception {
+    static protected Properties getProperties(String propText) throws IOException {
         Properties p = new Properties();
         if (propText != null) {
-            p.load(new ByteArrayInputStream(propText.replace(';', '\n').
-                                            getBytes()));
+            p.load(new ByteArrayInputStream(propText.replace(';', '\n').getBytes()));
         }
         return p;
     }

Modified: tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceProxy.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceProxy.java?rev=757705&r1=757704&r2=757705&view=diff
==============================================================================
--- tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceProxy.java (original)
+++ tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/DataSourceProxy.java Tue
Mar 24 10:35:04 2009
@@ -44,10 +44,16 @@
     
     protected volatile ConnectionPool pool = null;
     
-    protected PoolProperties poolProperties = new PoolProperties();
+    protected PoolProperties poolProperties = null;
 
     public DataSourceProxy() {
+        this(new PoolProperties());
     }
+    
+    public DataSourceProxy(PoolProperties poolProperties) {
+        this.poolProperties = poolProperties;
+    }
+    
 
 
     public boolean isWrapperFor(Class<?> iface) throws SQLException {

Modified: tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/SlowQueryReportJmx.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/SlowQueryReportJmx.java?rev=757705&r1=757704&r2=757705&view=diff
==============================================================================
--- tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/SlowQueryReportJmx.java
(original)
+++ tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/SlowQueryReportJmx.java
Tue Mar 24 10:35:04 2009
@@ -226,7 +226,7 @@
                 if (mbean!=null && mbeans.putIfAbsent(poolName, mbean)==null) {
                     registry.getMBeanServer().registerMBean( mbean, oname);
                 } else if (mbean==null){
-                    log.warn(SlowQueryReport.class.getName()+ "- No JMX support, unable to
initiate Tomcat JMX.");
+                    log.warn(SlowQueryReport.class.getName()+ "- No JMX support, unable to
initiate Tomcat JMX. This requires the system to run inside the Tomcat container.");
                 }
             } else {
                 log.warn(SlowQueryReport.class.getName()+ "- No JMX support, composite type
was not found.");



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message