实际开发中最常用到连接池,连接池是创建和管理一个连接的缓冲池的技术,这些连接准备好被任何需要它们的线程使用。连接池的出现可以减少资源的频繁请求和释放。
连接池实现的核心就是:当用户关闭连接时,我们把连接返回到池中,好使其他线程使用,而并非真正的关闭
。
从这个角度分析,我们只需要重写连接的 close 方法,就可以实现一个简单的连接池。可以使用包装设计模式或者是代理模式,重写 close 方法即可。
但是包装设计模式需要重写所有的类,比较麻烦,所以我使用的是代理模式。(具体代码可以参考cn.xiuyu.pool
)
GitHub 地址:传送门
当 spring data 与 jpa 子项目一起使用时只需要写一个 dao 接口,继承一个 jparepository 接口。spring data 就会自动帮你生成一个代理 dao 类,并自动生成 sql 语句运行并返回结果,当有复杂操作时在方法上面添加 @Query 注解 就可以自动 sql 语句。这也是我实现的核心。
写一个 UserResponse 类,将 UserRespons 继承Repository
,再一个实体类 User 用于封装数据,然后在测试类使用ResponseFactory.getInstance()
获取 ResponseFactory 的工厂实例,然后再使用工厂方法createResponse
创建 dao 代理对象,然后就可以进行快乐的操作了.(这也是我设计不合理的地方,很狗血,这也是我不想继续写下去的原因)
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);
}
}
这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。
V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。
V2EX is a community of developers, designers and creative people.