本文实例为大家分享了使用XML配置c3p0数据库连接池的具体代码,供大家参考,具体内容如下
想通过JDBC来配置c3p0数据库连接池,上网想找到解析工具没有找到,只要自己写了一个,可以读取在根目录下的c3p0配置文档,再根据配置信息来反射ComboPooledDataSource 中的setter进行连接池的配置。
本人水平很菜,如果有什么不足请大家指出。
package cn.vagasnail.sgms.util;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import com.mchange.v2.c3p0.ComboPooledDataSource;
/**
* 得到c3p0的数据库连接池
*
* @author vagasnail
*
* 2009-3-26 下午07:54:10
*/
public class C3p0ConnectionFactory {
private C3p0ConnectionFactory() {
}
private static ComboPooledDataSource ds = null;
static {
Map<String, String> configs = C3p0XMLParser
.parserXML("c3p0-config.xml"); // 得到一个map包含配置信息
ds = new ComboPooledDataSource(); // 得到一个数据库连接池数据源
Method[] fs = ComboPooledDataSource.class.getMethods(); // 得到该数据库连接池数据源的所以方法信息
Pattern pattern = Pattern.compile("get([A-Z]\\w+)()");
for (Method m : fs) {
Matcher matcher = pattern.matcher(m.getName());
String str = "";
String strLow = "";
if (matcher.find()) {
str = matcher.group(1);
char c = str.charAt(0);
strLow = Character.toLowerCase(c) + str.substring(1);
}
try {
String value = configs.get(strLow);
int intValue = 0;
Method setMod = null;
if (value != null && !"".equals(value)){
try{
intValue = Integer.parseInt(value);
setMod = ComboPooledDataSource.class.getMethod("set"
+ str, int.class); //如果反射的方法中是int类型,而不是包装类Interger,那么无法反射到该犯法,反射调用方法无法自动解包
if(setMod != null)
setMod.invoke(ds, intValue);
}catch(NumberFormatException nfe){
setMod = ComboPooledDataSource.class.getMethod("set"
+ str, String.class);
if(setMod != null)
setMod.invoke(ds, value);
}
}else
continue;
} catch (SecurityException e) {
e.printStackTrace();
} catch (NoSuchMethodException e) {
// e.printStackTrace(); //如果方法不存在则继续下面的循环
continue;
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
login(configs);
}
private static void login(Map<String, String> configs){
ds.setUser(configs.get("user"));
ds.setPassword(configs.get("password"));
}
/**
* 得到一个数据库连接
*
* @return 数据库连接
*/
public static synchronized Connection getConnection() {
Connection con = null;
try {
con = ds.getConnection();
} catch (SQLException e1) {
e1.printStackTrace();
}
return con;
}
/**
* 关闭数据库(并没有真正的关闭,连接池把连接存储起来下一次调用的时候还可以使用)
* @param conn
* @throws SQLException
*//*
public static synchronized void close(Connection conn) {
if (conn != null) {
try {
conn.close();
conn = null;
} catch (SQLException e) {
e.printStackTrace();
return;
}
}
}*/
public static int getCurrentConns() throws SQLException{
return ds.getNumConnectionsAllUsers();
}
}
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持亿速云。
亿速云「云数据库 MySQL」免部署即开即用,比自行安装部署数据库高出1倍以上的性能,双节点冗余防止单节点故障,数据自动定期备份随时恢复。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。