DBUtils案列：实现数据的增删改查及分页显示

痛定思痛。 2022-06-04 06:40 312阅读 0赞

> Commons DBUtils是Apache组织提供的一个对JDBC进行简单封装的开源工具类库，使用它能够简化JDBC应用程序的开发，同时也不会影响程序的性能。它封装了对JDBC的操作，简化了JDBC操作。可以少写代码

1.对于数据表的读操作，他可以把结果转换成List，Array，Set等java集合，便于程序员操作；  
2.对于数据表的写操作，也变得很简单（只需写sql语句）  
3.可以使用数据源，使用JNDI，数据库连接池等技术来优化性能–重用已经构建好的数据库连接对象  
（在本案例中我们使用C3P0的数据源）

> 核心对象：  
> QueryRunner类：提供对sql语句操作的API（query() 用于执行select ；update() 用于执行insert update delete；batch() 批处理）  
> ResultSetHandler接口：用于定义select操作后，怎样封装结果集.  
> DBUtils类：它就是一个工具类,定义了关闭资源与事务处理的方法

使用步骤：  
1.导入jar包  
2.创建QueryRunner对象  
3.使用query方法执行select语句  
4.使用ResultSetHandler封装结果集  
5.使用DbUtils类释放资源  
po代码：  
![SouthEast][]  
  
**ResultSetHandler下的所有结果处理器**  
//ArrayHandler:适合取1条记录。把该条记录的每列值封装到一个数组中Object\[\]  
//ArrayListHandler:适合取多条记录。把每条记录的每列值封装到一个数组中Object\[\]，把数组封装到一个List中  
//ColumnListHandler:取某一列的数据。封装到List中。  
//KeyedHandler:取多条记录，每一条记录封装到一个Map中，再把这个Map封装到另外一个Map中，key为指定的字段值。  
//MapHandler:适合取1条记录。把当前记录的列名和列值放到一个Map中  
//MapListHandler:适合取多条记录。把每条记录封装到一个Map中，再把Map封装到List中  
//ScalarHandler:适合取单行单列数据  
//BeanHandler:适合取一条记录，封装到对象中  
//BeanListHandler ：适合取多条记录，将每一条记录封装到对象中，然后再把所有对象装到list集合中

QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
    List<User> list = qr.query("select * from user",new BeanListHandler<User>(User.class));

在我们使用DBUtils去实现转账的功能，在分层操作的时候，发现需要我们手动去控制事务，因为转账的过程必须符合事务的一致性，由于我们分层实现的时候，转账是两次更新操作，执行的时候是使用了两个连接，所以不能通过事务去控制，那么我们就想是否可以通过传递同一个连接从而保证事务的控制。  
此处我们使用**ThreadLocal**

> [ThreadLocal][]：线程局部变量。当使用ThreadLocal维护变量时，ThreadLocal为每个使用该变量的线程提供独立的变量副本，所以每一个线程都可以独立地改变自己的副本，而不会影响其它线程所对应的副本。

此处，我们使用ThreadLocal来维护变量Connection

package com.itdream.utils;
    
    import java.sql.Connection;
    import java.sql.SQLException;
    
    /** * Created by Dream on 2017/12/5. */
    public class MyThreadLocal { 
        private static ThreadLocal<Connection> tl = new ThreadLocal<>();
        public static Connection getConnection(){
            Connection con = tl.get();
            if(con == null){
                con = C3P0Utils.getConnection();
                tl.set(con);
            }
            return con;
        }
    
        public static void startTransaction(){
            try {
                getConnection().setAutoCommit(false);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        public static void commit(){
            try {
                getConnection().commit();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        public static void rollback(){
            try {
                getConnection().rollback();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        public static void close(){
            try {
                Connection con = getConnection();
                con.close();
                tl.remove();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

使用DBUtils实现了类似于“书城”的系统  
![这里写图片描述][SouthEast 1]

其中dao包中是最底层，和数据库打交道的接口  
service包是业务层，调用Dao层的方法  
web.servlet是Servlet，实现数据的接收；业务逻辑的调用；分发转向  
其中显示列表数据的思路如下，其他增删改类似：  
![这里写图片描述][SouthEast 2]  
着重说一下多条件查询和分页查询

> 多条件查询：

public class SearchServlet extends HttpServlet { 
        public void doGet(HttpServletRequest request, HttpServletResponse response)throws IOException,ServletException{
            Book book = new Book();
            request.setCharacterEncoding("UTF-8");
        //form表单提交数据，Servlet通过getParameter接收
            String id = request.getParameter("id");
            String name = request.getParameter("name");
            String category = request.getParameter("category");
            String minPrice = request.getParameter("minPrice");
            String maxPrice =request.getParameter("maxPrice");
    
            BookService bs = new BookService();
            List<Book> books = bs.searchBooks(id,name,category,minPrice,maxPrice);
            request.setAttribute("bs",books);
            request.getRequestDispatcher("/admin/products/list.jsp").forward(request,response);
        }
        public void doPost(HttpServletRequest request,HttpServletResponse response)throws ServletException,IOException{
            doGet(request,response);
        }
    }

service层的search就是对底层的直接调用，下面着重po出dao层的search代码

public List<Book> search(String id,String name,String category,String minPrice,String maxPrice)throws SQLException{
            QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
            String sql = "select * from book where 1=1";
            List list = new ArrayList();
            if(!"".equals(id)){
                sql+=" and id like ?";  
                //此处切忌写成：" and id like %?%" ，如果这么写，后续设置上值后会变成 " and id like %'XXX'%" ，而我们需要的是" and id like '%XXX%'"
                list.add("%"+id+"%");
            }
            if(!"".equals(name)){
                sql+=" and name like ?";
                list.add("%"+name+"%");
            }
            if(!"".equals(category)){
                sql += " and category= ?";
                list.add(category);
            }
            if(!"".equals(minPrice)){
                sql += " and price>?";
                list.add(minPrice);
            }
            if(!"".equals(maxPrice)){
                sql += " and price<?";
                list.add(maxPrice);
            }
            return qr.query(sql,new BeanListHandler<Book>(Book.class),list.toArray());
        }

> 分页查询：

对于分页查询，底层的sql语句及其含义：  
select \* from book limit 0,3; //从book表中查出第1~3条  
select \* from book limit 3,6; //从book表中查出第4~6条  
分页牵扯的定义：  
currentPage：当前页面  
pageSize：每页显示的记录数  
count：总记录数  
pageCount：总页数  
count = Math.ceil(count/pageSize)  
select \* from book limit (currentPage-1)\*pageSize,pageSize; //第一个参数：从哪条开始查 第二个参数：查几条  
思路：  
![这里写图片描述][SouthEast 3]  
dao中实现总记录数的查询和满足分页条件的记录的查询  
service调用dao中总记录数的查询和分页的记录的查询，通过总记录数得到总页数，然后完成PageBean对象数据的设置，返回给Servlet  
定义PageBean类：存放分页信息

package com.itdream.domain;
    
    import java.util.List;
    
    /** * Created by Dream on 2017/12/6. */
    public class PageBean { 
        private int currentPage;   //当前页面
        private int pageSize;      //每页显示的记录数
        private int count;         //总记录数
        private int totalPage;     //总页数
        private List<Book> books;  //保存满足分页条件的记录数
        public int getCurrentPage() {
            return currentPage;
        }
        public void setCurrentPage(int currentPage) {
            this.currentPage = currentPage;
        }
        public int getPageSize() {
            return pageSize;
        }
        public void setPageSize(int pageSize) {
            this.pageSize = pageSize;
        }
        public int getCount() {
            return count;
        }
        public void setCount(int count) {
            this.count = count;
        }
        public int getTotalPage() {
            return totalPage;
        }
        public void setTotalPage(int totalPage) {
            this.totalPage = totalPage;
        }
        public List<Book> getBooks() {
            return books;
        }
        public void setBooks(List<Book> books) {
            this.books = books;
        }
    }

PageServlet类：

public class PageServlet extends HttpServlet { 
        public void doGet(HttpServletRequest request, HttpServletResponse response)throws IOException,ServletException{
            int currentPage = 1;   
            int pageSize = 2;  //设定每页显示两条记录
            String current = request.getParameter("currentPage");
            if(current != null){  //第一次访问current可能为null
                currentPage = Integer.parseInt(current);  //默认显示第一页
            }
            BookService bs = new BookService();
            //分页查询，并返回pageBean对象
            PageBean pb = bs.findBooksPage(currentPage,pageSize);
            request.setAttribute("pb",pb);
            request.getRequestDispatcher("/product_list.jsp").forward(request,response);
        }
        public void doPost(HttpServletRequest request, HttpServletResponse response)throws IOException,ServletException{
            doGet(request,response);
        }
    }

BookService类：

public PageBean findBooksPage(int currentPage, int pageSize) {
            try{
                int count = bd.count();   //得到总记录数
                int totalPage = (int) Math.ceil(count*1.0/pageSize);  //得到总页数
                List<Book> books = bd.findBooks(currentPage,pageSize);
                PageBean pb = new PageBean();
                pb.setBooks(books);
                pb.setCount(count);
                pb.setTotalPage(totalPage);
                pb.setCurrentPage(currentPage);
                pb.setPageSize(pageSize);
    
                return  pb;
            }catch (Exception e){
                e.printStackTrace();
            }
            return null;
        }

BookDao类：

public List<Book> findBooks(int currentPage, int pageSize) throws SQLException {
            QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
            return qr.query("select * from book limit ?,?",new BeanListHandler<Book>(Book.class),pageSize*(currentPage-1),pageSize);
        }

[SouthEast]: /images/20220604/4e7d0d24345149f6a7cea48c59843db8.png
[ThreadLocal]: https://www.cnblogs.com/dreamroute/p/5034726.html
[SouthEast 1]: /images/20220604/8d9e358025ec4e4aa66f5358af3e66b4.png
[SouthEast 2]: /images/20220604/242dd5eaa36747d8847da96c0953c12b.png
[SouthEast 3]: /images/20220604/770341806c194a13b3616f6f5fb87ec3.png