ibatis下加入c3p0連接池的方法
我看論壇里有兩個(gè)人寫了在iBatis中加入c3p0連接池，我也就不跟著摻合了，做這個(gè)ibatis下加入c3p0連接池的方法的原因是沒法用spring，又需要連接池，且對(duì)DBCP一直觀感不加，沒法，只好自己動(dòng)手加入c3p0連接池了。
在iBatis中加入c3p0連接池沒啥難技術(shù)含量，寫個(gè)文章備份下。
首先打開iBatis的源碼包，找到com.ibatis.sqlmap.engine.datasource包，在里面新建個(gè)類，C3p0DataSourceFactory，并實(shí)現(xiàn)DataSourceFactory接口，里面的代碼是Java代碼
private DataSource dataSource;
public DataSource getDataSource() {
return dataSource;
}
public void initialize(Map map) {
C3p0Configuration c3p0 = new C3p0Configuration(map);
dataSource = c3p0.getDataSource();
}
private DataSource dataSource;
public DataSource getDataSource() {
return dataSource;
}
public void initialize(Map map) {
C3p0Configuration c3p0 = new C3p0Configuration(map);
dataSource = c3p0.getDataSource();
}
在ibatis下加入c3p0連接池的下一步是到com.ibatis.common.jdbc包里，新建類C3p0Configuration，里面的代碼是。。。太長(zhǎng)了，原來在dbcp那部分里，還有單獨(dú)加載配置文件的方法，我覺得如果連這個(gè)xml都讀不了，那別的一樣沒法讀。
Java代碼
private static final Probe PROBE = ProbeFactory.getProbe();
private DataSource dataSource;
/**
* Constructor to supply a map of properties
*
* @param properties
* - the map of configuration properties
*/
public C3p0Configuration(Map properties) {
try {
dataSource = legacyC3p0Configuration(properties);
} catch (Exception e) {
throw new RuntimeException(
"Error initializing C3p0DataSourceFactory. Cause: " + e, e);
}
}
/**
* Getter for DataSource
*
* @return The DataSource
*/
public DataSource getDataSource() {
return dataSource;
}
private boolean notEmpty(String s) {
return s != null && s.length() > 0;
}
private boolean notSelfString(String s, String compareStr) {
return !s.equalsIgnoreCase(compareStr);
}
private DataSource legacyC3p0Configuration(Map map) {
ComboPooledDataSource combo = null;
try {
if (map.containsKey("JDBC.Driver")) {
combo = new ComboPooledDataSource();
String driverClass = (String) map.get("JDBC.Driver");
String jdbcUrl = (String) map.get("JDBC.ConnectionURL");
String user = (String) map.get("JDBC.Username");
String password = (String) map.get("JDBC.Password");
Class.forName(driverClass);
combo.setDriverClass(driverClass);
combo.setJdbcUrl(jdbcUrl);
combo.setUser(user);
combo.setPassword(password);
String acquireIncrement = (String) map
.get("Pool.acquireIncrement");
if (notEmpty(acquireIncrement)
&& notSelfString(acquireIncrement, "acquireIncrement"))
combo.setAcquireIncrement(Integer
.parseInt(acquireIncrement));
......................
private static final Probe PROBE = ProbeFactory.getProbe();
private DataSource dataSource;
/**
* Constructor to supply a map of properties
*
* @param properties
* - the map of configuration properties
*/
public C3p0Configuration(Map properties) {
try {
dataSource = legacyC3p0Configuration(properties);
} catch (Exception e) {
throw new RuntimeException(
"Error initializing C3p0DataSourceFactory. Cause: " + e, e);
}
}
/**
* Getter for DataSource
*
* @return The DataSource
*/
public DataSource getDataSource() {
return dataSource;
}
private boolean notEmpty(String s) {
return s != null && s.length() > 0;
}
private boolean notSelfString(String s, String compareStr) {
return !s.equalsIgnoreCase(compareStr);
}
private DataSource legacyC3p0Configuration(Map map) {
ComboPooledDataSource combo = null;
try {
if (map.containsKey("JDBC.Driver")) {
combo = new ComboPooledDataSource();
String driverClass = (String) map.get("JDBC.Driver");
String jdbcUrl = (String) map.get("JDBC.ConnectionURL");
String user = (String) map.get("JDBC.Username");
String password = (String) map.get("JDBC.Password");
Class.forName(driverClass);
combo.setDriverClass(driverClass);
combo.setJdbcUrl(jdbcUrl);
combo.setUser(user);
combo.setPassword(password);
String acquireIncrement = (String) map
.get("Pool.acquireIncrement");
if (notEmpty(acquireIncrement)
&& notSelfString(acquireIncrement, "acquireIncrement"))
combo.setAcquireIncrement(Integer
.parseInt(acquireIncrement));
......................
***在com.ibatis.sqlmap.engine.config包里，找到SqlMapConfiguration，在里面找到，加上C3P0就可以實(shí)現(xiàn)在ibatis下加入c3p0連接池了
Java代碼
// DATA SOURCE ALIASES
typeHandlerFactory.putTypeAlias("SIMPLE", SimpleDataSourceFactory.class.getName());
typeHandlerFactory.putTypeAlias("DBCP", DbcpDataSourceFactory.class.getName());
typeHandlerFactory.putTypeAlias("C3P0", C3p0DataSourceFactory.class.getName());
typeHandlerFactory.putTypeAlias("JNDI", JndiDataSourceFactory.class.getName());
通過這種手段，可以在ibatis下加入c3p0連接池，但是由于代碼太長(zhǎng)，在這里就不一一列出了，本文只是提出了一個(gè)在ibatis下加入c3p0連接池的思路，具體關(guān)于ibatis下加入c3p0連接池代碼還需要朋友們自己斟酌。
【編輯推薦】
