自定义实现MySQL连接池：从零构建数据库连接池并与SpringData集成

GitHub : 传送门

实际开发中最常用到连接池&＃xff0c;连接池是创建和管理一个连接的缓冲池的技术&＃xff0c;这些连接准备好被任何需要它们的线程使用。连接池的出现可以减少资源的频繁请求和释放。

连接池实现的核心就是&＃xff1a;当用户关闭连接时&＃xff0c;我们把连接返回到池中&＃xff0c;好使其他线程使用&＃xff0c;而并非真正的关闭。

从这个角度分析&＃xff0c;我们只需要重写连接的 close 方法&＃xff0c;就可以实现一个简单的连接池。可以使用包装设计模式或者是代理模式&＃xff0c;重写 close 方法即可。

但是包装设计模式需要重写所有的类&＃xff0c;比较麻烦&＃xff0c;所以我使用的是代理模式。(具体代码可以参考cn.xiuyu.pool)

GitHub 地址&＃xff1a;传送门

Spring Data 是一个用于简化数据库访问&＃xff0c;并支持云服务的开源框架。其主要目标是使得对数据的访问变得方便快捷&＃xff0c;并支持 map-reduce 框架和云计算数据服务。

当 spring data 与 jpa 子项目一起使用时只需要写一个 dao 接口&＃xff0c;继承一个 jparepository 接口。spring data 就会自动帮你生成一个代理 dao 类,并自动生成 sql 语句运行并返回结果&＃xff0c;当有复杂操作时在方法上面添加 &＃64;Query 注解 就可以自动 sql 语句。这也是我实现的核心。

仿照 spring data 实现了自动生成代理类&＃xff0c;支持简单的 CURD&＃xff0c;分页,和一些自定的复杂查询

如何使用&＃xff1f;

写一个 UserResponse 类&＃xff0c;将 UserRespons 继承Repository,再一个实体类 User 用于封装数据,然后在测试类使用ResponseFactory.getInstance()获取 ResponseFactory 的工厂实例&＃xff0c;然后再使用工厂方法createResponse创建 dao 代理对象&＃xff0c;然后就可以进行快乐的操作了.(这也是我设计不合理的地方&＃xff0c;很狗血&＃xff0c;这也是我不想继续写下去的原因)

UserResponse 类

public interface UserResponse extends Repository{

&＃64;Delete("delete from user where id&＃61;?")

public void deletebyid(int id);

&＃64;Query("from User where id&＃61;?")

public User QuerybyID(int id);

&＃64;Updata("update user set name&＃61;?,password&＃61;? where id&＃61;?")

public void updatebyID(String name,String password,int id);

}

封装的方法使用

public class TestOrm {

//获取代理的类和封装的实体类

ResponseFactory factory &＃61; ResponseFactory.getInstance();

UserResponse createResponse &＃61; factory.createResponse(UserResponse.class, User.class);

&＃64;Test

//添加用户

public void add() throws Exception{

for(int i&＃61;0;i<100;i&＃43;&＃43;){

User u &＃61; new User(i&＃43;"",i&＃43;"张三","123123");

createResponse.insert(u);

}

}

&＃64;Test

//更新用户

public void update() throws Exception{

User u &＃61; new User("1","1","1");

createResponse.update(u);

}

&＃64;Test

//删除用户

public void delete() throws Exception{

createResponse.delete(1);

}

&＃64;Test

//查询用户

public void query() throws Exception{

User u &＃61; createResponse.query(1);

System.out.println(u);

}

&＃64;Test

//获取总数

public void count() throws SQLException{

System.out.println(createResponse.Querycount());

}

&＃64;Test

//分页

public void page() throws InstantiationException, IllegalAccessException, SQLException{

//从第 0 叶开始查询 查询 3 页

PageEntity queryBypage &＃61; createResponse.QueryBypage(new PageEntity(0, 3));

List entity &＃61; queryBypage.getEntity();

System.out.println(entity.size());

for(User u:entity){

System.out.println(u);

}

}

&＃64;Test

//通过 &＃64;Query 注解查询

public void querybysql() {

User querybyID &＃61; createResponse.QuerybyID(2);

System.out.println(querybyID);

}

&＃64;Test

//通过 &＃64;Delete 注解删除

public void deletebysql(){

createResponse.deletebyid(1);

}

&＃64;Test

//通过 &＃64;Update 注解更新

public void updatebysql(){

createResponse.updatebyID("123", "123", 2);

}

}

我的其他系列文章

自己手写 springmvc&＃xff1a;传送门

jvm 虚拟机系列 &＃xff1a;传送门

SpringIOC 源码分析系列文章 &＃xff1a;传送门

SpringAOP 源码分析细类文章&＃xff1a;传送门

当然还有我的小博客 &＃xff1a;传送门打一波广告(逃