前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >JDBC与MySQL实现分页查询技术

JDBC与MySQL实现分页查询技术

作者头像
Python进击者
发布2019-09-17 15:13:25
1.9K0
发布2019-09-17 15:13:25
举报
文章被收录于专栏:JAVAandPython君

本文转自Cute-Rui的博客:https://blog.csdn.net/coder_gwr/article/details/86563709

由于通过ResultSet的光标实现数据分页存在占用大量资源等性能方便的缺陷,所以,在实际开发中,通过采用数据库的分页机制来实现分页查询功能更为上上之策。

下面我就通过MySQL数据库提供的分页机制来作为案例。

创建Product类,用于封装商品信息。该类是商品信息的JavaBean

代码语言:javascript
复制
package bean;

import java.math.BigDecimal;

public class Product {
    public static final int PAGE_SIZE = 2;//每页记录数
    private int p_id;//编号
    private String p_name;//名称
    private BigDecimal p_price;//价格

    public int getP_id() {
        return p_id;
    }

    public void setP_id(int p_id) {
        this.p_id = p_id;
    }

    public String getP_name() {
        return p_name;
    }

    public void setP_name(String p_name) {
        this.p_name = p_name;
    }

    public BigDecimal getP_price() {
        return p_price;
    }

    public void setP_price(BigDecimal p_price) {
        this.p_price = p_price;
    }
}

Product类中,主要封装了商品对象的基本信息。除此之外,我还定义了分页的每页记录数。

创建ProductDao类,主要用于封装商品对象的数据库相关操作。该类是商品信息的Dao层。

代码语言:javascript
复制
package dao;

import bean.Product;
import util.DBUtil;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class ProductDao {

    /**
     * 分页查询所有商品信息
     *
     * @param page 页数
     * @return List<Product>
     */
    public List<Product> findAllProduct(int page) {
        List<Product> productList = new ArrayList<>();//实例化List对象
        Connection conn = null;//数据库连接
        PreparedStatement pstmt = null;//PreparedStatement
        ResultSet rs = null;//结果集
        //limit arg0,arg1 指定查询起始位置,指定查询数据所返回的记录数
        String sql = "select p_id,p_name,p_price from product order by p_id limit ?,?";//分页查询的SQL语句

        try {
            conn = DBUtil.getCon();//获取数据库连接
            pstmt = conn.prepareStatement(sql);//获取PreparedStatement
            pstmt.setInt(1, (page - 1) * Product.PAGE_SIZE);//对SQL语句第一个参数赋值
            pstmt.setInt(2, Product.PAGE_SIZE);//对SQL语句第二个参数赋值
            rs = pstmt.executeQuery();//执行查询操作
            while (rs.next()) {
                Product product = new Product();
                product.setP_id(rs.getInt("p_id"));//对p_id属性赋值
                product.setP_name(rs.getString("p_name"));//对p_name属性赋值
                product.setP_price(rs.getBigDecimal("p_price"));//对p_price属性赋值
                productList.add(product);//将Product对象添加到List集合中
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtil.close(rs, pstmt, conn);//关闭进行回收资源
        }
        return productList;
    }

    /**
     * 查询总记录数
     *
     * @return count总记录数
     */
    public int findAllProductCount() {
        int count = 0;//总记录数
        Connection conn = null;//数据库连接
        PreparedStatement pstmt = null;//PreparedStatement
        ResultSet rs = null;//结果集
        String sql = "select count(*) from product";//查询总记录数的SQL语句

        try {
            conn = DBUtil.getCon();//获取数据库连接
            pstmt = conn.prepareStatement(sql);//获取PreparedStatement
            rs = pstmt.executeQuery();//执行查询操作
            if (rs.next()) {//光标向后移动,并判断是否有效
                count = rs.getInt(1);//对总记录数赋值
            }

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtil.close(rs, pstmt, conn);//关闭回收资源
        }
        return count;//返回总记录数
    }

}

findAllProduct(int page) ;方法,用来查询指定页数的商品。page参数,用来指定页数。 findAllProductCount();方法,用来查询总记录数。这样一次查询,即可知道总记录数。

缺点在于,一旦有新的记录产生,在下一次查询后,有一些记录不会被查询到,因此待优化。

创建FindAllProduct类,该类是分页查询商品信息的Servlet对象。在doGet()方法中,对分页请求进行处理。

代码语言:javascript
复制
package servlet;

import bean.Product;
import dao.ProductDao;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.List;

@WebServlet("/FindAllProduct")
public class FindAllProduct extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) {

    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        int currPage = 1;//当前页码
        if (request.getParameter("page") != null) {//判断传递页面是否有效
            currPage = Integer.parseInt(request.getParameter("page"));//对当前页码赋值
        }
        ProductDao dao = new ProductDao();//实例化ProductDao
        List<Product> productList = dao.findAllProduct(currPage);//查询所有商品的信息
        request.setAttribute("productList", productList);//将list放置到request中
        int pages;//总页数
        int count = dao.findAllProductCount();//查询总记录数
        if (count % Product.PAGE_SIZE == 0) {
            pages = count / Product.PAGE_SIZE;//对总页数赋值
        } else {
            pages = count / Product.PAGE_SIZE + 1;//对总页数赋值
        }
        StringBuilder sb = new StringBuilder();//实例化StringBuffer
        for (int i = 1; i <= pages; i++) {
            if (i == currPage) {
                sb.append("[").append(i).append("]");//构建分页条
            } else {
                sb.append("<a href='FindAllProduct?page=").append(i).append("'>").append(i).append("</a>");//构建分页条
            }
        }
        sb.append("  ");//构建分页条
        request.setAttribute("bar", sb.toString());//将分页条的字符串放置到request中
        request.getRequestDispatcher("product.jsp").forward(request, response);//将请求转发到product.jsp页面中
    }
}

FindAllProduct类主要做两件事,获取分页查询结果集和构造分页条对象。

分页查询结果集的实现,通过调用ProductDao类的findAllProduct(page)方法。

构造分页条对象是通过拼接html字符串进行构造,然后使用Servlet中的HttpServletRequest对象,将请求转发至product.jsp页面做出展示。

创建product.jsp页面,该页面通过EL表达式JavaAPI获取查询的结果集与分页条来分页显示商品信息数据。

代码语言:javascript
复制
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<%--
Created by IntelliJ IDEA.
  User: wen
  Date: 2019/1/20
  Time: 15:43
  To change this template use File | Settings | File Templates.
--%>
<%@ page contentType="text/html;charset=UTF-8" %>
<html>
<head>
    <title>商品展示</title>
</head>
<body>
<table align="center" width="450" border="1">
    <tr>
        <td align="center" colspan="3">
            <h2>商品信息展示</h2>
        </td>
    </tr>
    <tr align="center">
        <td>ID</td>
        <td>商品名称</td>
        <td>价格</td>
    </tr>
    <c:forEach items="${requestScope.productList}" var="item">
        <tr>
            <td>${item.p_id}</td>
            <td>${item.p_name}</td>
            <td>${item.p_price}</td>
        </tr>
    </c:forEach>
    <tr>
        <td align="center" colspan="5">
            <%=request.getAttribute("bar")%>
        </td>
    </tr>
</table>
</body>
</html>

最后附上我封装的JDBC连接数据库的工具类DBUtil

代码语言:javascript
复制
package util;

/**
 * 连接数据库
 */

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBUtil {

    /**
     * 获取连接
     *
     * @return Connection
     * @throws Exception 异常
     */
    public static Connection getCon() throws Exception {
        //数据库驱动名字
        String jdbcName = "com.mysql.jdbc.Driver";
        Class.forName(jdbcName);
        //数据库协议地址
        String dbUrl = "jdbc:mysql://129.204.104.108:3306/guowenrui?useUnicode=true&characterEncoding=UTF-8";
        //数据库用户名
        String dbUser = "guowenrui";
        //数据库密码
        String dbPassword = "gwr123";
        Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
        return conn;
    }

    /**
     * 关闭连接
     *
     * @param stmt Statement
     * @param conn Connection
     * @throws Exception 异常
     */
    public static void close(Statement stmt, Connection conn) throws Exception {
        if (stmt != null) {
            stmt.close();
            if (conn != null) {
                conn.close();
            }
        }
    }

    /**
     * 关闭连接
     *
     * @param cstmt CallableStatement
     * @param conn  Connection
     * @throws Exception 异常
     */
    public static void close(CallableStatement cstmt, Connection conn) throws Exception {
        if (cstmt != null) {
            cstmt.close();
            if (conn != null) {
                conn.close();
            }
        }
    }


    /**
     * 关闭连接
     *
     * @param pstmt PreparedStatement
     * @param conn  Connection
     * @throws SQLException SQL异常
     */
    public static void close(PreparedStatement pstmt, Connection conn) {
        if (pstmt != null) {
            try {
                pstmt.close();
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 重载关闭方法
     *
     * @param pstmt PreparedStatement
     * @param conn  Connection
     * @throws Exception 异常
     */
    public static void close(ResultSet rs, PreparedStatement pstmt, Connection conn) {
        if (rs != null) {
            try {
                rs.close();
                if (pstmt != null) {
                    pstmt.close();
                    if (conn != null) {
                        conn.close();
                    }
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

}

展示效果图如下:

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2019-02-01,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 Python进击者 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档