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

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

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

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层。

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

*/

public List findAllProduct(int page) {

List 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()方法中,对分页请求进行处理。

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 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("").append(i).append("");//构建分页条

}

}

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获取查询的结果集与分页条来分页显示商品信息数据。

Created by IntelliJ IDEA.

User: wen

Date: 2019/1/20

Time: 15:43

To change this template use File | Settings | File Templates.

--%>

商品展示

商品信息展示

ID 商品名称 价格
${item.p_id} ${item.p_name} ${item.p_price}

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

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();

}

}

}

}

展示效果图如下:

mysql jdbc 分页查询_JDBC与MySQL实现分页查询技术相关推荐

  1. mysql jdbc 绑定变量_jdbc测试mysql数据库sql预解析(绑定变量)

    jdbc测试mysql数据库sql预解析(绑定变量) 用习惯了oracle,学习mysql,想测试一下mysql绑定变量的效果.以前看网上介绍大部份都说mysql没有sql共享池的概念,所以也不存在s ...

  2. mysql jdbc连接失败_JDBC连接MySQL失败

    梳理一下连接需要注意的关键点 1.首先需要导入外部的驱动jar包,jar包与MySQL的版本最好对应,一般都是用最新的就没问题. 2.最新驱动加载时要使用Class.forname("com ...

  3. mysql jdbc无法连接_jdbc无法连接mysql

    mysql_connector_java_5.1.34_bin.jar(5.1.19驱动也不行) mysql5.6 代码: private static String JDBCDriver=" ...

  4. centos mysql jar 驱动包_JDBC连接MySQL的数据库

    JDBC连接MySQL的数据库 开发工具:eclipes 数据库:mysql 5.6 jdk:1.8 目的:通过简单示例,教会大家如何通过java的代码实现的MySQL的数据库访问. 访问数据库:首先 ...

  5. jdbc mysql 自动重连_JDBC实现Mysql自动重连机制的方法详解

    JDBC是Java程序连接和访问各种数据库的API,它可以提供Java程序和各种数据库之间的连接服务,下面是爱站技术频道小编为大家带来的JDBC实现Mysql自动重连机制的方法详解. 日志:using ...

  6. mysql jdbc 表结构_JDBC操作表:JDBC修改表结构

    操作数据库:mysql 操作目的:通过增加字段,删除字段,修改字段和修改字段类型的方式让大家熟练掌握通过JDBC修改表结构. 在通过JDBC修改表结构前,我们还是先看下当前的表结构,如下图所示: 1. ...

  7. 本地mysql拒绝jdbc连接失败_jdbc连接MySQL数据库的诡异异常 java.net.ConnectException: 拒绝连接...

    今天遇到一个很诡异的异常,查了很多资料都没有解决. 用JDBC连接数据库的时候出现以下异常 @Test public void test() { try { Class.forName("c ...

  8. mysql jdbc连接串_jdbc连接字符串

    MySQL: String Driver="com.mysql.jdbc.Driver"; //驱动程序 String URL="jdbc:mysql://localho ...

  9. Java数据库部分(MySQL+JDBC)(一、MySQL超详细学习笔记)

    所有示例使用的数据表均为Oracle提供的SQL基础数据表(t_employees.sql dept.sql emp.sql salgrade.sql) 熟练掌握多多练习即可达到完成后端开发所需具备的 ...

最新文章

  1. 零基础入门学习Python(33)-图形用户界面编程(GUI编程)EasyGui
  2. html浏览器影响js问题,js 浏览器兼容性问题
  3. zepto点击事件兼容pc和mobile
  4. 【中级软考】UML图(Unified Modeling Language统一建模语言、标准建模语言)
  5. linux进程被中断打断,linux – 当中断处理程序被另一个中断中断时,中断上下文如何“恢复”?...
  6. 【译】A Beginner-Friendly Introduction to Containers, VMs and Docker
  7. 日周月筛选器_举个栗子!Tableau 技巧(147):使用 动态参数 筛选到最新日期值...
  8. Android之TypedArray 为什么需要调用recycle()
  9. SSH连接远程服务器,本地known_hosts文件记录了什么
  10. ffmpeg 解码视频(h264、mpeg2)输出yuv420p文件
  11. LEADTOOLS概览
  12. 是什么计算机接入网络的接口设备,什么是计算机接入网络的接口设备
  13. Python 调度算法 死锁 静动态链接 分页分段(七)
  14. LeetCode 437. 路径总和 III
  15. 58移动开发 App 工厂
  16. SMB/CIFS--NetBOIS/Browser/NBNS 协议
  17. nginx负载均衡的5种策略及原理
  18. Java中文繁简体转换工具
  19. 张靓颖同学2006年日程表
  20. pmp知识点(12)-项目采购管理

热门文章

  1. CSS keylogger:攻击与防御
  2. 《ASP.NET MVC企业实战》(二) MVC开发前奏
  3. 二维树状数组 BZOJ 1452 [JSOI2009]Count
  4. 【字符串处理算法】最长连续字符及其出现次数的算法设计及C代码实现
  5. 我的 FPGA 学习历程(11)—— 实验:按键消抖
  6. 自定义的 ListBoxItem 自适应ListBox的宽度
  7. 重力感应的测试程序andriod源代码
  8. 在Visual Studio 2010 里使用Nunit 进行Debug 测试
  9. 分不清的InputStream和OutputStream
  10. 瑞士的迷人风光(转)