MySQL---数据库从入门走向大神系列(十七)-JavaWeb分页技术实例演示2

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: MySQL---数据库从入门走向大神系列(十七)-JavaWeb分页技术实例演示2

分页,是一种将所有数据分段展示给用户的技术.用户每次看到的不 是全部数据,而是其中的一部分,如果在其中没有找到自己想要的内容,用户可以通过指定页码或是点上/下一页的方式进行翻页。

本例演示静态分页,也就是先设置好每页显示10行,再根据总行数,来算出总页数,并且只显示10个页码。增加查询功能,并且查询后的页面也进行分页。页码也进行分页 !

查询功能的实现,需要我们在servlet向后台传输一个person,封装我们的查询条件

相关算法(技术):

总行数(num): select count(1) from stud;
每页显示的行数(n): 固定值---已知的一个常量
页数: pageSize= num/n +( (num%n==0)?0:1 )
当前页号: currentPage
当前要显示的页面数据的起始行号和终止行号
startN: (currentPage-1)*pageSize
如何显示从startN开始的pageSize条记录
select * from stud limit startN, pageSize;
增加了:
开始的页码:
showStart
结束的页码:
showEnd

像这样:

image.png

数据库数据:

创建的数据库表,还有需要准备的jar包,请看本篇博客:

http://blog.csdn.net/qq_26525215/article/details/52222472

源码:

PageJdbc.java

package cn.hncu.dao;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import cn.hncu.domain.Person;
import cn.hncu.pubs.C3p0Pool;
public class PageJdbc implements IPageDAO {
    private final int pageSize = 10;// 每页显示的行数
    @Override
    public Map<String, Object> query(Integer pageNo, Person person)
            throws NumberFormatException, SQLException {
        Map<String, Object> result = new HashMap<String, Object>();
        // 获取总页数 pageCount = rows/pageSize + ( (rows%pageSize==0)?0:1 )
        // 总行数rows
        String sql = "select count(1) from person where 1=1 ";// 用来查总行数
        String sql2 = "select * from person where 1=1 ";// 用来查表内容
        if (person.getId() != null && person.getId().trim().length() != 0) {
            sql = sql + "and id like '%" + person.getId() + "%'";
            sql2 = sql2 + "and id like '%" + person.getId() + "%'";
        }
        if (person.getName() != null && person.getName().trim().length() != 0) {
            sql = sql + "and name like '%" + person.getName() + "%'";
            sql2 = sql2 + "and name like '%" + person.getName() + "%'";
        }
        //System.out.println(sql2);
        QueryRunner run = new QueryRunner(C3p0Pool.getDataSource());
        int rows = Integer.parseInt("" + run.query(sql, new ScalarHandler()));
        // 总页数
        int pageCount = rows / pageSize + ((rows % pageSize == 0) ? 0 : 1);
        result.put("pageCount", pageCount);// 封装到result
        // 分页页面内容datas
        // 起始行号
        int startN = (pageNo - 1) * pageSize;
        sql2 = sql2+ " limit "+startN+", "+pageSize;
        List<Map<String, Object>> datas = run.query(sql2, new MapListHandler());
        result.put("datas", datas);//封装到result
        return result;
    }
}

PageServlet.java

package cn.hncu.servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.SQLException;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import cn.hncu.domain.Person;
import cn.hncu.service.IPageService;
import cn.hncu.service.PageServiceImpl;
public class PageServlet extends HttpServlet {
    //注入servlet
    IPageService service = new PageServiceImpl();
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        doPost(request, response);
    }
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        request.setCharacterEncoding("utf-8");
        String pageNo = request.getParameter("page");
        if(pageNo==null || pageNo.trim().length()==0){
            pageNo = "1";
        }
        Integer iPageNo =1;
        try {
            iPageNo = Integer.parseInt(pageNo);
        } catch (NumberFormatException e) {
            request.getRequestDispatcher(request.getContextPath()+"/index.jsp").forward(request, response);
        }
        Person person =null;
        //区分是Post还是GET方式请求,前者是新的查询,后者是原查询结果中进行翻页
        if(request.getMethod().equalsIgnoreCase("get")){//翻页
            //从session中把旧的查询条件值对象取出来
            person = (Person) request.getSession().getAttribute("person");
            if(person==null){//没有进行第一次查询之前,person就是需要我们new出来一个空的
                person = new Person();
            }
        }else{//POST方式---新的查询
            //收集模糊查询的输入参数
            String id = request.getParameter("id");
            String name = request.getParameter("name");
            person = new Person();
            person.setId(id);
            person.setName(name);
            //放入session,这样下一次翻页才能读取出来
            request.getSession().setAttribute("person", person);
        }
        try {
            Map<String, Object> result = service.query(iPageNo, person);
            //给结果集补一个数据:currentPage --当前页号
            result.put("currentPage", iPageNo);
            //把结果集放入容器中
            request.setAttribute("result", result);
            //分页后的分页--向前端多传送两个数据(起始和末尾页号):showStart和showEnd
            int showSize=10;//每页显示几行
            int showStart=0;//从第几个页号开始显示
            int showEnd=0;//显示到第几个页号
            //pageCount---总页数
            //如果所有页码不足showSize:  showStart=1,showEnd=pageCount
            int pageCount = Integer.parseInt(""+result.get("pageCount"));
            if(pageCount<=showSize){//不需要二次分页
                showStart=1;
                showEnd=pageCount;
            }else{//需要二次分页
                //如果当前页号iPageNo<=showSize/2时,showStart=1
                if(iPageNo<=showSize/2){
                    showStart=1;
                    showEnd=showSize;
                }else{
                    showStart = iPageNo - showSize/2;
                    showEnd = showStart + showSize-1;
                }
                if(showEnd>pageCount){
                    showEnd=pageCount;
                    showStart = showEnd-showSize-1;
                }
            }
            //存储showStart和showEnd
            request.setAttribute("showStart", showStart);
            request.setAttribute("showEnd", showEnd);
            //转到结果页面
            request.getRequestDispatcher("/jsps/show.jsp").forward(request, response);
        } catch (NumberFormatException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

show.jsp

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <title>演示数据分页</title>
    <link rel="stylesheet" href="<c:url value='/css/table.css' />" />
    <script type="text/javascript">
        function sub(obj){
            window.location.href="<c:url value='/PageServlet?page=' />"+obj.value;
        }
    </script>
  </head>
  <body>
     <h3>数据查询</h3>
     <form action="<c:url value='/PageServlet'/>" method="post">
            ID:<input type="text" name="id" value="${person.id }"> &nbsp;
            姓名:<input type="text" name="name" value="${person.name }" > &nbsp;&nbsp;
            <input type="submit" value="模糊查询">
     </form>
    <h3>当前页的内容:</h3>
    <table>
        <tr><th>学号</th><th>姓名</th><th>地址</th><th>年龄</th></tr>
        <c:forEach items="${result.datas}" var="map">
            <tr>
                <td>${map.id}</td>
                <td>${map.name}</td>
                <td>${map.address}</td>
                <td>${map.age}</td>
            </tr>
        </c:forEach>
    </table>
    <c:if test="${result.currentPage!=1}">
        <span class="pc">
            <a href='<c:url value="/PageServlet?page=${result.currentPage-1}"></c:url>'>上一页</a>
        </span>
    </c:if>
    &nbsp;&nbsp;
    <c:forEach begin="${showStart}" end="${showEnd}" var="idx">
        <c:if test="${idx==result.currentPage}" var="isNow">
            <span class=now>${idx}</span>
        </c:if>         
        <c:if test="${!isNow }">
            <span class="pc">
                <a href='<c:url value="/PageServlet?page=${idx}"></c:url>'>${idx}</a>
            </span>
        </c:if>
        &nbsp;&nbsp;
    </c:forEach>
    <c:if test="${result.currentPage!=result.pageCount}">
        <span class="pc">
            <a href="<c:url value='/PageServlet?page=${result.currentPage+1}'></c:url>">下一页</a>
        </span>
    </c:if>
    <br/><br/>
    <!-- 复选框 -->
    <select onchange="sub(this)">
        <c:forEach begin="1" end="${result.pageCount}" var="idx">
            <option <c:if test="${idx==result.currentPage}">selected="selected"</c:if> value="${idx}" >
                第${idx}页
            </option>
        </c:forEach>
    </select>
  </body>
</html>

演示结果:

image.png

整个项目源码链接:

https://github.com/chenhaoxiang/Java/tree/master/myPagesDividedWeb2

myPagesDividedWeb2.zip文件

转载请附上原文博客链接:  

http://blog.csdn.net/qq_26525215

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
13天前
|
存储 Oracle 关系型数据库
数据库传奇:MySQL创世之父的两千金My、Maria
《数据库传奇:MySQL创世之父的两千金My、Maria》介绍了MySQL的发展历程及其分支MariaDB。MySQL由Michael Widenius等人于1994年创建,现归Oracle所有,广泛应用于阿里巴巴、腾讯等企业。2009年,Widenius因担心Oracle收购影响MySQL的开源性,创建了MariaDB,提供额外功能和改进。维基百科、Google等已逐步替换为MariaDB,以确保更好的性能和社区支持。掌握MariaDB作为备用方案,对未来发展至关重要。
39 3
|
13天前
|
安全 关系型数据库 MySQL
MySQL崩溃保险箱:探秘Redo/Undo日志确保数据库安全无忧!
《MySQL崩溃保险箱:探秘Redo/Undo日志确保数据库安全无忧!》介绍了MySQL中的三种关键日志:二进制日志(Binary Log)、重做日志(Redo Log)和撤销日志(Undo Log)。这些日志确保了数据库的ACID特性,即原子性、一致性、隔离性和持久性。Redo Log记录数据页的物理修改,保证事务持久性;Undo Log记录事务的逆操作,支持回滚和多版本并发控制(MVCC)。文章还详细对比了InnoDB和MyISAM存储引擎在事务支持、锁定机制、并发性等方面的差异,强调了InnoDB在高并发和事务处理中的优势。通过这些机制,MySQL能够在事务执行、崩溃和恢复过程中保持
42 3
|
13天前
|
SQL 关系型数据库 MySQL
数据库灾难应对:MySQL误删除数据的救赎之道,技巧get起来!之binlog
《数据库灾难应对:MySQL误删除数据的救赎之道,技巧get起来!之binlog》介绍了如何利用MySQL的二进制日志(Binlog)恢复误删除的数据。主要内容包括: 1. **启用二进制日志**:在`my.cnf`中配置`log-bin`并重启MySQL服务。 2. **查看二进制日志文件**:使用`SHOW VARIABLES LIKE &#39;log_%&#39;;`和`SHOW MASTER STATUS;`命令获取当前日志文件及位置。 3. **创建数据备份**:确保在恢复前已有备份,以防意外。 4. **导出二进制日志为SQL语句**:使用`mysqlbinlog`
54 2
|
27天前
|
关系型数据库 MySQL 数据库
Python处理数据库:MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库,包括安装必要的库、连接数据库、执行增删改查等基本操作,适合初学者快速上手。
184 15
|
20天前
|
SQL 关系型数据库 MySQL
数据库数据恢复—Mysql数据库表记录丢失的数据恢复方案
Mysql数据库故障: Mysql数据库表记录丢失。 Mysql数据库故障表现: 1、Mysql数据库表中无任何数据或只有部分数据。 2、客户端无法查询到完整的信息。
|
27天前
|
关系型数据库 MySQL 数据库
数据库数据恢复—MYSQL数据库文件损坏的数据恢复案例
mysql数据库文件ibdata1、MYI、MYD损坏。 故障表现:1、数据库无法进行查询等操作;2、使用mysqlcheck和myisamchk无法修复数据库。
|
1月前
|
SQL 关系型数据库 MySQL
MySQL导入.sql文件后数据库乱码问题
本文分析了导入.sql文件后数据库备注出现乱码的原因,包括字符集不匹配、备注内容编码问题及MySQL版本或配置问题,并提供了详细的解决步骤,如检查和统一字符集设置、修改客户端连接方式、检查MySQL配置等,确保导入过程顺利。
|
2月前
|
关系型数据库 MySQL 数据库
GBase 数据库如何像MYSQL一样存放多行数据
GBase 数据库如何像MYSQL一样存放多行数据
|
2月前
|
SQL 关系型数据库 MySQL
12 PHP配置数据库MySQL
路老师分享了PHP操作MySQL数据库的方法,包括安装并连接MySQL服务器、选择数据库、执行SQL语句(如插入、更新、删除和查询),以及将结果集返回到数组。通过具体示例代码,详细介绍了每一步的操作流程,帮助读者快速入门PHP与MySQL的交互。
48 1
|
2月前
|
SQL 关系型数据库 MySQL
go语言数据库中mysql驱动安装
【11月更文挑战第2天】
75 4