Header javaperspective.com
JavaPerspective.com  >   Advanced Tutorials  >   2. JDBC - database access  >   2.6. Connection pooling

2.6. Connection pooling
Last updated: 1 January 2013.

This tutorial discusses connection pooling with JDBC.

As you might already know, a typical database access involves 3 steps:
  1. Establish a connection with the database by calling one of the methods getConnection provided by the class java.sql.DriverManager.
  2. Use the created connection to execute one or more SQL statements.
  3. Close the connection by calling the method close provided by the class java.sql.DriverManager.
The problem with this approach is that establishing a connection with a database is costly. Consequently, if an application establishes a new connection with a database every time it needs to issue an SQL statement, performance is degraded.

A connection pool uses JDBC to create a limited number of connections with the database. Whenever your application needs a connection, it borrows it from the connection pool. Later on, instead of closing the connection, the application gives it back to the connection pool. That connection can then be reused later since it has not been closed.

Connection pools are supplied as simple JAR files that you include in your classpath. There is a number of open source connection pools you can download for free. Some of the most commonly used are Commons DBCP, BoneCP, C3P0 and Proxool.

As an example, the following section will show you how to use Proxool. I have tried several connection pools but what I found interesting about Proxool is that you can easily keep track of the events that occur on each connection. In particular, Proxool gives you the execution time of each SQL statement in milliseconds, allowing you to pinpoint the time-consuming statements in your application.

How to use Proxool

Download Proxool, unzip the downloaded file and include in your classpath the JAR files contained in the /lib directory. The example shown in this section provides two classes: ConnectionPool and ConnectionListener:The class ConnectionPool assumes that you are using a locally installed Oracle database. If you are using another database, all you have to do is modify driverClass and driverUrl accordingly. Here is the code:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

import org.logicalcobwebs.proxool.ProxoolFacade;

public final class ConnectionPool {

public ConnectionPool() throws Exception {
// Set up the URL
String alias = "demo"; // The alias uniquely identifies the pool
String driverClass = "oracle.jdbc.driver.OracleDriver";
          String driverUrl =
          String url =
"proxool." + alias + ":" + driverClass + ":" + driverUrl;

// Set up the Properties object
Properties info = new Properties();
("proxool.maximum-connection-count", "30");
("user", "yourName");
("password", "yourPassword");

// Initialize the pool, borrow a connection and return it to the pool by calling "close"
          // If something goes wrong, an exception is thrown
          Connection connection = DriverManager.getConnection
(url, info);

// Add a connection listener to the pool
ProxoolFacade.addConnectionListener(alias, new ConnectionListener());

public Connection getConnection() throws SQLException {
// Use the alias "demo" defined in the constructor to borrow a connection
return DriverManager.getConnection("proxool.demo");


The class ConnectionListener shown below implements the interface ConnectionListenerIF. Its purpose is to listen to the events that occur on each connection. Since I am only interested in the execution time of each SQL statement, I have implemented a single method: onExecute.

import java.sql.Connection;
import java.sql.SQLException;
import org.logicalcobwebs.proxool.ConnectionListenerIF;

public final class ConnectionListener implements ConnectionListenerIF {

public void onBirth(Connection arg0) throws SQLException {


public void onDeath(Connection arg0, int arg1) throws SQLException {


public void onExecute(String command, long elapsedTime) {
System.out.println("command = " + command);
("elapsedTime = " + elapsedTime);

public void onFail(String arg0, Exception arg1) {



The following sample creates an instance of the class ConnectionPool and borrows a connection from the pool to issue an SQL statement:

Connection connection = null;
PreparedStatement statement =

try {
// Create an instance of the class ConnectionPool and use it to issue an SQL statement
ConnectionPool connectionPool = new ConnectionPool();

    connection = connectionPool.getConnection

    statement = connection.prepareStatement

(1, "Africa");
(2, 3000);

    ResultSet resultSet = statement.executeQuery

// do something with the selected rows
if(statement != null)
if(connection != null)

If you run the above sample, you will get an output like this:

elapsedTime = 33

You are here :  JavaPerspective.com  >   Advanced Tutorials  >   2. JDBC - database access  >   2.6. Connection pooling
Next tutorial :  JavaPerspective.com  >   Advanced Tutorials  >   2. JDBC - database access  >   2.7. Transactions

Copyright © 2013. JavaPerspective.com. All rights reserved.  ( Terms | Contact | About ) 
Java is a trademark of Oracle Corporation
Image 1 Image 2 Image 3 Image 4 Image 5 Image 6 Image 7