Description:
When calling pooledConnection.getConnection() after a logical Connection has been retrieved from the same PooledConnection and not yet closed, the previous Connection is automatically closed, as stated by the JDBC 2.0 specification.
But in that case, the MySQL implementation will generate a closeEvent when the JDBC specification says it must not.
The MySQL implementation of PooledConnection also generates a closeEvent when calling pooledConnection.close().
While the JDBC specification is not clear about this, I think It shouldn't generate a closeEvent in that case because the PooledConnection won't be returned to the pool.
How to repeat:
I have created a JUnit test case:
/* PooledConnectionTest.java
* Created on 16 juillet 2003, 11:56 */
import java.sql.*;
import javax.sql.ConnectionPoolDataSource;
import javax.sql.ConnectionEventListener;
import javax.sql.ConnectionEvent;
import javax.sql.PooledConnection;
import junit.framework.*;
import junit.textui.TestRunner;
import com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource;
/** Tests a PooledConnection implementation provided by a JDBC driver.
*
* According to the JDBC 2.0 specification:
*
* <p>"Each call to PooledConnection.getConnection() must return a newly
* constructed Connection object that exhibits the default Connection behavior.
* Only the most recent Connection object produced from a particular
* PooledConnection is open. An existing Connection object is automatically
* closed, if the getConnection() method of its associated Pooled-Connection is
* called again, before it has been explicitly closed by the application. This
* gives the application server a way to ‘take away’ a Connection from the
* application if it wishes, and give it out to someone else. This capability
* will not likely be used frequently in practice."</p>
*
* <p>"When the application calls Connection.close(), an event is triggered
* that tells the connection pool it can recycle the physical database
* connection. In other words, the event signals the connection pool that the
* PooledConnection object which originally produced the Connection object
* generating the event can be put back in the connection pool."</p>
*
* <p>"A Connection-EventListener will also be notified when a fatal error occurs,
* so that it can make a note not to put a bad PooledConnection object back in
* the cache when the application finishes using it. When an error occurs, the
* ConnectionEventListener is notified by the JDBC driver, just before the
* driver throws an SQLException to the application to notify it of the same
* error. Note that automatic closing of a Connection object as discussed
* in the previous section does not generate a connection close event."</p>
*
* The JDBC 3.0 specification states the same in other words:
*
* <p> "The Connection.close method closes the logical handle, but the physical
* connection is maintained. The connection pool manager is notified that the
* underlying PooledConnection object is now available for reuse. If the
* application attempts to reuse the logical handle, the Connection
* implementation throws an SQLException."</p>
*
* <p>"For a given PooledConnection object, only the most recently produced
* logical Connection object will be valid.
* Any previously existing Connection object is automatically closed when the
* associated PooledConnection.getConnection method is called. Listeners
* (connection pool managers) are not notified in this case.
* This gives the application server a way to take a connection away from
* a client.
* This is an unlikely scenario but may be useful if the application server is
* trying to force an orderly shutdown."</p>
*
* <p>"A connection pool manager shuts down a physical connection by calling the
* method PooledConnection.close. This method is typically called only in
* certain circumstances: when the application server is undergoing an orderly
* shutdown, when the connection cache is being reinitialized, or when the
* application server receives an event indicating that an unrecoverable error
* has occurred on the connection."</p>
*
* Even though the specification isn't clear about it, I think it is no use
* generating a close event when calling the method PooledConnection.close(),
* even if a logical Connection is open for this PooledConnection,
* bc the PooledConnection will obviously not be returned to the pool.
*
* @author fcr
*/
public final class PooledConnectionTest extends TestCase {
// Count nb of closeEvent.
private int closeEventCount;
private ConnectionPoolDataSource cpds;
/** Creates a new instance of ProgressPooledConnectionTest */
public PooledConnectionTest(String testname) {
super(testname);
}
/** Set up test case before a test is run. */
public void setUp() {
// Reset event count.
closeEventCount = 0;
MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource();
ds.setServerName("localhost");
ds.setDatabaseName("whestia");
ds.setUser("root");
ds.setPassword("");
cpds = ds;
}
/** After the test is run. */
public void tearDown() {
cpds = null;
}
/** @return a test suite composed of this test case. */
public static Test suite() {
TestSuite suite = new TestSuite(PooledConnectionTest.class);
return suite;
}
/** Test the nb of closeEvents generated by a PooledConnection.
* A JDBC-compliant driver should only generate 1 closeEvent each time
* connection.close() is called. */
public void testCloseEvent() {
final ConnectionEventListener conListener = new ConnectionListener();
PooledConnection pc = null;
final int NB_TESTS = 5;
try {
pc = cpds.getPooledConnection();
pc.addConnectionEventListener(conListener);
for (int i = 0; i < NB_TESTS; i++) {
Connection conn = pc.getConnection();
System.out.println("Before connection.close().");
// This should generate a close event.
conn.close();
System.out.println("After connection.close().");
}
} catch (SQLException ex) {
fail(ex.toString());
} finally {
if (pc != null) {
try {
System.out.println("Before pooledConnection.close().");
// This should not generate a close event.
pc.close();
System.out.println("After pooledConnection.close().");
} catch (SQLException ex) {
ex.printStackTrace();
}
}
}
assertEquals("Wrong nb of CloseEvents: ", NB_TESTS, closeEventCount);
}
/** Test the nb of closeEvents generated when a Connection is reclaimed.
* No event should be generated in that case. */
public void testConnectionReclaim() {
final ConnectionEventListener conListener = new ConnectionListener();
PooledConnection pc = null;
final int NB_TESTS = 5;
try {
pc = cpds.getPooledConnection();
pc.addConnectionEventListener(conListener);
for (int i = 0; i < NB_TESTS; i++) {
Connection conn = pc.getConnection();
try {
// Try to reclaim connection.
System.out.println("Before connection reclaim.");
conn = pc.getConnection();
System.out.println("After connection reclaim.");
} finally {
if (conn != null) {
System.out.println("Before connection.close().");
// This should generate a close event.
conn.close();
System.out.println("After connection.close().");
}
}
}
} catch (SQLException ex) {
ex.printStackTrace();
fail(ex.toString());
} finally {
if (pc != null) {
try {
System.out.println("Before pooledConnection.close().");
// This should not generate a close event.
pc.close();
System.out.println("After pooledConnection.close().");
} catch (SQLException ex) {
ex.printStackTrace();
fail(ex.toString());
}
}
}
assertEquals("Wrong nb of CloseEvents: ", NB_TESTS, closeEventCount);
}
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
TestRunner.run(PooledConnectionTest.suite());
}
/** Listener for PooledConnection events. */
private final class ConnectionListener implements ConnectionEventListener {
/** */
public void connectionClosed(ConnectionEvent event) {
closeEventCount++;
System.out.println(closeEventCount + " - Connection closed.");
}
/** */
public void connectionErrorOccurred(ConnectionEvent event) {
System.out.println("Connection error: " + event.getSQLException());
}
}
}
Description: When calling pooledConnection.getConnection() after a logical Connection has been retrieved from the same PooledConnection and not yet closed, the previous Connection is automatically closed, as stated by the JDBC 2.0 specification. But in that case, the MySQL implementation will generate a closeEvent when the JDBC specification says it must not. The MySQL implementation of PooledConnection also generates a closeEvent when calling pooledConnection.close(). While the JDBC specification is not clear about this, I think It shouldn't generate a closeEvent in that case because the PooledConnection won't be returned to the pool. How to repeat: I have created a JUnit test case: /* PooledConnectionTest.java * Created on 16 juillet 2003, 11:56 */ import java.sql.*; import javax.sql.ConnectionPoolDataSource; import javax.sql.ConnectionEventListener; import javax.sql.ConnectionEvent; import javax.sql.PooledConnection; import junit.framework.*; import junit.textui.TestRunner; import com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource; /** Tests a PooledConnection implementation provided by a JDBC driver. * * According to the JDBC 2.0 specification: * * <p>"Each call to PooledConnection.getConnection() must return a newly * constructed Connection object that exhibits the default Connection behavior. * Only the most recent Connection object produced from a particular * PooledConnection is open. An existing Connection object is automatically * closed, if the getConnection() method of its associated Pooled-Connection is * called again, before it has been explicitly closed by the application. This * gives the application server a way to ‘take away’ a Connection from the * application if it wishes, and give it out to someone else. This capability * will not likely be used frequently in practice."</p> * * <p>"When the application calls Connection.close(), an event is triggered * that tells the connection pool it can recycle the physical database * connection. In other words, the event signals the connection pool that the * PooledConnection object which originally produced the Connection object * generating the event can be put back in the connection pool."</p> * * <p>"A Connection-EventListener will also be notified when a fatal error occurs, * so that it can make a note not to put a bad PooledConnection object back in * the cache when the application finishes using it. When an error occurs, the * ConnectionEventListener is notified by the JDBC driver, just before the * driver throws an SQLException to the application to notify it of the same * error. Note that automatic closing of a Connection object as discussed * in the previous section does not generate a connection close event."</p> * * The JDBC 3.0 specification states the same in other words: * * <p> "The Connection.close method closes the logical handle, but the physical * connection is maintained. The connection pool manager is notified that the * underlying PooledConnection object is now available for reuse. If the * application attempts to reuse the logical handle, the Connection * implementation throws an SQLException."</p> * * <p>"For a given PooledConnection object, only the most recently produced * logical Connection object will be valid. * Any previously existing Connection object is automatically closed when the * associated PooledConnection.getConnection method is called. Listeners * (connection pool managers) are not notified in this case. * This gives the application server a way to take a connection away from * a client. * This is an unlikely scenario but may be useful if the application server is * trying to force an orderly shutdown."</p> * * <p>"A connection pool manager shuts down a physical connection by calling the * method PooledConnection.close. This method is typically called only in * certain circumstances: when the application server is undergoing an orderly * shutdown, when the connection cache is being reinitialized, or when the * application server receives an event indicating that an unrecoverable error * has occurred on the connection."</p> * * Even though the specification isn't clear about it, I think it is no use * generating a close event when calling the method PooledConnection.close(), * even if a logical Connection is open for this PooledConnection, * bc the PooledConnection will obviously not be returned to the pool. * * @author fcr */ public final class PooledConnectionTest extends TestCase { // Count nb of closeEvent. private int closeEventCount; private ConnectionPoolDataSource cpds; /** Creates a new instance of ProgressPooledConnectionTest */ public PooledConnectionTest(String testname) { super(testname); } /** Set up test case before a test is run. */ public void setUp() { // Reset event count. closeEventCount = 0; MysqlConnectionPoolDataSource ds = new MysqlConnectionPoolDataSource(); ds.setServerName("localhost"); ds.setDatabaseName("whestia"); ds.setUser("root"); ds.setPassword(""); cpds = ds; } /** After the test is run. */ public void tearDown() { cpds = null; } /** @return a test suite composed of this test case. */ public static Test suite() { TestSuite suite = new TestSuite(PooledConnectionTest.class); return suite; } /** Test the nb of closeEvents generated by a PooledConnection. * A JDBC-compliant driver should only generate 1 closeEvent each time * connection.close() is called. */ public void testCloseEvent() { final ConnectionEventListener conListener = new ConnectionListener(); PooledConnection pc = null; final int NB_TESTS = 5; try { pc = cpds.getPooledConnection(); pc.addConnectionEventListener(conListener); for (int i = 0; i < NB_TESTS; i++) { Connection conn = pc.getConnection(); System.out.println("Before connection.close()."); // This should generate a close event. conn.close(); System.out.println("After connection.close()."); } } catch (SQLException ex) { fail(ex.toString()); } finally { if (pc != null) { try { System.out.println("Before pooledConnection.close()."); // This should not generate a close event. pc.close(); System.out.println("After pooledConnection.close()."); } catch (SQLException ex) { ex.printStackTrace(); } } } assertEquals("Wrong nb of CloseEvents: ", NB_TESTS, closeEventCount); } /** Test the nb of closeEvents generated when a Connection is reclaimed. * No event should be generated in that case. */ public void testConnectionReclaim() { final ConnectionEventListener conListener = new ConnectionListener(); PooledConnection pc = null; final int NB_TESTS = 5; try { pc = cpds.getPooledConnection(); pc.addConnectionEventListener(conListener); for (int i = 0; i < NB_TESTS; i++) { Connection conn = pc.getConnection(); try { // Try to reclaim connection. System.out.println("Before connection reclaim."); conn = pc.getConnection(); System.out.println("After connection reclaim."); } finally { if (conn != null) { System.out.println("Before connection.close()."); // This should generate a close event. conn.close(); System.out.println("After connection.close()."); } } } } catch (SQLException ex) { ex.printStackTrace(); fail(ex.toString()); } finally { if (pc != null) { try { System.out.println("Before pooledConnection.close()."); // This should not generate a close event. pc.close(); System.out.println("After pooledConnection.close()."); } catch (SQLException ex) { ex.printStackTrace(); fail(ex.toString()); } } } assertEquals("Wrong nb of CloseEvents: ", NB_TESTS, closeEventCount); } /** * @param args the command line arguments */ public static void main(String[] args) { TestRunner.run(PooledConnectionTest.suite()); } /** Listener for PooledConnection events. */ private final class ConnectionListener implements ConnectionEventListener { /** */ public void connectionClosed(ConnectionEvent event) { closeEventCount++; System.out.println(closeEventCount + " - Connection closed."); } /** */ public void connectionErrorOccurred(ConnectionEvent event) { System.out.println("Connection error: " + event.getSQLException()); } } }