JR 精品文章 - 超级简单的数据库连接池（支持多数据源）

首页 » 研究文集 » J2EE综合

搜索标题相关文章

发表评论

开始监控

加入收藏夹

超级简单的数据库连接池（支持多数据源）
giscat 原创更新：2006-11-16 09:29:54 版本: 1.0

连接池最基本的目的：
1、重用连接，节省连接资源；
2、免去建立连接操作，提高效率
3. 限制最大连接并发数

自己弄的一个连接池，绝对高效安全，支持多数据源

连接池的两种实现方式：

1. 修饰模式弄个ConnectionWrapper类出来
2. 动态代理

这里采用的是第一种方式

ConnectionAdapter  implements Connetion
ConnectionWrapper extends ConnectionAdapter

ConnectionWrapper 中封装了connection对象
close方法重写为
{
SimpleConnectionPool.putConnectionToPool(this);
//把连接返回连接池
}

配置文件 app.properties

ConnectionAdapter 从DBCP拷贝过来，删了些垃圾东西

支持多数据源

DBUtil.getConn();//获取默认连接池
DBUtil.getConn(pool_name);//获取指定名称的连接池

各参数说明

pool_name.dirver

driver=net.sourceforge.jtds.jdbc.Driver
url=jdbc:jtds:sqlserver://127.0.0.1:1433/data
user=sa
pwd=sa
type=sqlserver //数据库类型
pool=1        //是否使用连接池 1 使用
max_wait=3    //连接池已满时，最大等待时间，单位 s
#timeout ,wait time when max active ,  unit s
max_active=20  //最大活动连接数，用这个来控制最大并发数
min_free=3     //连接池中最小空闲连接数
max_free=20    //连接池中最大空闲连接数,默认=max_active
check_sql=select getdate()  //验证连接是否有效，
clear_time=2                //清理空闲连接
#clear_time,remove the old connection,unit min

还可以用动态代理的方式实现连接池

2.

动态代理实现

class ConnectionWrapper implements InvocationHandler {

private final static String CLOSE_METHOD_NAME = "close";
  public Connection connection = null;
  private Connection m_originConnection = null;

ConnectionWrapper(Connection con,String pool_name)throws Exception {
    this.pool_name=pool_name;

    this.check_sql = getCheckSqlByPoolName(pool_name);

    last_use_time = System.currentTimeMillis();
    create = StringUtil.getNowTime()+"";

      Class[] interfaces = {java.sql.Connection.class};
    this.connection = (Connection) Proxy.newProxyInstance(
      con.getClass().getClassLoader(),
      interfaces, this);
    m_originConnection = con;
  }


  void close() {
    //m_originConnection.close();
      DBUtil.close(m_originConnection);
  }

  public Object invoke(Object proxy, Method m, Object[] args) throws Throwable {
    Object obj = null;
    if (CLOSE_METHOD_NAME.equals(m.getName())) {
        //SimpleConnectionPool.pushConnectionBackToPool(this);
        SimpleConnectionPool.putConnectionToPool(this);

    }
    else {

      obj = m.invoke(m_originConnection, args);
      //last_use_time = System.currentTimeMillis();
    }


    return obj;
  }


}

              代码不全，只提供连接池部分代码，学习交流用

      enjoy
                               giscat
                                       2006-11-15附件：pool.rar(9K)

本篇文章对您是否有帮助？投票：是否投票结果：

作者其它文章：

作者全部文章查看作者的Blog

评论人：十字刀客	发表时间: Thu Nov 16 09:48:17 CST 2006
好，支持一下。

评论人：yangyangsun_124	发表时间: Fri Nov 17 14:32:50 CST 2006
看一下

评论人：yangyangsun_124	发表时间: Fri Nov 17 16:53:53 CST 2006
学习看一下

评论人：jacky3621	发表时间: Fri Nov 17 18:19:51 CST 2006
虽然简单，但很能说明问题。其实连接池也不是那么神秘。

评论人：jacksj207	发表时间: Sun Nov 19 18:08:56 CST 2006
不错

评论人：fishee44	发表时间: Tue Nov 21 23:40:49 CST 2006
还是不错的... 收下了

评论人：teleping	发表时间: Wed Nov 22 11:55:01 CST 2006
弄全了吧

评论人：mrou2001	发表时间: Wed Dec 06 22:13:30 CST 2006
不错的文章

评论人：vampire_315	发表时间: Sun Dec 17 19:11:22 CST 2006
不错啊

评论人：xushiming	发表时间: Tue Jul 08 14:21:32 CST 2008
能支持不同的开源链接池包吗？

评论人：xushiming	发表时间: Tue Jul 08 14:33:21 CST 2008
晕，老是分数不够！！

评论人：mll0301	发表时间: Thu Nov 20 10:41:53 CST 2008
破网站老弄个啥积分啊没分咋下啊

这个文章共有 12 条评论

上一篇文章

返回〔J2EE综合〕

下一篇文章