/* ====================================================================== The Bodington System Software License, Version 1.0 Copyright (c) 2001 The University of Leeds. All rights reserved. Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met: 1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer. 2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution. 3. The end-user documentation included with the redistribution, if any, must include the following acknowledgement: "This product includes software developed by the University of Leeds (http://www.bodington.org/)." Alternately, this acknowledgement may appear in the software itself, if and wherever such third-party acknowledgements normally appear. 4. The names "Bodington", "Nathan Bodington", "Bodington System", "Bodington Open Source Project", and "The University of Leeds" must not be used to endorse or promote products derived from this software without prior written permission. For written permission, please contact d.gardner@leeds.ac.uk. 5. The name "Bodington" may not appear in the name of products derived from this software without prior written permission of the University of Leeds. THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, TITLE, THE IMPLIED WARRANTIES OF QUALITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE UNIVERSITY OF LEEDS OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. ========================================================= This software was originally created by the University of Leeds and may contain voluntary contributions from others. For more information on the Bodington Open Source Project, please see http://bodington.org/ ====================================================================== */ package org.bodington.database; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; import org.apache.log4j.Logger; import org.bodington.pool.LimitedObjectPool; import org.bodington.pool.ObjectPoolException; /** * This is a wrapper around the old Bodington connection pooling. * You should probably use the {@link CommonsConnectionPool} instead. * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
PropertyDescriptionDefaultRequired
sqldatabase.urlThe JDBC URL to attempt to connect to.Yes
sqldatabase.driverThe class to use for the database driver.Yes
sqldatabase.user_nameThe username to connect to the database with.No
sqldatabase.passwordThe password to connect to the database with.No
sqldatabase.poolsizeThe size of the database connection pool.10No
sqldatabase.poolusermaxThe maximum number of connections a user can hold at once.2No
sqldatabase.poolusergreedymaxThe maximum number of outstanding requests for connections a user can hold.10No
* @author buckett */ public class BodingtonConnectionPool extends LimitedObjectPool implements ConnectionPool { private static Logger log = Logger.getLogger(BodingtonConnectionPool.class); private String url; private String user_name; private String password; /** * Create a new Bodington connection pool, getting the values from the * bodington properties. * @param properties The properties object containing the configuration information. */ public BodingtonConnectionPool (Properties properties) throws ConnectionPoolException { this.url = properties.getProperty( "sqldatabase.url" ); this.user_name = properties.getProperty( "sqldatabase.user_name" ); this.password = properties.getProperty( "sqldatabase.password" ); String jdbc_driver = properties.getProperty( "sqldatabase.driver" ); int pool_size = 10; int pool_user_max = 2; int pool_user_greedy_max = 10; try { pool_size = Integer.parseInt( properties.getProperty( "sqldatabase.poolsize", "10" ) ); } catch ( NumberFormatException nfex ){} try { pool_user_max = Integer.parseInt( properties.getProperty( "sqldatabase.poolusermax", "2" ) ); } catch ( NumberFormatException nfex ){} try { pool_user_greedy_max = Integer.parseInt( properties.getProperty( "sqldatabase.poolusergreedymax", "10" ) ); } catch ( NumberFormatException nfex ){} if (jdbc_driver == null || url == null) throw new ConnectionPoolException ("JDBC Driver and URL cannot be empty"); //make sure database driver registers itself try { Class.forName( jdbc_driver ); } catch (ClassNotFoundException cnfe) { throw new ConnectionPoolException("Could not find database driver: "+ jdbc_driver); } try { init( pool_size, pool_user_max, 30000, pool_user_greedy_max, 30000); } catch ( ObjectPoolException ope ) { throw new ConnectionPoolException("Failed to setup pool", ope); } } protected Object createObject() throws Exception { return DriverManager.getConnection( url, user_name, password ); } protected Object initialiseObject( Object o ) throws Exception { Connection connection = (Connection)o; Statement statement = null; ResultSet results = null; try { connection.setAutoCommit( true ); // force exception on connections that are dead statement = connection.createStatement(); results = statement.executeQuery( "SELECT * FROM objects WHERE id = 0" ); results.close(); //didn't throw exception so it's OK to use this connection. return connection; } catch ( SQLException ex ) { log.fatal("ConnectionPool.initialiseObject() SQLException trying to init connection - got rid of it.", ex ); } finally { try { if ( results != null ) results.close(); if ( statement != null ) statement.close(); } catch ( SQLException sqlex ) { } } // erase this dead connection try { if ( !connection.isClosed() ) connection.close(); } catch ( SQLException sqlex ) { } // and make a fresh one connection = DriverManager.getConnection( url, user_name, password ); connection.setAutoCommit( true ); return connection; } protected void poolObject( Object o ) throws Exception { } public Connection getConnection( Object user ) throws ConnectionPoolException { Connection connection; if (log.isDebugEnabled()) { log.debug("Getting connection for: "+ user); } try { connection = (Connection)getObject( user ); if (connection == null) throw new ConnectionPoolException( "Unable to get connection" ); return connection; } catch (ObjectPoolException ope) { throw new ConnectionPoolException( ope.getMessage()); } } public void freeConnection( Connection free_con ) throws ConnectionPoolException { if (log.isDebugEnabled()) { log.debug("Freeing connection: "+ free_con); } try { freeObject( free_con ); } catch (ObjectPoolException ope) { throw new ConnectionPoolException (ope.getMessage()); } } }