JFox Service-Oriented Application Framework

Clover coverage report - JFox Service-Oriented Application Framework - 1.0-M2

Coverage timestamp: 星期四十一月 25 2004 17:14:11 PST

FRAMES NO FRAMES

file stats:	LOC:	213		Methods:	5
	NCLOC:	117		Classes:	1

30 day Evaluation Version distributed via the Maven Jar Repository. Clover is not free. You have 30 days to evaluate it. Please visit http://www.thecortex.net/clover to obtain a licensed version of Clover

Source file

Conditionals

Statements

Methods

TOTAL

C3P0DataSourceFactory.java

43.3%

62.3%

80%

57.3%

 /** 
  * JFoxSOAF, Service-Oriented Application Framework
  * 
  * Copyright (C) www.huihoo.org
  *
  * Distributable under GNU LGPL
  * 
  * For more information, please visit: http://www.huihoo.org/jfox/jfoxsoaf
  */
 
 package org.huihoo.jfox.soaf.services.jdbc;
 
 import java.util.Enumeration;
 import java.util.Hashtable;
 import java.util.Vector;
 
 import javax.sql.DataSource;
 
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.math.NumberUtils;
 import org.apache.commons.lang.BooleanUtils;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.huihoo.jfox.soaf.exception.DataSourceConfigurationException;
 
 import com.mchange.v2.c3p0.DataSources;
 import com.mchange.v2.c3p0.PoolConfig;
 
 /**
  * <p>
  * C3P0 DataSource Factory
  * </p>
  * 
  * @author <a href="mailto:founder_chen@yahoo.com.cn">Peter Cheng </a>
  * @version $Revision: 1.1 $ $Date: 2004/10/28 15:12:15 $
  * @version Revision: 1.0
  */
 
 public class C3P0DataSourceFactory extends DataSourceFactory {
 
     private final Log logger = LogFactory.getLog(getClass());
 
     private DataSource dataSource;
 
     //  The configuration attributes for this {@link DataSourceFactory}.
     private Hashtable attributes = new Hashtable();
 
     /**
      * @see org.huihoo.jfox.soaf.services.jdbc.DataSourceFactory#getInstance()
      */
     public DataSource getInstance() throws DataSourceConfigurationException {
         String jdbcDriverClass = (String) getAttribute(DatabaseConstant.JDBC_DRIVER_CLASS_NAME);
         if (StringUtils.isEmpty(jdbcDriverClass)) {
             logger.warn("No JDBC Driver class was specified by database.properties : "
                             + DatabaseConstant.JDBC_DRIVER_CLASS_NAME);
         } else {
             try {
                 Class.forName(jdbcDriverClass);
             } catch (ClassNotFoundException e) {
                 String errorMsg = "JDBC Driver class not found: "
                         + jdbcDriverClass;
                 logger.fatal(errorMsg);
                 throw new DataSourceConfigurationException(errorMsg, e);
             }
         }
 
         // Set pool configuration
         PoolConfig poolConfig = new PoolConfig();
         String initPoolSize = (String) getAttribute(DatabaseConstant.JDBC_INIT_POOL_SIZE);
 
         if (!NumberUtils.isNumber(initPoolSize)) {
             poolConfig.setInitialPoolSize(NumberUtils.stringToInt(initPoolSize));
         }
 
         String minPoolSize = (String) getAttribute(DatabaseConstant.JDBC_MIN_POOL_SIZE);
 
         if (!NumberUtils.isNumber(minPoolSize)) {
             poolConfig.setMinPoolSize(NumberUtils.stringToInt(minPoolSize));
         }
 
         String maxPoolSize = (String) getAttribute(DatabaseConstant.JDBC_MAX_POOL_SIZE);
 
         if (!!NumberUtils.isNumber(maxPoolSize)) {
             poolConfig.setMaxPoolSize(NumberUtils.stringToInt(maxPoolSize));
         }
 
         String maxIdleTime = (String) getAttribute(DatabaseConstant.JDBC_MAX_IDLE_TIME);
 
         if (!NumberUtils.isNumber(maxIdleTime)) {            
             poolConfig.setMaxIdleTime(NumberUtils.stringToInt(maxIdleTime));
         }
 
         String idleConnTestPeriod = (String) getAttribute(DatabaseConstant.C3P0_JDBC_IDLE_CONN_TEST_PERIOD);
 
         if (!NumberUtils.isNumber(maxIdleTime)) {
             poolConfig.setIdleConnectionTestPeriod(NumberUtils
                     .stringToInt(idleConnTestPeriod));
         }
 
         String maxStatements = (String) getAttribute(DatabaseConstant.C3P0_JDBC_MAX_STATEMENTS);
 
         if (!NumberUtils.isNumber(maxStatements)) {
             poolConfig.setMaxStatements(NumberUtils.stringToInt(maxStatements));
         }
 
         String propertyCycle = (String) getAttribute(DatabaseConstant.C3P0_JDBC_PROPERTY_CYCLE);
 
         if (!NumberUtils.isNumber(propertyCycle)) {
             poolConfig.setPropertyCycle(NumberUtils.stringToInt(propertyCycle));
         }
 
         String acquireIncrement = (String) getAttribute(DatabaseConstant.C3P0_JDBC_ACQUIRE_INCREMENT);
 
         if (!NumberUtils.isNumber(acquireIncrement)) {
             poolConfig.setAcquireIncrement(NumberUtils
                     .stringToInt(acquireIncrement));
         }
 
         // c3p0 version is below 0.8.5 , does't support acquireRetryAttempts,
         // acquireRetryDelay, breakAfterAcquireFailure,
         // usesTraditionalReflectiveProxies
 
         String forceIgnoreUnresolvedTransactions = (String) getAttribute(DatabaseConstant.C3P0_JDBC_FORCE_IGNORE_UNRESOLVED_TRANS);
 
         if (!StringUtils.isEmpty(forceIgnoreUnresolvedTransactions)) {
             poolConfig.setForceIgnoreUnresolvedTransactions(BooleanUtils
                     .toBoolean(forceIgnoreUnresolvedTransactions));
         }
 
         String numHelperThreads = (String) getAttribute(DatabaseConstant.C3P0_JDBC_NUM_HELPER_THREADS);
 
         if (!NumberUtils.isNumber(numHelperThreads)) {
             poolConfig.setNumHelperThreads(NumberUtils
                     .stringToInt(numHelperThreads));
         }
 
         String jdbcURL = (String) getAttribute(DatabaseConstant.JDBC_URL);
         if (StringUtils.isEmpty(jdbcURL)) {
             logger.error("No JDBC url was specified by database.properties");
             throw new DataSourceConfigurationException(
                     "No JDBC url was specified");
         } else {
             String jdbcUsername = (String) getAttribute(DatabaseConstant.JDBC_USERNAME);
             String jdbcPassword = (String) getAttribute(DatabaseConstant.JDBC_PASSWORD);
 
             DataSource unpooledDataSource = DataSources.unpooledDataSource(
                     jdbcURL, jdbcUsername, jdbcPassword);
             dataSource = DataSources.pooledDataSource(unpooledDataSource,
                     poolConfig);
         }
         return dataSource;
     }
 
     /**
      * Return the configuration attribute with the specified name (if any), or
      * <code>null</code> if there is no such attribute.
      * 
      * @param name
      *            Name of the attribute to return
      */
     public Object getAttribute(String name) {
         return (attributes.get(name));
     }
 
     /**
      * Return an array containing the names of all currently defined
      * configuration attributes. If there are no such attributes, a zero length
      * array is returned.
      */
     public String[] getAttributeNames() {
         Vector names = new Vector();
         Enumeration keys = attributes.keys();
         while (keys.hasMoreElements()) {
             names.addElement((String) keys.nextElement());
         }
         String results[] = new String[names.size()];
         for (int i = 0; i < results.length; i++) {
             results[i] = (String) names.elementAt(i);
         }
         return (results);
     }
 
     /**
      * Set the configuration attribute with the specified name. Calling this
      * with a <code>null</code> value is equivalent to calling
      * <code>removeAttribute(name)</code>.
      * 
      * @param name
      *            Name of the attribute to set
      * @param value
      *            Value of the attribute to set, or <code>null</code> to
      *            remove any setting for this attribute
      */
     public void setAttribute(String name, Object value) {
         if (value == null) {
             attributes.remove(name);
         } else {
             attributes.put(name, value);
         }
     }
 
     /**
      * Remove any configuration attribute associated with the specified name. If
      * there is no such attribute, no action is taken.
      * 
      * @param name
      *            Name of the attribute to remove
      */
     public void removeAttribute(String name) {
         attributes.remove(name);
     }
 
 }

1		/**
2		* JFoxSOAF, Service-Oriented Application Framework
3		*
4		* Copyright (C) www.huihoo.org
5		*
6		* Distributable under GNU LGPL
7		*
8		* For more information, please visit: http://www.huihoo.org/jfox/jfoxsoaf
9		*/
10
11		package org.huihoo.jfox.soaf.services.jdbc;
12
13		import java.util.Enumeration;
14		import java.util.Hashtable;
15		import java.util.Vector;
16
17		import javax.sql.DataSource;
18
19		import org.apache.commons.lang.StringUtils;
20		import org.apache.commons.lang.math.NumberUtils;
21		import org.apache.commons.lang.BooleanUtils;
22		import org.apache.commons.logging.Log;
23		import org.apache.commons.logging.LogFactory;
24		import org.huihoo.jfox.soaf.exception.DataSourceConfigurationException;
25
26		import com.mchange.v2.c3p0.DataSources;
27		import com.mchange.v2.c3p0.PoolConfig;
28
29		/**
30		* <p>
31		* C3P0 DataSource Factory
32		* </p>
33		*
34		* @author <a href="mailto:founder_chen@yahoo.com.cn">Peter Cheng </a>
35		* @version $Revision: 1.1 $ $Date: 2004/10/28 15:12:15 $
36		* @version Revision: 1.0
37		*/
38
39		public class C3P0DataSourceFactory extends DataSourceFactory {
40
41		private final Log logger = LogFactory.getLog(getClass());
42
43		private DataSource dataSource;
44
45		// The configuration attributes for this {@link DataSourceFactory}.
46		private Hashtable attributes = new Hashtable();
47
48		/**
49		* @see org.huihoo.jfox.soaf.services.jdbc.DataSourceFactory#getInstance()
50		*/
51	4	public DataSource getInstance() throws DataSourceConfigurationException {
52	4	String jdbcDriverClass = (String) getAttribute(DatabaseConstant.JDBC_DRIVER_CLASS_NAME);
53	4	if (StringUtils.isEmpty(jdbcDriverClass)) {
54	0	logger.warn("No JDBC Driver class was specified by database.properties : "
55		+ DatabaseConstant.JDBC_DRIVER_CLASS_NAME);
56		} else {
57	4	try {
58	4	Class.forName(jdbcDriverClass);
59		} catch (ClassNotFoundException e) {
60	0	String errorMsg = "JDBC Driver class not found: "
61		+ jdbcDriverClass;
62	0	logger.fatal(errorMsg);
63	0	throw new DataSourceConfigurationException(errorMsg, e);
64		}
65		}
66
67		// Set pool configuration
68	4	PoolConfig poolConfig = new PoolConfig();
69	4	String initPoolSize = (String) getAttribute(DatabaseConstant.JDBC_INIT_POOL_SIZE);
70
71	4	if (!NumberUtils.isNumber(initPoolSize)) {
72	0	poolConfig.setInitialPoolSize(NumberUtils.stringToInt(initPoolSize));
73		}
74
75	4	String minPoolSize = (String) getAttribute(DatabaseConstant.JDBC_MIN_POOL_SIZE);
76
77	4	if (!NumberUtils.isNumber(minPoolSize)) {
78	0	poolConfig.setMinPoolSize(NumberUtils.stringToInt(minPoolSize));
79		}
80
81	4	String maxPoolSize = (String) getAttribute(DatabaseConstant.JDBC_MAX_POOL_SIZE);
82
83	4	if (!!NumberUtils.isNumber(maxPoolSize)) {
84	4	poolConfig.setMaxPoolSize(NumberUtils.stringToInt(maxPoolSize));
85		}
86
87	4	String maxIdleTime = (String) getAttribute(DatabaseConstant.JDBC_MAX_IDLE_TIME);
88
89	4	if (!NumberUtils.isNumber(maxIdleTime)) {
90	0	poolConfig.setMaxIdleTime(NumberUtils.stringToInt(maxIdleTime));
91		}
92
93	4	String idleConnTestPeriod = (String) getAttribute(DatabaseConstant.C3P0_JDBC_IDLE_CONN_TEST_PERIOD);
94
95	4	if (!NumberUtils.isNumber(maxIdleTime)) {
96	0	poolConfig.setIdleConnectionTestPeriod(NumberUtils
97		.stringToInt(idleConnTestPeriod));
98		}
99
100	4	String maxStatements = (String) getAttribute(DatabaseConstant.C3P0_JDBC_MAX_STATEMENTS);
101
102	4	if (!NumberUtils.isNumber(maxStatements)) {
103	0	poolConfig.setMaxStatements(NumberUtils.stringToInt(maxStatements));
104		}
105
106	4	String propertyCycle = (String) getAttribute(DatabaseConstant.C3P0_JDBC_PROPERTY_CYCLE);
107
108	4	if (!NumberUtils.isNumber(propertyCycle)) {
109	0	poolConfig.setPropertyCycle(NumberUtils.stringToInt(propertyCycle));
110		}
111
112	4	String acquireIncrement = (String) getAttribute(DatabaseConstant.C3P0_JDBC_ACQUIRE_INCREMENT);
113
114	4	if (!NumberUtils.isNumber(acquireIncrement)) {
115	0	poolConfig.setAcquireIncrement(NumberUtils
116		.stringToInt(acquireIncrement));
117		}
118
119		// c3p0 version is below 0.8.5 , does't support acquireRetryAttempts,
120		// acquireRetryDelay, breakAfterAcquireFailure,
121		// usesTraditionalReflectiveProxies
122
123	4	String forceIgnoreUnresolvedTransactions = (String) getAttribute(DatabaseConstant.C3P0_JDBC_FORCE_IGNORE_UNRESOLVED_TRANS);
124
125	4	if (!StringUtils.isEmpty(forceIgnoreUnresolvedTransactions)) {
126	4	poolConfig.setForceIgnoreUnresolvedTransactions(BooleanUtils
127		.toBoolean(forceIgnoreUnresolvedTransactions));
128		}
129
130	4	String numHelperThreads = (String) getAttribute(DatabaseConstant.C3P0_JDBC_NUM_HELPER_THREADS);
131
132	4	if (!NumberUtils.isNumber(numHelperThreads)) {
133	0	poolConfig.setNumHelperThreads(NumberUtils
134		.stringToInt(numHelperThreads));
135		}
136
137	4	String jdbcURL = (String) getAttribute(DatabaseConstant.JDBC_URL);
138	4	if (StringUtils.isEmpty(jdbcURL)) {
139	0	logger.error("No JDBC url was specified by database.properties");
140	0	throw new DataSourceConfigurationException(
141		"No JDBC url was specified");
142		} else {
143	4	String jdbcUsername = (String) getAttribute(DatabaseConstant.JDBC_USERNAME);
144	4	String jdbcPassword = (String) getAttribute(DatabaseConstant.JDBC_PASSWORD);
145
146	4	DataSource unpooledDataSource = DataSources.unpooledDataSource(
147		jdbcURL, jdbcUsername, jdbcPassword);
148	4	dataSource = DataSources.pooledDataSource(unpooledDataSource,
149		poolConfig);
150		}
151	4	return dataSource;
152		}
153
154		/**
155		* Return the configuration attribute with the specified name (if any), or
156		* <code>null</code> if there is no such attribute.
157		*
158		* @param name
159		* Name of the attribute to return
160		*/
161	59	public Object getAttribute(String name) {
162	59	return (attributes.get(name));
163		}
164
165		/**
166		* Return an array containing the names of all currently defined
167		* configuration attributes. If there are no such attributes, a zero length
168		* array is returned.
169		*/
170	0	public String[] getAttributeNames() {
171	0	Vector names = new Vector();
172	0	Enumeration keys = attributes.keys();
173	0	while (keys.hasMoreElements()) {
174	0	names.addElement((String) keys.nextElement());
175		}
176	0	String results[] = new String[names.size()];
177	0	for (int i = 0; i < results.length; i++) {
178	0	results[i] = (String) names.elementAt(i);
179		}
180	0	return (results);
181		}
182
183		/**
184		* Set the configuration attribute with the specified name. Calling this
185		* with a <code>null</code> value is equivalent to calling
186		* <code>removeAttribute(name)</code>.
187		*
188		* @param name
189		* Name of the attribute to set
190		* @param value
191		* Value of the attribute to set, or <code>null</code> to
192		* remove any setting for this attribute
193		*/
194	62	public void setAttribute(String name, Object value) {
195	62	if (value == null) {
196	0	attributes.remove(name);
197		} else {
198	62	attributes.put(name, value);
199		}
200		}
201
202		/**
203		* Remove any configuration attribute associated with the specified name. If
204		* there is no such attribute, no action is taken.
205		*
206		* @param name
207		* Name of the attribute to remove
208		*/
209	1	public void removeAttribute(String name) {
210	1	attributes.remove(name);
211		}
212
213		}