在JSP中如何实现分页技术啊?

Posted 2023-04-21

哪个大哥,大姐帮我解决这个问题啊,在JSP技术中实现分页.我QQ是17777406

title: JSP分页技术实现
summary:使用工具类实现通用分页处理
author: evan_zhao
email: [e-mail]

目前比较广泛使用的分页方式是将查询结果缓存在HttpSession或有状态bean中，翻页的时候从缓存中取出一页数据显示。这种方法有两个主要的缺点：一是用户可能看到的是过期数据；二是如果数据量非常大时第一次查询遍历结果集会耗费很长时间，并且缓存的数据也会占用大量内存，效率明显下降。
其它常见的方法还有每次翻页都查询一次数据库，从ResultSet中只取出一页数据（使用rs.last();rs.getRow()获得总计录条数，使用rs.absolute()定位到本页起始记录）。这种方式在某些数据库(如oracle)的JDBC实现中差不多也是需要遍历所有记录，实验证明在记录数很大时速度非常慢。
至于缓存结果集ResultSet的方法则完全是一种错误的做法。因为ResultSet在Statement或Connection关闭时也会被关闭，如果要使ResultSet有效势必长时间占用数据库连接。

因此比较好的分页做法应该是每次翻页的时候只从数据库里检索页面大小的块区的数据。这样虽然每次翻页都需要查询数据库，但查询出的记录数很少，网络传输数据量不大，如果使用连接池更可以略过最耗时的建立数据库连接过程。而在数据库端有各种成熟的优化技术用于提高查询速度，比在应用服务器层做缓存有效多了。

在oracle数据库中查询结果的行号使用伪列ROWNUM表示（从1开始）。例如select * from employee where rownum<10 返回前10条记录。但因为rownum是在查询之后排序之前赋值的，所以查询employee按birthday排序的第100到120条记录应该这么写：
[pre] select * from (
select my_table.*, rownum as my_rownum from (
select name, birthday from employee order by birthday
) my_table where rownum <120
) where my_rownum>=100
[/pre]
mysql可以使用LIMIT子句：
select name, birthday from employee order by birthday LIMIT 99,20
DB2有rownumber()函数用于获取当前行数。
SQL Server没研究过，可以参考这篇文章：http://www.csdn.net/develop/article/18/18627.shtm

在Web程序中分页会被频繁使用，但分页的实现细节却是编程过程中比较麻烦的事情。大多分页显示的查询操作都同时需要处理复杂的多重查询条件，sql语句需要动态拼接组成，再加上分页需要的记录定位、总记录条数查询以及查询结果的遍历、封装和显示，程序会变得很复杂并且难以理解。因此需要一些工具类简化分页代码，使程序员专注于业务逻辑部分。下面是我设计的两个工具类：
PagedStatement 封装了数据库连接、总记录数查询、分页查询、结果数据封装和关闭数据库连接等操作，并使用了PreparedStatement支持动态设置参数。
RowSetPage 参考PetStore的page by page iterator模式， 设计RowSetPage用于封装查询结果（使用OracleCachedRowSet缓存查询出的一页数据，关于使用CachedRowSet封装数据库查询结果请参考JSP页面查询显示常用模式）以及当前页码、总记录条数、当前记录数等信息， 并且可以生成简单的html分页代码。
PagedStatement 查询的结果封装成RowsetPage。

下面是简单的使用示例：

//DAO查询数据部分代码：
…
public RowSetPage getEmployee(String gender, int pageNo) throws Exception
String sql="select emp_id, emp_code, user_name, real_name from employee where gender =?";
//使用Oracle数据库的分页查询实现,每页显示5条
PagedStatement pst =new PagedStatementOracleImpl(sql, pageNo, 5);
pst.setString(1, gender);
return pst.executeQuery();


//Servlet处理查询请求部分代码：

…
int pageNo;
try
//可以通过参数pageno获得用户选择的页码
pageNo = Integer.parseInt(request.getParameter("pageno") );
catch(Exception ex)
//默认为第一页
pageNo=1;

String gender = request.getParameter("gender" );
request.setAttribute("empPage", myBean.getEmployee(gender, pageNo) );
…

//JSP显示部分代码
<%@ page import = "page.RowSetPage"%>
…
<script language="javascript">
function doQuery()
form1.actionType.value="doQuery";
form1.submit();

</script>
…
<form name=form1 method=get>
<input type=hidden name=actionType>
性别：
<input type=text name=gender size=1 value="<%=request.getParameter("gender")%>">
<input type=button value=" 查询 " onclick="doQuery()">
<%
RowSetPage empPage = (RowSetPage)request.getAttribute("empPage");
if (empPage == null ) empPage = RowSetPage.EMPTY_PAGE;
%>
…
<table cellspacing="0" width="90%">
<tr> <td>ID</td> <td>代码</td> <td>用户名</td> <td>姓名</td> </tr>
<%
javax.sql.RowSet empRS = (javax.sql.RowSet) empPage.getRowSet();
if (empRS!=null) while (empRS.next() )
%>
<tr>
<td><%= empRS.getString("EMP_ID")%></td>
<td><%= empRS.getString("EMP_CODE")%></td>
<td><%= empRS.getString("USER_NAME")%></td>
<td><%= empRS.getString("REAL_NAME")%></td>
</tr>
<%
// end while
%>
<tr>
<%
//显示总页数和当前页数(pageno)以及分页代码。
//此处doQuery为页面上提交查询动作的javascript函数名， pageno为标识当前页码的参数名
%>
<td colspan=4><%= empPage .getHTML("doQuery", "pageno")%></td>
</tr>
</table>
</form>

效果如图：

因为分页显示一般都会伴有查询条件和查询动作，页面应已经有校验查询条件和提交查询的javascript方法（如上面的doQuery），所以RowSetPage.getHTML()生成的分页代码在用户选择新页码时直接回调前面的处理提交查询的javascript方法。注意在显示查询结果的时候上次的查询条件也需要保持，如<input type=text name=gender size=1 value="<%=request.getParameter("gender")%>">。同时由于页码的参数名可以指定，因此也支持在同一页面中有多个分页区。
另一种分页代码实现是生成每一页的URL，将查询参数和页码作为QueryString附在URL后面。这种方法的缺陷是在查询条件比较复杂时难以处理，并且需要指定处理查询动作的servlet，可能不适合某些定制的查询操作。
如果对RowSetPage.getHTML()生成的默认分页代码不满意可以编写自己的分页处理代码，RowSetPage提供了很多getter方法用于获取相关信息（如当前页码、总页数、 总记录数和当前记录数等）。
在实际应用中可以将分页查询和显示做成jsp taglib， 进一步简化JSP代码，屏蔽Java Code。

附：分页工具类的源代码， 有注释，应该很容易理解。

1.Page.java
2.RowSetPage.java(RowSetPage继承Page)
3.PagedStatement.java
4.PagedStatementOracleImpl.java(PagedStatementOracleImpl继承PagedStatement)

您可以任意使用这些源代码，但必须保留author [e-mail]字样

///////////////////////////////////
//
// Page.java
// author: [e-mail]
//
///////////////////////////////////

package page;

import java.util.List;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;

/**
* Title: 分页对象<br>
* Description: 用于包含数据及分页信息的对象<br>
* Page类实现了用于显示分页信息的基本方法，但未指定所含数据的类型，
* 可根据需要实现以特定方式组织数据的子类，<br>
* 如RowSetPage以RowSet封装数据，ListPage以List封装数据<br>
* Copyright: Copyright (c) 2002 <br>
* @author [e-mail] <br>
* @version 1.0
*/
public class Page implements java.io.Serializable
public static final Page EMPTY_PAGE = new Page();
public static final int DEFAULT_PAGE_SIZE = 20;
public static final int MAX_PAGE_SIZE = 9999;

private int myPageSize = DEFAULT_PAGE_SIZE;

private int start;
private int avaCount,totalSize;
private Object data;

private int currentPageno;
private int totalPageCount;

/**
* 默认构造方法，只构造空页
*/
protected Page()
this.init(0,0,0,DEFAULT_PAGE_SIZE,new Object());


/**
* 分页数据初始方法，由子类调用
* @param start 本页数据在数据库中的起始位置
* @param avaCount 本页包含的数据条数
* @param totalSize 数据库中总记录条数
* @param pageSize 本页容量
* @param data 本页包含的数据
*/
protected void init(int start, int avaCount, int totalSize, int pageSize, Object data)

this.avaCount =avaCount;
this.myPageSize = pageSize;

this.start = start;
this.totalSize = totalSize;

this.data=data;

//System.out.println("avaCount:"+avaCount);
//System.out.println("totalSize:"+totalSize);
if (avaCount>totalSize)
//throw new RuntimeException("记录条数大于总条数？！");


this.currentPageno = (start -1)/pageSize +1;
this.totalPageCount = (totalSize + pageSize -1) / pageSize;

if (totalSize==0 && avaCount==0)
this.currentPageno = 1;
this.totalPageCount = 1;

//System.out.println("Start Index to Page No: " + start + "-" + currentPageno);


public Object getData()
return this.data;


/**
* 取本页数据容量（本页能包含的记录数）
* @return 本页能包含的记录数
*/
public int getPageSize()
return this.myPageSize;


/**
* 是否有下一页
* @return 是否有下一页
*/
public boolean hasNextPage()
/*
if (avaCount==0 && totalSize==0)
return false;

return (start + avaCount -1) < totalSize;
*/
return (this.getCurrentPageNo()<this.getTotalPageCount());


/**
* 是否有上一页
* @return 是否有上一页
*/
public boolean hasPreviousPage()
/*
return start > 1;
*/
return (this.getCurrentPageNo()>1);


/**
* 获取当前页第一条数据在数据库中的位置
* @return
*/
public int getStart()
return start;


/**
* 获取当前页最后一条数据在数据库中的位置
* @return
*/
public int getEnd()
int end = this.getStart() + this.getSize() -1;
if (end<0)
end = 0;

return end;


/**
* 获取上一页第一条数据在数据库中的位置
* @return 记录对应的rownum
*/
public int getStartOfPreviousPage()
return Math.max(start-myPageSize, 1);


/**
* 获取下一页第一条数据在数据库中的位置
* @return 记录对应的rownum
*/
public int getStartOfNextPage()
return start + avaCount;


/**
* 获取任一页第一条数据在数据库中的位置，每页条数使用默认值
* @param pageNo 页号
* @return 记录对应的rownum
*/
public static int getStartOfAnyPage(int pageNo)
return getStartOfAnyPage(pageNo, DEFAULT_PAGE_SIZE);


/**
* 获取任一页第一条数据在数据库中的位置
* @param pageNo 页号
* @param pageSize 每页包含的记录数
* @return 记录对应的rownum
*/
public static int getStartOfAnyPage(int pageNo, int pageSize)
int startIndex = (pageNo-1) * pageSize + 1;
if ( startIndex < 1) startIndex = 1;
//System.out.println("Page No to Start Index: " + pageNo + "-" + startIndex);
return startIndex;


/**
* 取本页包含的记录数
* @return 本页包含的记录数
*/
public int getSize()
return avaCount;


/**
* 取数据库中包含的总记录数
* @return 数据库中包含的总记录数
*/
public int getTotalSize()
return this.totalSize;


/**
* 取当前页码
* @return 当前页码
*/
public int getCurrentPageNo()
return this.currentPageno;


/**
* 取总页码
* @return 总页码
*/
public int getTotalPageCount()
return this.totalPageCount;


/**
*
* @param queryJSFunctionName 实现分页的JS脚本名字，页码变动时会自动回调该方法
* @param pageNoParamName 页码参数名称
* @return
*/
public String getHTML(String queryJSFunctionName, String pageNoParamName)
if (getTotalPageCount()<1)
return "<input type='hidden' name='"+pageNoParamName+"' value='1' >";

if (queryJSFunctionName == null || queryJSFunctionName.trim().length()<1)
queryJSFunctionName = "gotoPage";

if (pageNoParamName == null || pageNoParamName.trim().length()<1)
pageNoParamName = "pageno";


String gotoPage = "_"+queryJSFunctionName;

StringBuffer html = new StringBuffer("\n");
html.append("<script language=\"Javascript1.2\">\n")
.append("function ").append(gotoPage).append("(pageNo) \n")
.append( " var curPage=1; \n")
.append( " try curPage = document.all[\"")
.append(pageNoParamName).append("\"].value; \n")
.append( " document.all[\"").append(pageNoParamName)
.append("\"].value = pageNo; \n")
.append( " ").append(queryJSFunctionName).append("(pageNo); \n")
.append( " return true; \n")
.append( " catch(e) \n")
// .append( " try \n")
// .append( " document.forms[0].submit(); \n")
// .append( " catch(e) \n")
.append( " alert('尚未定义查询方法：function ")
.append(queryJSFunctionName).append("()'); \n")
.append( " document.all[\"").append(pageNoParamName)
.append("\"].value = curPage; \n")
.append( " return false; \n")
// .append( " \n")
.append( " \n")
.append( "")
.append( "</script> \n")
.append( "");
html.append( "<table border=0 cellspacing=0 cellpadding=0 align=center width=80%> \n")
.append( " <tr> \n")
.append( " <td align=left><br> \n");
html.append( " 共" ).append( getTotalPageCount() ).append( "页")
.append( " [") .append(getStart()).append("..").append(getEnd())
.append("/").append(this.getTotalSize()).append("] \n")
.append( " </td> \n")
.append( " <td align=right> \n");
if (hasPreviousPage())
html.append( "[<a href='javascript:").append(gotoPage)
.append("(") .append(getCurrentPageNo()-1)
.append( ")'>上一页</a>] \n");

html.append( " 第")
.append( " <select name='")
.append(pageNoParamName).append("' onChange='javascript:")
.append(gotoPage).append("(this.value)'>\n");
String selected = "selected";
for(int i=1;i<=getTotalPageCount();i++)
if( i == getCurrentPageNo() )
selected = "selected";
else selected = "";
html.append( " <option value='").append(i).append("' ")
.append(selected).append(">").append(i).append("</option> \n");

if (getCurrentPageNo()>getTotalPageCount())
html.append( " <option value='").append(getCurrentPageNo())
.append("' selected>").append(getCurrentPageNo())
.append("</option> \n");

html.append( " </select>页 \n");
if (hasNextPage())
html.append( " [<a href='javascript:").append(gotoPage)
.append("(").append((getCurrentPageNo()+1))
.append( ")'>下一页</a>] \n");

html.append( "</td></tr></table> \n");

return html.toString();




///////////////////////////////////
//
// RowSetPage.java
// author: [e-mail]
//
///////////////////////////////////
package page;

import javax.sql.RowSet;

/**
* <p>Title: RowSetPage</p>
* <p>Description: 使用RowSet封装数据的分页对象</p>
* <p>Copyright: Copyright (c) 2003</p>
* @author [e-mail]
* @version 1.0
*/

public class RowSetPage extends Page
private javax.sql.RowSet rs;

/**
*空页
*/
public static final RowSetPage EMPTY_PAGE = new RowSetPage();

/**
*默认构造方法，创建空页
*/
public RowSetPage()
this(null, 0,0);


/**
*构造分页对象
*@param crs 包含一页数据的OracleCachedRowSet
*@param start 该页数据在数据库中的起始位置
*@param totalSize 数据库中包含的记录总数
*/
public RowSetPage(RowSet crs, int start, int totalSize)
this(crs,start,totalSize,Page.DEFAULT_PAGE_SIZE);


/**
*构造分页对象
*@param crs 包含一页数据的OracleCachedRowSet
*@param start 该页数据在数据库中的起始位置
*@param totalSize 数据库中包含的记录总数
*@pageSize 本页能容纳的记录数
*/
public RowSetPage(RowSet crs, int start, int totalSize, int pageSize)
try
int avaCount=0;
if (crs!=null)
crs.beforeFirst();
if (crs.next())
crs.last();
avaCount = crs.getRow();

crs.beforeFirst();

rs = crs;
super.init(start,avaCount,totalSize,pageSize,rs);
catch(java.sql.SQLException sqle)
throw new RuntimeException(sqle.toString());



/**
*取分页对象中的记录数据
*/
public javax.sql.RowSet getRowSet()
return rs;




///////////////////////////////////
//
// PagedStatement.java
// author: [e-mail]
//
///////////////////////////////////

package page;

import foo.DBUtil;

import java.math.BigDecimal;
import java.util.List;
import java.util.Iterator;
import java.util.Collections;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.Timestamp;
import javax.sql.RowSet;

/**
* <p>Title: 分页查询</p>
* <p>Description: 根据查询语句和页码查询出当页数据</p>
* <p>Copyright: Copyright (c) 2002</p>
* @author [e-mail]
* @version 1.0
*/
public abstract class PagedStatement
public final static int MAX_PAGE_SIZE = Page.MAX_PAGE_SIZE;

protected String countSQL, querySQL;
protected int pageNo,pageSize,startIndex,totalCount;
protected javax.sql.RowSet rowSet;
protected RowSetPage rowSetPage;

private List boundParams;

/**
* 构造一查询出所有数据的PageStatement
* @param sql query sql
*/
public PagedStatement(String sql)
this(sql,1,MAX_PAGE_SIZE);


/**
* 构造一查询出当页数据的PageStatement
* @param sql query sql
* @param pageNo 页码
*/
public PagedStatement(String sql, int pageNo)
this(sql, pageNo, Page.DEFAULT_PAGE_SIZE);


/**
* 构造一查询出当页数据的PageStatement，并指定每页显示记录条数
* @param sql query sql
* @param pageNo 页码
* @param pageSize 每页容量
*/
public PagedStatement(String sql, int pageNo, int pageSize)
this.pageNo = pageNo;
this.pageSize = pageSize;
this.startIndex = Page.getStartOfAnyPage(pageNo, pageSize);
this.boundParams = Collections.synchronizedList(new java.util.LinkedList());

this.countSQL = "select count(*) from ( " + sql +") ";
this.querySQL = intiQuerySQL(sql, this.startIndex, pageSize);


/**
*生成查询一页数据的sql语句
*@param sql 原查询语句
*@startIndex 开始记录位置
*@size 需要获取的记录数
*/
protected abstract String intiQuerySQL(String sql, int startIndex, int size);

/**
*使用给出的对象设置指定参数的值
*@param index 第一个参数为1，第二个为2 参考技术A 处理方式：一：首先sql语句，使用not in的方式处理，

在dao类里写一个方法

public List<> getAllByPage(int pageSize,pageNum)

......

String sql="select top"+pageSize +" * from 表名x where 字段A not in (select top "+pageSize*(pageNum-1)+" 字段A from 表名x)";

.......

rerun list;



其中，pageSize是页面要显示的条数，pageNum是要显示的页码,sql语句是固定的,返回一个list对象。

二：在Biz里写一个方法，调用Dao里的getAllByPage方法，传入两个参数，返回list结果集。

三：在jsp页面以url传参的方式进行页面处理和数据的显示。

使用request对象获取传入的值，进行强制类型转作为参数，传入到Biz业务类的方法中处理，返回list结果集，使用表达式的方式在页面中进行显示。 参考技术B 和ASP其实是一个道理。

jsp分页技术

　　如果一张表的数据有非常多，页面就需要分页展示，但一次性从数据库中读取全部的数据会给服务器带来巨大压力。jsp分页技术的设计思想来源于“select * from employee limit ?,?”这条sql语句，第一个“？”指查询的起始位置，第二个“？”代表偏移量。页面需要展示多少数据，每次就从服务器读取多少数据，大大减轻了服务器的压力。下面开始实现一个javaweb的demo帮助大家更好的理解。

 

一.准备工作：

　　MySQL中创建一张用例表

CREATE TABLE employee(
    empId INT PRIMARY KEY AUTO_INCREMENT,
    empName VARCHAR(20),
    dept_id VARCHAR(20)
);

　　往里面插入足够的数据（20条就够了）

二.demo采用mvc模式，首先编写JSP页面

　　表格代码如下

<table border="1" width="80%" align="center" cellpadding="5" cellspacing="0">
          <tr>
              <td>序号</td>
              <td>员工编号</td>
              <td>员工姓名</td>
          </tr>
          <!-- 迭代数据 -->
          <c:choose>
              <c:when test="${not empty requestScope.pageBean.pageData}">
                  <c:forEach var="emp" items="${requestScope.pageBean.pageData}" varStatus="vs">
                      <tr>
                          <td>${vs.count }</td>
                          <td>${emp.empId }</td>
                          <td>${emp.empName }</td>
                      </tr>
                  </c:forEach>
              </c:when>
              <c:otherwise>
                  <tr>
                      <td colspan="3">对不起，没有你要找的数据</td>
                  </tr>
              </c:otherwise>
          </c:choose>
          
          <tr>
              <td colspan="3" align="center">
                  当前${requestScope.pageBean.currentPage }/${requestScope.pageBean.totalPage }页     &nbsp;&nbsp;
                  
                  <a href="${pageContext.request.contextPath }/index?currentPage=1">首页</a>
                  <a href="${pageContext.request.contextPath }/index?currentPage=${requestScope.pageBean.currentPage-1}">上一页 </a>
                  <a href="${pageContext.request.contextPath }/index?currentPage=${requestScope.pageBean.currentPage+1}">下一页 </a>
                  <a href="${pageContext.request.contextPath }/index?currentPage=${requestScope.pageBean.totalPage}">末页</a>
              </td>
          </tr>
          
      </table>

View Code

三.表对应实体类的设计，分页的几个重要参数也封装到一个实体类里

package cn.cracker.entity;

public class Employee {

    private int empId;            // 员工id
    private String empName;        // 员工名称
    private int dept_id;        // 部门id
    
    public int getEmpId() {
        return empId;
    }
    public void setEmpId(int empId) {
        this.empId = empId;
    }
    public String getEmpName() {
        return empName;
    }
    public void setEmpName(String empName) {
        this.empName = empName;
    }
    public int getDept_id() {
        return dept_id;
    }
    public void setDept_id(int deptId) {
        dept_id = deptId;
    }
    
    
}

View Code

package cn.cracker.utils;

import java.util.List;

import cn.cracker.entity.Employee;

public class PageBean<T> {
    private int currentPage = 1; // 当前页, 默认显示第一页
    private int pageCount = 4;   // 每页显示的行数(查询返回的行数), 默认每页显示4行
    private int totalCount;      // 总记录数
    private int totalPage;       // 总页数 = 总记录数 / 每页显示的行数  (+ 1)
    private List<T> pageData;       // 分页查询到的数据
    
    // 返回总页数
    public int getTotalPage() {
        if (totalCount % pageCount == 0) {
            totalPage = totalCount / pageCount;
        } else {
            totalPage = totalCount / pageCount + 1;
        }
        return totalPage;
    }
    public void setTotalPage(int totalPage) {
        this.totalPage = totalPage;
    }
    
    public int getCurrentPage() {
        return currentPage;
    }
    public void setCurrentPage(int currentPage) {
        this.currentPage = currentPage;
    }
    public int getPageCount() {
        return pageCount;
    }
    public void setPageCount(int pageCount) {
        this.pageCount = pageCount;
    }
    public int getTotalCount() {
        return totalCount;
    }
    public void setTotalCount(int totalCount) {
        this.totalCount = totalCount;
    }
    
    public List<T> getPageData() {
        return pageData;
    }
    public void setPageData(List<T> pageData) {
        this.pageData = pageData;
    }
    
    

}

View Code

四.DbUtils和C3p0配置文件

package cn.cracker.utils;

import javax.sql.DataSource;

import org.apache.commons.dbutils.QueryRunner;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 * 工具类
 */
public class JdbcUtils {

    /**
     *  1. 初始化C3P0连接池
     */
    private static  DataSource dataSource;
    static {
        dataSource = new ComboPooledDataSource();
    }
    
    /**
     * 2. 创建DbUtils核心工具类对象
     */
    public static QueryRunner getQueryRuner(){

        return new QueryRunner(dataSource);
    }
}

View Code

<c3p0-config>
    <default-config>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc_demo
        </property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="initialPoolSize">3</property>
        <property name="maxPoolSize">6</property>
        <property name="maxIdleTime">1000</property>
    </default-config>


    <named-config name="oracle_config">
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc_demo</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="initialPoolSize">3</property>
        <property name="maxPoolSize">6</property>
        <property name="maxIdleTime">1000</property>
    </named-config>


</c3p0-config>

View Code

五.数据库访问层的设计(包含接口与实现)

　　实现查询分页的数据和总数据两个功能

package cn.cracker.dao;

import cn.cracker.entity.Employee;
import cn.cracker.utils.PageBean;

public interface IEmployeeDao {

    public void getAll(PageBean<Employee> pb);
    
    public int getTotalCount();
}

View Code

package cn.cracker.dao.impl;

import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;

import cn.cracker.dao.IEmployeeDao;
import cn.cracker.entity.Employee;
import cn.cracker.utils.JdbcUtils;
import cn.cracker.utils.PageBean;

/**
 * 2. 数据访问层实现
 */
public class EmployeeDao implements IEmployeeDao {

    @Override
    public void getAll(PageBean<Employee> pb) {
        
        //2. 查询总记录数;  设置到pb对象中
        int totalCount = this.getTotalCount();
        pb.setTotalCount(totalCount);
        
        /*
         * 问题： jsp页面，如果当前页为首页，再点击上一页报错！
         *              如果当前页为末页，再点下一页显示有问题！
         * 解决：
         *        1. 如果当前页 <= 0;       当前页设置当前页为1;
         *        2. 如果当前页 > 最大页数；  当前页设置为最大页数
         */
        // 判断
        if (pb.getCurrentPage() <=0) {
            pb.setCurrentPage(1);                        // 把当前页设置为1
        } else if (pb.getCurrentPage() > pb.getTotalPage()){
            pb.setCurrentPage(pb.getTotalPage());        // 把当前页设置为最大页数
        }
        
        //1. 获取当前页： 计算查询的起始行、返回的行数
        int currentPage = pb.getCurrentPage();
        int index = (currentPage -1 ) * pb.getPageCount();        // 查询的起始行
        int count = pb.getPageCount();                            // 查询返回的行数
        
        
        //3. 分页查询数据;  把查询到的数据设置到pb对象中
        String sql = "select * from employee limit ?,?";
        
        try {
            // 得到Queryrunner对象
            QueryRunner qr = JdbcUtils.getQueryRuner();
            // 根据当前页，查询当前页数据(一页数据)
            List<Employee> pageData = qr.query(sql, new BeanListHandler<Employee>(Employee.class), index, count);
            // 设置到pb对象中
            pb.setPageData(pageData);
            
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        
    }

    @Override
    public int getTotalCount() {
        String sql = "select count(*) from employee";
        try {
            // 创建QueryRunner对象
            QueryRunner qr = JdbcUtils.getQueryRuner();
            // 执行查询， 返回结果的第一行的第一列
            Long count = qr.query(sql, new ScalarHandler<Long>());
            return count.intValue();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

}

View Code

六.业务层

package cn.cracker.service;

import cn.cracker.entity.Employee;
import cn.cracker.utils.PageBean;

public interface IEmployeeService {

    /**
     * 分页查询数据
     */
    public void getAll(PageBean<Employee> pb);
}

View Code

package cn.cracker.service.impl;

import cn.cracker.dao.IEmployeeDao;
import cn.cracker.dao.impl.EmployeeDao;
import cn.cracker.entity.Employee;
import cn.cracker.service.IEmployeeService;
import cn.cracker.utils.PageBean;

/**
 * 3. 业务逻辑层，实现
 */
public class EmployeeService implements IEmployeeService {
    
    // 创建Dao实例
    private IEmployeeDao employeeDao = new EmployeeDao();

    @Override
    public void getAll(PageBean<Employee> pb) {
        try {
            employeeDao.getAll(pb);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

}

View Code

七.控制层

package cn.cracker.servlet;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import cn.cracker.entity.Employee;
import cn.cracker.service.IEmployeeService;
import cn.cracker.service.impl.EmployeeService;
import cn.cracker.utils.PageBean;

/**
 * 4. 控制层开发
 */
public class IndexServlet extends HttpServlet {
    // 创建Service实例
    private IEmployeeService employeeService = new EmployeeService();
    // 跳转资源
    private String uri;

    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        
        try {
            //1. 获取“当前页”参数；  (第一次访问当前页为null) 
            String currPage = request.getParameter("currentPage");
            // 判断
            if (currPage == null || "".equals(currPage.trim())){
                currPage = "1";      // 第一次访问，设置当前页为1;
            }
            // 转换
            int currentPage = Integer.parseInt(currPage);
            
            //2. 创建PageBean对象，设置当前页参数； 传入service方法参数
            PageBean<Employee> pageBean = new PageBean<Employee>();
            pageBean.setCurrentPage(currentPage);
            
            //3. 调用service  
            employeeService.getAll(pageBean);    // 【pageBean已经被dao填充了数据】
            
            //4. 保存pageBean对象，到request域中
            request.setAttribute("pageBean", pageBean);
            
            //5. 跳转 
            uri = "/WEB-INF/list.jsp";
        } catch (Exception e) {
            e.printStackTrace();  // 测试使用
            // 出现错误，跳转到错误页面；给用户友好提示
            uri = "/error/error.jsp";
        }
        request.getRequestDispatcher(uri).forward(request, response);
        
    }

    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        this.doGet(request, response);
    }

}

View Code

PS：别忘了导入这几个lib包 c3p0-0.9.1.2.jar、commons-dbutils-1.6.jar、mysql-connector-java-5.1.12-bin.jar