~maria-captains/mariadb-java-client/trunk

package org.mariadb.jdbc;

 

import java.sql.Connection;

import java.sql.SQLException;

import java.util.Properties;

 

import org.junit.Test;

 

public class ConnectionPoolTest extends BaseTest {

    

    /* For this test case to compile the following must be added to the pom.xml:

       <dependency>

         <groupId>commons-dbcp</groupId>

         <artifactId>commons-dbcp</artifactId>

         <version>1.4</version>

      </dependency>

     */

    @Test

    public void testConnectionWithApacheDBCP() throws SQLException {

        org.apache.commons.dbcp.BasicDataSource dataSource;

        dataSource = new org.apache.commons.dbcp.BasicDataSource();

        dataSource.setUrl(connU);

        dataSource.setUsername(mUsername);

        dataSource.setPassword(mPassword);

        dataSource.setMaxActive(2);

        

        Connection connection = dataSource.getConnection();

        

        connection.close();

        dataSource.close();

    }

    

    /**

     * This test case simulates how the Apache DBCP connection pools works. It is written so it

     * should compile without Apache DBCP but still show the problem.

     */

    @Test

    public void testConnectionWithSimululatedApacheDBCP() throws SQLException {

        

        java.sql.Driver driver = new org.mariadb.jdbc.Driver();

 

        Properties props = new Properties();

        props.put("user", mUsername);

        props.put("password", mPassword);

        

        //A connection pool typically has a connection factor that stored everything needed to

        //create a Connection. Here I create a factory that stores URL, username and password.

        SimulatedDriverConnectionFactory factory = new SimulatedDriverConnectionFactory(driver,

            connU, props);

        

        //Create 1 first connection (This is typically done in the Connection validation step in a

        //connection pool)

        Connection connection1 = factory.createConnection();

        

        //Create another connection to make sure we can access the database. This is typically the

        //Connection that is exposed to the user of the connection pool

        Connection connection2 = factory.createConnection();

        

        connection1.close();

        connection2.close();

    }

    

    /** This class is a simulated version of org.apache.commons.dbcp.DriverConnectionFactory */

    private static class SimulatedDriverConnectionFactory {

        public SimulatedDriverConnectionFactory(java.sql.Driver driver, String connectUri, Properties props) {

            _driver = driver;

            _connectUri = connectUri;

            _props = props;

        }

 

        public Connection createConnection() throws SQLException {

            return _driver.connect(_connectUri,_props);

        }

 

        protected java.sql.Driver _driver = null;

        protected String _connectUri = null;

        protected Properties _props = null;

    }

}