浏览 3911 次
锁定老帖子 主题:使用XML配置c3p0数据库连接池
精华帖 (0) :: 良好帖 (0) :: 新手帖 (0) :: 隐藏帖 (0)
|
|
---|---|
作者 | 正文 |
发表时间:2009-03-29
最后修改:2009-04-02
想通过JDBC来配置c3p0数据库连接池,上网想找到解析工具没有找到,只要自己写了一个,可以读取在根目录下的
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(); } }
声明:ITeye文章版权属于作者,受法律保护。没有作者书面许可不得转载。
推荐链接
|
|
返回顶楼 | |
发表时间:2009-03-31
啥对啥?!
|
|
返回顶楼 | |
发表时间:2009-04-01
stevensinclair 写道 啥对啥?! 我还不是很会使用javaeye提供的功能 |
|
返回顶楼 | |