自己手写数据库连接池和 SpringData

2017-06-23 18:35:44 +08:00
 gexyuzz

GitHub : 传送门

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

连接池实现的核心就是:当用户关闭连接时,我们把连接返回到池中,好使其他线程使用,而并非真正的关闭。 从这个角度分析,我们只需要重写连接的 close 方法,就可以实现一个简单的连接池。可以使用包装设计模式或者是代理模式,重写 close 方法即可。
但是包装设计模式需要重写所有的类,比较麻烦,所以我使用的是代理模式。(具体代码可以参考cn.xiuyu.pool
GitHub 地址:传送门

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

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

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

如何使用?

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

UserResponse 类
public interface UserResponse extends Repository<User>{
	@Delete("delete from user where id=?")
	public void deletebyid(int id);
	@Query("from User where id=?")
	public User QuerybyID(int id);
	
	@Updata("update user set name=?,password=? where id=?")
	public void updatebyID(String name,String password,int id);
}

封装的方法使用

public class TestOrm {
	//获取代理的类和封装的实体类
	ResponseFactory factory = ResponseFactory.getInstance();
	UserResponse createResponse = factory.createResponse(UserResponse.class, User.class);
	
	@Test
	//添加用户
	public void add() throws Exception{
		for(int i=0;i<100;i++){
			User u = new User(i+"",i+"张三","123123");
			createResponse.insert(u);
		}
	}
	@Test
	//更新用户
	public void update() throws Exception{
		User u = new User("1","1","1");
		createResponse.update(u);
	}
	@Test
	//删除用户
	public void delete() throws Exception{
		createResponse.delete(1);
	}
	@Test
	//查询用户
	public void query() throws Exception{
		User u = createResponse.query(1);
		System.out.println(u);
	}
	
	@Test
	//获取总数
	public void count() throws SQLException{
		System.out.println(createResponse.Querycount());
	}
	
	@Test
	//分页
	public void page() throws InstantiationException, IllegalAccessException, SQLException{
		//从第 0 叶开始查询 查询 3 页
		PageEntity<User> queryBypage = createResponse.QueryBypage(new PageEntity<User>(0, 3));
		List<User> entity = queryBypage.getEntity();
		System.out.println(entity.size());
		for(User u:entity){
			System.out.println(u);
		}
	}
	
	
	@Test
	//通过 @Query 注解查询
	public void querybysql() {
		User querybyID = createResponse.QuerybyID(2);
		System.out.println(querybyID);
	}
	@Test
	//通过 @Delete 注解删除
	public void deletebysql(){
		createResponse.deletebyid(1);
	}
	
	@Test
	//通过 @Update 注解更新
	public void updatebysql(){
		createResponse.updatebyID("123", "123", 2);
	}
	
}


我的其他系列文章

自己手写 springmvc:传送门

jvm 虚拟机系列 :传送门

SpringIOC 源码分析系列文章 :传送门

SpringAOP 源码分析细类文章:传送门

当然还有我的小博客 :传送门打一波广告(逃

3620 次点击
所在节点    Java
10 条回复
lzhr
2017-06-23 20:42:47 +08:00
gexyuzz
2017-06-23 21:18:13 +08:00
@lzhr 一直自用来看坑王驾到(逃
gogohigh
2017-06-25 03:10:44 +08:00
简单看了下
1. useconn 只加不减,useconn>max_pool_size 后,每次 getConn 都会扩容 pool
2. getConn 后调用 abort 之后获取的连接都是 close 的,这里要加判断
gogohigh
2017-06-25 03:15:40 +08:00
3l 的第一条没问题,刚刚没仔细看,嘿嘿。 话说为什么不直接用 pool.size 判断呢?
gogohigh
2017-06-25 03:20:22 +08:00
= = 夜里脑子不好使,忽略 4l poolsize 那个
gexyuzz
2017-06-25 18:32:46 +08:00
@gogohigh 如果是调用 close,连接就是回到池中的。
gogohigh
2017-06-26 01:52:37 +08:00
@gexyuzz 调用 abort 呢?
gexyuzz
2017-06-26 10:16:02 +08:00
@gogohigh Connection 接口和他的父接口 Wrapper 并没有声明这个方法。
gexyuzz
2017-06-26 10:18:35 +08:00
@gogohigh 刚刚看了下,接口没有声明,但是有确实有那个方法。如果你有需求可以重写一下,让连接返回池中,或者是真正的关闭。
sagaxu
2017-06-27 06:42:45 +08:00
接手过一个轮子很多的项目,慢慢的把轮子都替换成主流库,太 tm 坑了,质量太差,还没文档。你们见过连 md5 和 base64 编码都要自己造轮子的项目吗?哦,连 json 都要自己轮一下。

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/370655

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX