mysql jdbc 分页查询_JDBC与MySQL实现分页查询技术
由于通过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实现分页查询技术相关推荐
- mysql jdbc 绑定变量_jdbc测试mysql数据库sql预解析(绑定变量)
jdbc测试mysql数据库sql预解析(绑定变量) 用习惯了oracle,学习mysql,想测试一下mysql绑定变量的效果.以前看网上介绍大部份都说mysql没有sql共享池的概念,所以也不存在s ...
- mysql jdbc连接失败_JDBC连接MySQL失败
梳理一下连接需要注意的关键点 1.首先需要导入外部的驱动jar包,jar包与MySQL的版本最好对应,一般都是用最新的就没问题. 2.最新驱动加载时要使用Class.forname("com ...
- mysql jdbc无法连接_jdbc无法连接mysql
mysql_connector_java_5.1.34_bin.jar(5.1.19驱动也不行) mysql5.6 代码: private static String JDBCDriver=" ...
- centos mysql jar 驱动包_JDBC连接MySQL的数据库
JDBC连接MySQL的数据库 开发工具:eclipes 数据库:mysql 5.6 jdk:1.8 目的:通过简单示例,教会大家如何通过java的代码实现的MySQL的数据库访问. 访问数据库:首先 ...
- jdbc mysql 自动重连_JDBC实现Mysql自动重连机制的方法详解
JDBC是Java程序连接和访问各种数据库的API,它可以提供Java程序和各种数据库之间的连接服务,下面是爱站技术频道小编为大家带来的JDBC实现Mysql自动重连机制的方法详解. 日志:using ...
- mysql jdbc 表结构_JDBC操作表:JDBC修改表结构
操作数据库:mysql 操作目的:通过增加字段,删除字段,修改字段和修改字段类型的方式让大家熟练掌握通过JDBC修改表结构. 在通过JDBC修改表结构前,我们还是先看下当前的表结构,如下图所示: 1. ...
- 本地mysql拒绝jdbc连接失败_jdbc连接MySQL数据库的诡异异常 java.net.ConnectException: 拒绝连接...
今天遇到一个很诡异的异常,查了很多资料都没有解决. 用JDBC连接数据库的时候出现以下异常 @Test public void test() { try { Class.forName("c ...
- mysql jdbc连接串_jdbc连接字符串
MySQL: String Driver="com.mysql.jdbc.Driver"; //驱动程序 String URL="jdbc:mysql://localho ...
- Java数据库部分(MySQL+JDBC)(一、MySQL超详细学习笔记)
所有示例使用的数据表均为Oracle提供的SQL基础数据表(t_employees.sql dept.sql emp.sql salgrade.sql) 熟练掌握多多练习即可达到完成后端开发所需具备的 ...
最新文章
- 零基础入门学习Python(33)-图形用户界面编程(GUI编程)EasyGui
- html浏览器影响js问题,js 浏览器兼容性问题
- zepto点击事件兼容pc和mobile
- 【中级软考】UML图(Unified Modeling Language统一建模语言、标准建模语言)
- linux进程被中断打断,linux – 当中断处理程序被另一个中断中断时,中断上下文如何“恢复”?...
- 【译】A Beginner-Friendly Introduction to Containers, VMs and Docker
- 日周月筛选器_举个栗子!Tableau 技巧(147):使用 动态参数 筛选到最新日期值...
- Android之TypedArray 为什么需要调用recycle()
- SSH连接远程服务器,本地known_hosts文件记录了什么
- ffmpeg 解码视频(h264、mpeg2)输出yuv420p文件
- LEADTOOLS概览
- 是什么计算机接入网络的接口设备,什么是计算机接入网络的接口设备
- Python 调度算法 死锁 静动态链接 分页分段(七)
- LeetCode 437. 路径总和 III
- 58移动开发 App 工厂
- SMB/CIFS--NetBOIS/Browser/NBNS 协议
- nginx负载均衡的5种策略及原理
- Java中文繁简体转换工具
- 张靓颖同学2006年日程表
- pmp知识点(12)-项目采购管理
热门文章
- CSS keylogger:攻击与防御
- 《ASP.NET MVC企业实战》(二) MVC开发前奏
- 二维树状数组 BZOJ 1452 [JSOI2009]Count
- 【字符串处理算法】最长连续字符及其出现次数的算法设计及C代码实现
- 我的 FPGA 学习历程(11)—— 实验:按键消抖
- 自定义的 ListBoxItem 自适应ListBox的宽度
- 重力感应的测试程序andriod源代码
- 在Visual Studio 2010 里使用Nunit 进行Debug 测试
- 分不清的InputStream和OutputStream
- 瑞士的迷人风光(转)