001: /* ====================================================================
002: * The QueryForm License, Version 1.1
003: *
004: * Copyright (c) 1998 - 2003 David F. Glasser. All rights
005: * reserved.
006: *
007: * Redistribution and use in source and binary forms, with or without
008: * modification, are permitted provided that the following conditions
009: * are met:
010: *
011: * 1. Redistributions of source code must retain the above copyright
012: * notice, this list of conditions and the following disclaimer.
013: *
014: * 2. Redistributions in binary form must reproduce the above copyright
015: * notice, this list of conditions and the following disclaimer in
016: * the documentation and/or other materials provided with the
017: * distribution.
018: *
019: * 3. The end-user documentation included with the redistribution,
020: * if any, must include the following acknowledgment:
021: * "This product includes software developed by
022: * David F. Glasser."
023: * Alternately, this acknowledgment may appear in the software itself,
024: * if and wherever such third-party acknowledgments normally appear.
025: *
026: * 4. The names "QueryForm" and "David F. Glasser" must
027: * not be used to endorse or promote products derived from this
028: * software without prior written permission. For written
029: * permission, please contact dglasser@pobox.com.
030: *
031: * 5. Products derived from this software may not be called "QueryForm",
032: * nor may "QueryForm" appear in their name, without prior written
033: * permission of David F. Glasser.
034: *
035: * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
036: * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
037: * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
038: * DISCLAIMED. IN NO EVENT SHALL DAVID F. GLASSER, THE APACHE SOFTWARE
039: * FOUNDATION OR ITS CONTRIBUTORS, OR ANY AUTHORS OR DISTRIBUTORS
040: * OF THIS SOFTWARE BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
041: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
042: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
043: * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
044: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
045: * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
046: * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
047: * SUCH DAMAGE.
048: * ====================================================================
049: *
050: * This product includes software developed by the
051: * Apache Software Foundation (http://www.apache.org/).
052: *
053: * ====================================================================
054: *
055: * $Source: /cvsroot/qform/qform/src/org/glasser/sql/DataSourceManager.java,v $
056: * $Revision: 1.4 $
057: * $Author: dglasser $
058: * $Date: 2003/04/26 13:19:06 $
059: *
060: * --------------------------------------------------------------------
061: */
062: package org.glasser.sql;
063:
064: import java.sql.*;
065: import javax.sql.*;
066: import java.util.*;
067: import org.apache.commons.dbcp.DriverManagerConnectionFactory;
068: import org.apache.commons.dbcp.*;
069: import org.apache.commons.dbcp.PoolableConnectionFactory;
070: import org.apache.commons.dbcp.PoolingDataSource;
071: import org.apache.commons.pool.impl.GenericObjectPool;
072:
073: import org.glasser.sql.LocalDataSourceConfig;
074: import org.glasser.util.ExtensionClassLoader;
075:
076: public class DataSourceManager {
077:
078: public static DataSource getLocalDataSource(
079: LocalDataSourceConfig config, String userName,
080: String password) throws ClassNotFoundException, Exception {
081:
082: Driver driver = null;
083: Class driverClass = ExtensionClassLoader.getSingleton()
084: .loadClass(config.getDriverClassName());
085: driver = (Driver) driverClass.newInstance();
086:
087: if (userName == null)
088: userName = config.getUser();
089: if (password == null)
090: password = config.getPassword();
091:
092: int maxConnections = 1000;
093: Integer n = config.getMaxConnections();
094: if (n != null)
095: maxConnections = n.intValue();
096:
097: Properties props = new Properties();
098: if (userName != null) {
099: props.setProperty("user", userName);
100: }
101: if (password != null) {
102: props.setProperty("password", password);
103: }
104:
105: if (driver.acceptsURL(config.getUrl()) == false) {
106: throw new RuntimeException("The URL \"" + config.getUrl()
107: + "\" is invalid for the JDBC driver class "
108: + driverClass.getName() + ".");
109: }
110:
111: DriverConnectionFactory connFactory = new DriverConnectionFactory(
112: driver, config.getUrl(), props);
113:
114: GenericObjectPool genericPool = new GenericObjectPool(null,
115: maxConnections);
116: genericPool
117: .setWhenExhaustedAction(genericPool.WHEN_EXHAUSTED_FAIL);
118: // genericPool.setMaxWait(1);
119: PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(
120: connFactory, genericPool, null, null, false, true);
121: PoolingDataSource dataSource = new PoolingDataSource(
122: genericPool);
123: return dataSource;
124: }
125:
126: }
|