What if you change your pool with a datasource pooling solutiuon such as DBCP? The iBatis default connection pool is fairly simple implemented, last time I went through the code.Hi jbarrez,
thanks for your reply.
I am using the Apache Commons DBCP, mainly to monitor who's asking for connections, closing them, etc. It's configured this way:
myDataSource = new org.apache.commons.dbcp.BasicDataSource();
myDataSource.setDriverClassName("org.postgresql.Driver");
myDataSource.setUrl("jdbc
ostgresql://127.0.0.1:54322/activiti");
myDataSource.setUsername("activiti");
myDataSource.setPassword("activiti");
myDataSource.setMaxActive(maxConnectionNumber);
myDataSource.setMinIdle(0);
System.out.println("max Active: " + myDataSource.getMaxActive());
DataSource ds = new HackedDataSource(myDataSource);
ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration
.createStandaloneProcessEngineConfiguration()
.setDataSource(ds);
processEngine = processEngineConfiguration.buildProcessEngine();
System.out.println("processEngine created OK!");
The classes HackedConnection and HackedDataSource implement java.sql.Connection and javax.sql.DataSource respectively. :
public class HackedConnection implements Connection {
private Connection conn;
public HackedConnection(Connection conn) {
this.conn = conn;
}
public void close() throws SQLException {
String name = Thread.currentThread().getName();
System.out.println(" –Connection.close called for thread " + name
+ ".");
HackerDatabase.customerLeaves(name);
conn.close();
System.out.println(" –Connection.close finishes for thread " + name
+ ".");
}
..delegate methods…
public class HackedDataSource implements DataSource {
private DataSource dataSource;
private TreeSet<String> customers;
public HackedDataSource(DataSource dataSource) {
this.dataSource = dataSource;
this.customers = new TreeSet<String>();
}
public Connection getConnection() throws SQLException {
String name = Thread.currentThread().getName();
System.out.println(" –getConnection called for thread " + name + ".");
synchronized (customers) {
if (!"main".equals(name)) {
if (customers.contains(name))
System.out.println(" —-hey!");
customers.add(name);
}
}
HackerDatabase.customerAsking(name);
Connection conn = dataSource.getConnection();
HackerDatabase.customerServed(name);
System.out.println(" –getConnection finishes for thread " + name
+ ".");
return new HackedConnection(conn);
}
…delegate methods…
HackerDatabase maintains sets of threads waiting for the connection and those holding a connection.
Thanks,
Marcin Jaskolski
