目前比較廣泛使用的分頁方式是將查詢結(jié)果緩存在HttpSession或有狀態(tài)bean中，翻頁的時候從緩存中取出一頁數(shù)據(jù)顯示。這種方法有兩個主要的缺點：一是用戶可能看到的是過期數(shù)據(jù)；二是如果數(shù)據(jù)量非常大時第一次查詢遍歷結(jié)果集會耗費很長時間，并且緩存的數(shù)據(jù)也會占用大量內(nèi)存，效率明顯下降。
其它常見的方法還有每次翻頁都查詢一次數(shù)據(jù)庫，從ResultSet中只取出一頁數(shù)據(jù)（使用rs.last();rs.getRow()獲得總計錄條數(shù)，使用rs.absolute()定位到本頁起始記錄）。這種方式在某些數(shù)據(jù)庫(如oracle)的JDBC實現(xiàn)中差不多也是需要遍歷所有記錄，實驗證明在記錄數(shù)很大時速度非常慢。
至于緩存結(jié)果集ResultSet的方法則完全是一種錯誤的做法。因為ResultSet在Statement或Connection關(guān)閉時也會被關(guān)閉，如果要使ResultSet有效勢必長時間占用數(shù)據(jù)庫連接。
因此比較好的分頁做法應(yīng)該是每次翻頁的時候只從數(shù)據(jù)庫里檢索頁面大小的塊區(qū)的數(shù)據(jù)。這樣雖然每次翻頁都需要查詢數(shù)據(jù)庫，但查詢出的記錄數(shù)很少，網(wǎng)絡(luò)傳輸數(shù)據(jù)量不大，如果使用連接池更可以略過最耗時的建立數(shù)據(jù)庫連接過程。而在數(shù)據(jù)庫端有各種成熟的優(yōu)化技術(shù)用于提高查詢速度，比在應(yīng)用服務(wù)器層做緩存有效多了。
在oracle數(shù)據(jù)庫中查詢結(jié)果的行號使用偽列ROWNUM表示（從1開始）。例如select * from employee where rownum<10 返回前10條記錄。但因為rownum是在查詢之后排序之前賦值的，所以查詢employee按birthday排序的第100到120條記錄應(yīng)該這么寫：
下面是簡單的
使用示例：
//DAO查詢數(shù)據(jù)部分代碼：…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數(shù)據(jù)庫的分頁查詢實現(xiàn),每頁顯示5條PagedStatement pst =new PagedStatementOracleImpl(sql, pageNo, 5);pst.setString(1, gender);return pst.executeQuery();}//Servlet處理查詢請求部分代碼：…int pageNo;try{//可以通過參數(shù)pageno獲得用戶選擇的頁碼pageNo = Integer.parseInt(request.getParameter("pageno") );}catch(Exception ex){//默認(rèn)為第一頁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><%//顯示總頁數(shù)和當(dāng)前頁數(shù)(pageno)以及分頁代碼。//此處doQuery為頁面上提交查詢動作的javascript函數(shù)名， pageno為標(biāo)識當(dāng)前頁碼的參數(shù)名%><td colspan=4><%= empPage .getHTML("doQuery", "pageno")%></td></tr></table></form> 效果如圖：
因為分頁顯示一般都會伴有查詢條件和查詢動作，頁面應(yīng)已經(jīng)有校驗查詢條件和提交查詢的javascript方法（如上面的doQuery），所以RowSetPage.getHTML()生成的分頁代碼在用戶選擇新頁碼時直接回調(diào)前面的處理提交查詢的javascript方法。注意在顯示查詢結(jié)果的時候上次的查詢條件也需要保持，如<input type=text name=gender size=1 value="<%=request.getParameter("gender")%>">。同時由于頁碼的參數(shù)名可以指定，因此也支持在同一頁面中有多個分頁區(qū)。
另一種分頁代碼實現(xiàn)是生成每一頁的URL，將查詢參數(shù)和頁碼作為QueryString附在URL后面。這種方法的缺陷是在查詢條件比較復(fù)雜時難以處理，并且需要指定處理查詢動作的servlet，可能不適合某些定制的查詢操作。
如果對RowSetPage.getHTML()生成的默認(rèn)分頁代碼不滿意可以編寫自己的分頁處理代碼，RowSetPage提供了很多getter方法用于獲取相關(guān)信息（如當(dāng)前頁碼、總頁數(shù)、 總記錄數(shù)和當(dāng)前記錄數(shù)等）。
在實際應(yīng)用中可以將分頁查詢和顯示做成jsp taglib， 進(jìn)一步簡化JSP代碼，屏蔽Java Code。
附：分頁工具類的源代碼， 有注釋，應(yīng)該很容易理解。
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: 用于包含數(shù)據(jù)及分頁信息的對象<br>
* Page類實現(xiàn)了用于顯示分頁信息的基本方法，但未指定所含數(shù)據(jù)的類型，
* 可根據(jù)需要實現(xiàn)以特定方式組織數(shù)據(jù)的子類，<br>
* 如RowSetPage以RowSet封裝數(shù)據(jù)，ListPage以List封裝數(shù)據(jù)<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;/**
* 默認(rèn)構(gòu)造方法，只構(gòu)造空頁
*/protected Page(){this.init(0,0,0,DEFAULT_PAGE_SIZE,new Object());}/**
* 分頁數(shù)據(jù)初始方法，由子類調(diào)用
* @param start 本頁數(shù)據(jù)在數(shù)據(jù)庫中的起始位置
* @param avaCount 本頁包含的數(shù)據(jù)條數(shù)
* @param totalSize 數(shù)據(jù)庫中總記錄條數(shù)
* @param pageSize 本頁容量
* @param data 本頁包含的數(shù)據(jù)
*/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("記錄條數(shù)大于總條數(shù)？！");}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;}/**
* 取本頁數(shù)據(jù)容量（本頁能包含的記錄數(shù)）
* @return 本頁能包含的記錄數(shù)
*/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);}/**
* 獲取當(dāng)前頁第一條數(shù)據(jù)在數(shù)據(jù)庫中的位置
* @return
*/public int getStart(){return start;}/**
* 獲取當(dāng)前頁最后一條數(shù)據(jù)在數(shù)據(jù)庫中的位置
* @return
*/public int getEnd(){int end = this.getStart() + this.getSize() -1;if (end<0) {end = 0;}return end;}/**
* 獲取上一頁第一條數(shù)據(jù)在數(shù)據(jù)庫中的位置
* @return 記錄對應(yīng)的rownum
*/public int getStartOfPreviousPage() {return Math.max(start-myPageSize, 1);}/**
* 獲取下一頁第一條數(shù)據(jù)在數(shù)據(jù)庫中的位置
* @return 記錄對應(yīng)的rownum
*/public int getStartOfNextPage() {return start + avaCount;}/**
* 獲取任一頁第一條數(shù)據(jù)在數(shù)據(jù)庫中的位置，每頁條數(shù)使用默認(rèn)值
* @param pageNo 頁號
* @return 記錄對應(yīng)的rownum
*/public static int getStartOfAnyPage(int pageNo){return getStartOfAnyPage(pageNo, DEFAULT_PAGE_SIZE);}/**
* 獲取任一頁第一條數(shù)據(jù)在數(shù)據(jù)庫中的位置
* @param pageNo 頁號
* @param pageSize 每頁包含的記錄數(shù)
* @return 記錄對應(yīng)的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;}/**
* 取本頁包含的記錄數(shù)
* @return 本頁包含的記錄數(shù)
*/public int getSize() {return avaCount;}/**
* 取數(shù)據(jù)庫中包含的總記錄數(shù)
* @return 數(shù)據(jù)庫中包含的總記錄數(shù)
*/public int getTotalSize() {return this.totalSize;}/**
* 取當(dāng)前頁碼
* @return 當(dāng)前頁碼
*/public int getCurrentPageNo(){return this.currentPageno;}/**
* 取總頁碼
* @return 總頁碼
*/public int getTotalPageCount(){return this.totalPageCount;}/**
*
* @param queryJSFunctionName 實現(xiàn)分頁的JS腳本名字，頁碼變動時會自動回調(diào)該方法
* @param pageNoParamName 頁碼參數(shù)名稱
* @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封裝數(shù)據(jù)的分頁對象</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();/**
*默認(rèn)構(gòu)造方法，創(chuàng)建空頁
*/public RowSetPage(){this(null, 0,0);}/**
*構(gòu)造分頁對象
*@param crs 包含一頁數(shù)據(jù)的OracleCachedRowSet
*@param start 該頁數(shù)據(jù)在數(shù)據(jù)庫中的起始位置
*@param totalSize 數(shù)據(jù)庫中包含的記錄總數(shù)
*/public RowSetPage(RowSet crs, int start, int totalSize) {this(crs,start,totalSize,Page.DEFAULT_PAGE_SIZE);}/**
*構(gòu)造分頁對象
*@param crs 包含一頁數(shù)據(jù)的OracleCachedRowSet
*@param start 該頁數(shù)據(jù)在數(shù)據(jù)庫中的起始位置
*@param totalSize 數(shù)據(jù)庫中包含的記錄總數(shù)
*@pageSize 本頁能容納的記錄數(shù)
*/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());}}/**
*取分頁對象中的記錄數(shù)據(jù)
*/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: 根據(jù)查詢語句和頁碼查詢出當(dāng)頁數(shù)據(jù)</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;/**
* 構(gòu)造一查詢出所有數(shù)據(jù)的PageStatement
* @param sql query sql
*/public PagedStatement(String sql){this(sql,1,MAX_PAGE_SIZE);}/**
* 構(gòu)造一查詢出當(dāng)頁數(shù)據(jù)的PageStatement
* @param sql query sql
* @param pageNo 頁碼
*/public PagedStatement(String sql, int pageNo){this(sql, pageNo, Page.DEFAULT_PAGE_SIZE);}/**
* 構(gòu)造一查詢出當(dāng)頁數(shù)據(jù)的PageStatement，并指定每頁顯示記錄條數(shù)
* @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);}/**
*生成查詢一頁數(shù)據(jù)的sql語句
*@param sql 原查詢語句
*@startIndex 開始記錄位置
*@size 需要獲取的記錄數(shù)
*/protected abstract String intiQuerySQL(String sql, int startIndex, int size);/**
*使用給出的對象設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param obj 包含參數(shù)值的對象
*/public void setObject(int index, Object obj) throws SQLException{BoundParam bp = new BoundParam(index, obj);boundParams.remove(bp);boundParams.add( bp);}/**
*使用給出的對象設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param obj 包含參數(shù)值的對象
*@param targetSqlType 參數(shù)的數(shù)據(jù)庫類型
*/public void setObject(int index, Object obj, int targetSqlType) throws SQLException{BoundParam bp = new BoundParam(index, obj, targetSqlType);boundParams.remove(bp);boundParams.add(bp );}/**
*使用給出的對象設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param obj 包含參數(shù)值的對象
*@param targetSqlType 參數(shù)的數(shù)據(jù)庫類型(常量定義在java.sql.Types中)
*@param scale 精度，小數(shù)點后的位數(shù)
* （只對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);}/**
*使用給出的字符串設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param str 包含參數(shù)值的字符串
*/public void setString(int index, String str)throws SQLException{BoundParam bp = new BoundParam(index, str) ;boundParams.remove(bp);boundParams.add(bp);}/**
*使用給出的字符串設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param timestamp 包含參數(shù)值的時間戳
*/public void setTimestamp(int index, Timestamp timestamp)throws SQLException{BoundParam bp = new BoundParam(index, timestamp) ;boundParams.remove(bp);boundParams.add( bp );}/**
*使用給出的整數(shù)設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param value 包含參數(shù)值的整數(shù)
*/public void setInt(int index, int value)throws SQLException{BoundParam bp = new BoundParam(index, new Integer(value)) ;boundParams.remove(bp);boundParams.add( bp );}/**
*使用給出的長整數(shù)設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param value 包含參數(shù)值的長整數(shù)
*/public void setLong(int index, long value)throws SQLException{BoundParam bp = new BoundParam(index, new Long(value)) ;boundParams.remove(bp);boundParams.add( bp );}/**
*使用給出的雙精度浮點數(shù)設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param value 包含參數(shù)值的雙精度浮點數(shù)
*/public void setDouble(int index, double value)throws SQLException{BoundParam bp = new BoundParam(index, new Double(value)) ;boundParams.remove(bp);boundParams.add( bp);}/**
*使用給出的BigDecimal設(shè)置指定參數(shù)的值
*@param index 第一個參數(shù)為1，第二個為2，。。。
*@param bd 包含參數(shù)值的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);}}}/**
* 執(zhí)行查詢?nèi)〉靡豁摂?shù)據(jù)，執(zhí)行結(jié)束后關(guān)閉數(shù)據(jù)庫連接
* @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數(shù)據(jù)填充進(jìn)CachedRowSet
*/protected abstract RowSet populate(ResultSet rs) throws SQLException;/**
*取封裝成RowSet查詢結(jié)果
*@return RowSet
*/public javax.sql.RowSet getRowSet(){return this.rowSet;}/**
*取封裝成RowSetPage的查詢結(jié)果
*@return RowSetPage
*/public RowSetPage getRowSetPage() {return this.rowSetPage;}/**
*關(guān)閉數(shù)據(jù)庫連接
*/public void close(){//因為數(shù)據(jù)庫連接在查詢結(jié)束或發(fā)生異常時即關(guān)閉，此處不做任何事情//留待擴充。}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數(shù)據(jù)庫實現(xiàn)</p>
* <p>Copyright: Copyright (c) 2002</p>
* @author evan_zhao@hotmail.com
* @version 1.0
*/public class PagedStatementOracleImpl extends PagedStatement {/**
* 構(gòu)造一查詢出所有數(shù)據(jù)的PageStatement
* @param sql query sql
*/public PagedStatementOracleImpl(String sql){super(sql);}/**
* 構(gòu)造一查詢出當(dāng)頁數(shù)據(jù)的PageStatement
* @param sql query sql
* @param pageNo 頁碼
*/public PagedStatementOracleImpl(String sql, int pageNo){super(sql, pageNo);}/**
* 構(gòu)造一查詢出當(dāng)頁數(shù)據(jù)的PageStatement，并指定每頁顯示記錄條數(shù)
* @param sql query sql
* @param pageNo 頁碼
* @param pageSize 每頁容量
*/public PagedStatementOracleImpl(String sql, int pageNo, int pageSize){super(sql, pageNo, pageSize);}/**
*生成查詢一頁數(shù)據(jù)的sql語句
*@param sql 原查詢語句
*@startIndex 開始記錄位置
*@size 需要獲取的記錄數(shù)
*/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數(shù)據(jù)填充進(jìn)CachedRowSet
*/protected RowSet populate(ResultSet rs) throws SQLException{OracleCachedRowSet ocrs = new OracleCachedRowSet();ocrs.populate(rs);return ocrs;}}
