echeneidae's Introduction

Echeneidae

a connection pool , supply a long connection for per thread

#产生原因: #

由于现有的连接池实现都比较复杂,配置项也很多,导致使用的时候容易出问题,后来考虑了下,由于现在一般的服务都是用线程池的技术了,所以想充分利用下这个特点,给每个线程建立一个长连接,这样实现和理解起来都很简单,也做到了连接的复用(取名Echeneidae,也是因为和这种鱼的特点相似)

##特点:##

1.实现模式简单:一个线程对应一个数据库长连接,无需加锁
2.使用简单:几乎无外部依赖,几乎无需配置即可使用
3.必须配合固定大小线程池一起使用,否则连接可能无法释放(为什么是可能?)

##使用要求:## jdk 1.6以上,jdbc4

##TODO:## 未实现存储过程调用

##实现方式:##

第一次建立连接之后,首先将连接保存到ThreadLocal中,之后代理连接的close方法,让close的时候不执行关闭连接的操作, 下次需要连接的时候,直接返回之前建立的连接,如果在执行sql语句的时候出现了异常,会检查一下连接是否正常,如果不正常了,会把连接标记为无效,并在下次获取连接的时候关闭旧连接,并重新创建新的连接

##使用方式:## 使用方式和普通的数据源一样,以下是一个配合commons-dbutils的例子

String driverClassName = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost/test?connectTimeout=1000&socketTimeout=1000";
EcheneidaeDataSource ds = new EcheneidaeDataSource(driverClassName, url, "root", "");

QueryRunner queryer = new QueryRunner(ds);
List<Map<String, Object>> result = queryer.query("select * from tb_users", new MapListHandler());
System.out.println(result);

Recommend Projects