在oracle数据库中查询结果的行号使用伪列ROWNUM表示（从1开始）。例如select * from employee where rownum<10 返回前10条记录。但因为rownum是在查询之后排序之前赋值的，所以查询employee按birthday排序的第100到120条记录应该这么写：
下面是简单的使用示例：
//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 evan_zhao@hotmail.com字样
/////////////////////////////////// // // Page.java // author: evan_zhao@hotmail.com // /////////////////////////////////// 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 evan_zhao@hotmail.com <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: evan_zhao@hotmail.com // /////////////////////////////////// package page; import javax.sql.RowSet; /**
* <p>Title: RowSetPage</p>
* <p>Description: 使用RowSet封装数据的分页对象</p>
* <p>Copyright: Copyright (c) 2003</p>
* @author evan_zhao@hotmail.com
* @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: evan_zhao@hotmail.com // /////////////////////////////////// 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 evan_zhao@hotmail.com
* @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，。。。
*@param obj 包含参数值的对象
*/ public void setObject(int index, Object obj) throws SQLException{ BoundParam bp = new BoundParam(index, obj); boundParams.remove(bp); boundParams.add( bp); } /**
*使用给出的对象设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param obj 包含参数值的对象
*@param targetSqlType 参数的数据库类型
*/ public void setObject(int index, Object obj, int targetSqlType) throws SQLException{ BoundParam bp = new BoundParam(index, obj, targetSqlType); boundParams.remove(bp); boundParams.add(bp ); } /**
*使用给出的对象设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param obj 包含参数值的对象
*@param targetSqlType 参数的数据库类型(常量定义在java.sql.Types中)
*@param scale 精度，小数点后的位数
* （只对targetSqlType是Types.NUMBER或Types.DECIMAL有效，其它类型则忽略）
*/ public void setObject(int index, Object obj, int targetSqlType, int scale) throws SQLException{ BoundParam bp = new BoundParam(index, obj, targetSqlType, scale) ; boundParams.remove(bp); boundParams.add(bp); } /**
*使用给出的字符串设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param str 包含参数值的字符串
*/ public void setString(int index, String str)throws SQLException{ BoundParam bp = new BoundParam(index, str) ; boundParams.remove(bp); boundParams.add(bp); } /**
*使用给出的字符串设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param timestamp 包含参数值的时间戳
*/ public void setTimestamp(int index, Timestamp timestamp)throws SQLException{ BoundParam bp = new BoundParam(index, timestamp) ; boundParams.remove(bp); boundParams.add( bp ); } /**
*使用给出的整数设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param value 包含参数值的整数
*/ public void setInt(int index, int value)throws SQLException{ BoundParam bp = new BoundParam(index, new Integer(value)) ; boundParams.remove(bp); boundParams.add( bp ); } /**
*使用给出的长整数设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param value 包含参数值的长整数
*/ public void setLong(int index, long value)throws SQLException{ BoundParam bp = new BoundParam(index, new Long(value)) ; boundParams.remove(bp); boundParams.add( bp ); } /**
*使用给出的双精度浮点数设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param value 包含参数值的双精度浮点数
*/ public void setDouble(int index, double value)throws SQLException{ BoundParam bp = new BoundParam(index, new Double(value)) ; boundParams.remove(bp); boundParams.add( bp); } /**
*使用给出的BigDecimal设置指定参数的值
*@param index 第一个参数为1，第二个为2，。。。
*@param bd 包含参数值的BigDecimal
*/ public void setBigDecimal(int index, BigDecimal bd)throws SQLException{ BoundParam bp = new BoundParam(index, bd ) ; boundParams.remove(bp); boundParams.add( bp); } private void setParams(PreparedStatement pst) throws SQLException{ if (pst==null || this.boundParams==null || this.boundParams.size()==0 ) return ; BoundParam param; for (Iterator itr = this.boundParams.iterator();itr.hasNext();){ param = (BoundParam) itr.next(); if (param==null) continue; if (param.sqlType == java.sql.Types.OTHER){ pst.setObject(param.index, param.value); }else{ pst.setObject(param.index, param.value, param.sqlType, param.scale); } } } /**
* 执行查询取得一页数据，执行结束后关闭数据库连接
* @return RowSetPage
* @throws SQLException
*/ public RowSetPage executeQuery() throws SQLException{ System.out.println("executeQueryUsingPreparedStatement"); Connection conn = DBUtil.getConnection(); PreparedStatement pst = null; ResultSet rs = null; try{ pst = conn.prepareStatement(this.countSQL); setParams(pst); rs =pst.executeQuery(); if (rs.next()){ totalCount = rs.getInt(1); } else { totalCount = 0; } rs.close(); pst.close(); if (totalCount < 1 ) return RowSetPage.EMPTY_PAGE; pst = conn.prepareStatement(this.querySQL); System.out.println(querySQL); pst.setFetchSize(this.pageSize); setParams(pst); rs =pst.executeQuery(); //rs.setFetchSize(pageSize); this.rowSet = populate(rs); rs.close(); rs = null; pst.close(); pst = null; this.rowSetPage = new RowSetPage(this.rowSet,startIndex,totalCount,pageSize); return this.rowSetPage; }catch(SQLException sqle){ //System.out.println("executeQuery SQLException"); sqle.printStackTrace(); throw sqle; }catch(Exception e){ e.printStackTrace(); throw new RuntimeException(e.toString()); }finally{ //System.out.println("executeQuery finally"); DBUtil.close(rs, pst, conn); } } /**
*将ResultSet数据填充进CachedRowSet
*/ protected abstract RowSet populate(ResultSet rs) throws SQLException; /**
*取封装成RowSet查询结果
*@return RowSet
*/ public javax.sql.RowSet getRowSet(){ return this.rowSet; } /**
*取封装成RowSetPage的查询结果
*@return RowSetPage
*/ public RowSetPage getRowSetPage() { return this.rowSetPage; } /**
*关闭数据库连接
*/ public void close(){ //因为数据库连接在查询结束或发生异常时即关闭，此处不做任何事情 //留待扩充。 } private class BoundParam { int index; Object value; int sqlType; int scale; public BoundParam(int index, Object value) { this(index, value, java.sql.Types.OTHER); } public BoundParam(int index, Object value, int sqlType) { this(index, value, sqlType, 0); } public BoundParam(int index, Object value, int sqlType, int scale) { this.index = index; this.value = value; this.sqlType = sqlType; this.scale = scale; } public boolean equals(Object obj){ if (obj!=null && this.getClass().isInstance(obj)){ BoundParam bp = (BoundParam)obj; if (this.index==bp.index) return true; } return false; } } } /////////////////////////////////// // // PagedStatementOracleImpl.java // author: evan_zhao@hotmail.com // /////////////////////////////////// package page; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.RowSet; import oracle.jdbc.rowset.OracleCachedRowSet; /**
* <p>Title: 分页查询Oracle数据库实现</p>
* <p>Copyright: Copyright (c) 2002</p>
* @author evan_zhao@hotmail.com
* @version 1.0
*/ public class PagedStatementOracleImpl extends PagedStatement { /**
* 构造一查询出所有数据的PageStatement
* @param sql query sql
*/ public PagedStatementOracleImpl(String sql){ super(sql); } /**
* 构造一查询出当页数据的PageStatement
* @param sql query sql
* @param pageNo 页码
*/ public PagedStatementOracleImpl(String sql, int pageNo){ super(sql, pageNo); } /**
* 构造一查询出当页数据的PageStatement，并指定每页显示记录条数
* @param sql query sql
* @param pageNo 页码
* @param pageSize 每页容量
*/ public PagedStatementOracleImpl(String sql, int pageNo, int pageSize){ super(sql, pageNo, pageSize); } /**
*生成查询一页数据的sql语句
*@param sql 原查询语句
*@startIndex 开始记录位置
*@size 需要获取的记录数
*/ protected String intiQuerySQL(String sql, int startIndex, int size){ StringBuffer querySQL = new StringBuffer(); if (size != super.MAX_PAGE_SIZE) { querySQL.append("select * from (select my_table.*,rownum as my_rownum from(") .append( sql) .append(") my_table where rownum<").append(startIndex + size) .append(") where my_rownum>=").append(startIndex); } else { querySQL.append("select * from (select my_table.*,rownum as my_rownum from(") .append(sql) .append(") my_table ") .append(") where my_rownum>=").append(startIndex); } return querySQL.toString(); } /**
*将ResultSet数据填充进CachedRowSet
*/ protected RowSet populate(ResultSet rs) throws SQLException{ OracleCachedRowSet ocrs = new OracleCachedRowSet(); ocrs.populate(rs); return ocrs; } }
相关连接：
JSP页面查询显示常用模式,介绍查询结果集封装的几种常用模式。本程序使用了其中部分代码
RowSet规范原来是JDBC(TM) 2.0 Optional Package的一部分，现在已经并入JDBC3.0规范，并且将成为J2SE1.5的组成部分。
关于RowSet的实现各个数据库的jdbc driver应该都有提供,oracle实现可以到http://otn.oracle.com/software/tech/java/sqlj_jdbc/content.html下载(Additional RowSet support)
Sun也提供了RowSet的参考实现，应该可以支持大多数数据库：http://java.sun.com/products/jdbc/download.html
PetStore 是Sun关于J2EE设计模式的一个示例程序。
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。