RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
使用XML配置c3p0数据库连接池

本文实例为大家分享了使用XML配置c3p0数据库连接池的具体代码,供大家参考,具体内容如下

创新互联建站:从2013年成立为各行业开拓出企业自己的“网站建设”服务,为数千家公司企业提供了专业的网站设计制作、做网站、网页设计和网站推广服务, 定制开发由设计师亲自精心设计,设计的效果完全按照客户的要求,并适当的提出合理的建议,拥有的视觉效果,策划师分析客户的同行竞争对手,根据客户的实际情况给出合理的网站构架,制作客户同行业具有领先地位的。

想通过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 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 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();
 }
 
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持创新互联。


当前文章:使用XML配置c3p0数据库连接池
标题URL:http://lswzjz.com/article/gigido.html