目前比較廣泛使用的分頁方式是將查詢結果緩存在HttpSession或有狀態bean中,翻頁的時候從緩存中取出一頁數據顯示。這種方法有兩個主要的缺點:一是用戶可能看到的是過期數據;二是如果數據量非常大時第一次查詢遍歷結果集會耗費很長時間,并且緩存的數據也會占用大量內存,效率明顯下降。
其它常見的方法還有每次翻頁都查詢一次數據庫,從ResultSet中只取出一頁數據(使用rs.last();rs.getRow()獲得總計錄條數,使用rs.absolute()定位到本頁起始記錄)。這種方式在某些數據庫(如oracle)的JDBC實現中差不多也是需要遍歷所有記錄,實驗證明在記錄數很大時速度非常慢。
至于緩存結果集ResultSet的方法則完全是一種錯誤的做法。因為ResultSet在Statement或Connection關閉時也會被關閉,如果要使ResultSet有效勢必長時間占用數據庫連接。
因此比較好的分頁做法應該是每次翻頁的時候只從數據庫里檢索頁面大小的塊區的數據。這樣雖然每次翻頁都需要查詢數據庫,但查詢出的記錄數很少,網絡傳輸數據量不大,如果使用連接池更可以略過最耗時的建立數據庫連接過程。而在數據庫端有各種成熟的優化技術用于提高查詢速度,比在應用服務器層做緩存有效多了。
在oracle數據庫中查詢結果的行號使用偽列ROWNUM表示(從1開始)。例如select*fromemployeewhererownum<10返回前10條記錄。但因為rownum是在查詢之后排序之前賦值的,所以查詢employee按birthday排序的第100到120條記錄應該這么寫:
mySQL可以使用LIMIT子句:
selectname,birthdayfromemployeeorderbybirthdayLIMIT99,20
DB2有rownumber()函數用于獲取當前行數。
SQLServer沒研究過,可以參考這篇文章: http://www.csdn.net/develop/article/18/18627.shtm
在Web程序中分頁會被頻繁使用,但分頁的實現細節卻是編程過程中比較麻煩的事情。大多分頁顯示的查詢操作都同時需要處理復雜的多重查詢條件,sql語句需要動態拼接組成,再加上分頁需要的記錄定位、總記錄條數查詢以及查詢結果的遍歷、封裝和顯示,程序會變得很復雜并且難以理解。因此需要一些工具類簡化分頁代碼,使程序員專注于業務邏輯部分。下面是我設計的兩個工具類:
PagedStatement 封裝了數據庫連接、總記錄數查詢、分頁查詢、結果數據封裝和關閉數據庫連接等操作,并使用了PreparedStatement支持動態設置參數。
RowSetPage 參考PetStore的pagebypageiterator模式,設計RowSetPage用于封裝查詢結果(使用OracleCachedRowSet緩存查詢出的一頁數據,關于使用CachedRowSet封裝數據庫查詢結果請參考 JSP頁面查詢顯示常用模式 )以及當前頁碼、總記錄條數、當前記錄數等信息,并且可以生成簡單的HTML分頁代碼。
PagedStatement查詢的結果封裝成RowsetPage。
下面是簡單的 使用示例 :
效果如圖:
因為分頁顯示一般都會伴有查詢條件和查詢動作,頁面應已經有校驗查詢條件和提交查詢的javascript方法(如上面的doQuery),所以RowSetPage.getHTML()生成的分頁代碼在用戶選擇新頁碼時直接回調前面的處理提交查詢的javascript方法。注意在顯示查詢結果的時候上次的查詢條件也需要保持,如<inputtype=textname=gendersize=1value="<%=request.getParameter("gender")%>">。同時由于頁碼的參數名可以指定,因此也支持在同一頁面中有多個分頁區。
另一種分頁代碼實現是生成每一頁的URL,將查詢參數和頁碼作為QueryString附在URL后面。這種方法的缺陷是在查詢條件比較復雜時難以處理,并且需要指定處理查詢動作的servlet,可能不適合某些定制的查詢操作。
如果對RowSetPage.getHTML()生成的默認分頁代碼不滿意可以編寫自己的分頁處理代碼,RowSetPage提供了很多getter方法用于獲取相關信息(如當前頁碼、總頁數、總記錄數和當前記錄數等)。
在實際應用中可以將分頁查詢和顯示做成jsptaglib,進一步簡化JSP代碼,屏蔽JavaCode。
附:分頁工具類的源代碼,有注釋,應該很容易理解。
1.Page.java
2.RowSetPage.java(RowSetPage繼承Page)
3.PagedStatement.java
4.PagedStatementOracleImpl.java(PagedStatementOracleImpl繼承PagedStatement)
您可以任意使用這些源代碼,但必須保留authorevan_zhao@hotmail.com字樣
其它常見的方法還有每次翻頁都查詢一次數據庫,從ResultSet中只取出一頁數據(使用rs.last();rs.getRow()獲得總計錄條數,使用rs.absolute()定位到本頁起始記錄)。這種方式在某些數據庫(如oracle)的JDBC實現中差不多也是需要遍歷所有記錄,實驗證明在記錄數很大時速度非常慢。
至于緩存結果集ResultSet的方法則完全是一種錯誤的做法。因為ResultSet在Statement或Connection關閉時也會被關閉,如果要使ResultSet有效勢必長時間占用數據庫連接。
因此比較好的分頁做法應該是每次翻頁的時候只從數據庫里檢索頁面大小的塊區的數據。這樣雖然每次翻頁都需要查詢數據庫,但查詢出的記錄數很少,網絡傳輸數據量不大,如果使用連接池更可以略過最耗時的建立數據庫連接過程。而在數據庫端有各種成熟的優化技術用于提高查詢速度,比在應用服務器層做緩存有效多了。
在oracle數據庫中查詢結果的行號使用偽列ROWNUM表示(從1開始)。例如select*fromemployeewhererownum<10返回前10條記錄。但因為rownum是在查詢之后排序之前賦值的,所以查詢employee按birthday排序的第100到120條記錄應該這么寫:
select*from(
selectmy_table.*,rownumasmy_rownumfrom(
selectname,birthdayfromemployeeorderbybirthday
)my_tablewhererownum<120
)wheremy_rownum>=100
mySQL可以使用LIMIT子句:
selectname,birthdayfromemployeeorderbybirthdayLIMIT99,20
DB2有rownumber()函數用于獲取當前行數。
SQLServer沒研究過,可以參考這篇文章: http://www.csdn.net/develop/article/18/18627.shtm
在Web程序中分頁會被頻繁使用,但分頁的實現細節卻是編程過程中比較麻煩的事情。大多分頁顯示的查詢操作都同時需要處理復雜的多重查詢條件,sql語句需要動態拼接組成,再加上分頁需要的記錄定位、總記錄條數查詢以及查詢結果的遍歷、封裝和顯示,程序會變得很復雜并且難以理解。因此需要一些工具類簡化分頁代碼,使程序員專注于業務邏輯部分。下面是我設計的兩個工具類:
PagedStatement 封裝了數據庫連接、總記錄數查詢、分頁查詢、結果數據封裝和關閉數據庫連接等操作,并使用了PreparedStatement支持動態設置參數。
RowSetPage 參考PetStore的pagebypageiterator模式,設計RowSetPage用于封裝查詢結果(使用OracleCachedRowSet緩存查詢出的一頁數據,關于使用CachedRowSet封裝數據庫查詢結果請參考 JSP頁面查詢顯示常用模式 )以及當前頁碼、總記錄條數、當前記錄數等信息,并且可以生成簡單的HTML分頁代碼。
PagedStatement查詢的結果封裝成RowsetPage。
下面是簡單的 使用示例 :
- //DAO查詢數據部分代碼:
- …
- public RowSetPagegetEmployee( String gender, int pageNo) throws Exception {
- String sql="selectemp_id,emp_code,user_name,real_namefromemployeewheregender=?";
- //使用Oracle數據庫的分頁查詢實現,每頁顯示5條
- PagedStatementpst= 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"%>
- …
- <scriptlanguage="javascript">
- functiondoQuery(){
- form1.actionType.value="doQuery";
- form1.submit();
- }
- </script>
- …
- <formname=form1method=get>
- <inputtype=hiddenname=actionType>
- 性別:
- <inputtype=textname=gendersize=1value="<%=request.getParameter("gender")%>">
- <inputtype=buttonvalue="查詢"onclick="doQuery()">
- <%
- RowSetPageempPage=(RowSetPage)request.getAttribute("empPage");
- if (empPage== null )empPage=RowSetPage.EMPTY_PAGE;
- %>
- …
- <tablecellspacing="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>
- <%
- } //endwhile
- %>
- <tr>
- <%
- //顯示總頁數和當前頁數(pageno)以及分頁代碼。
- //此處doQuery為頁面上提交查詢動作的javascript函數名,pageno為標識當前頁碼的參數名
- %>
- <tdcolspan=4><%=empPage.getHTML("doQuery","pageno")%></td>
- </tr>
- </table>
- </form>
效果如圖:
因為分頁顯示一般都會伴有查詢條件和查詢動作,頁面應已經有校驗查詢條件和提交查詢的javascript方法(如上面的doQuery),所以RowSetPage.getHTML()生成的分頁代碼在用戶選擇新頁碼時直接回調前面的處理提交查詢的javascript方法。注意在顯示查詢結果的時候上次的查詢條件也需要保持,如<inputtype=textname=gendersize=1value="<%=request.getParameter("gender")%>">。同時由于頁碼的參數名可以指定,因此也支持在同一頁面中有多個分頁區。
另一種分頁代碼實現是生成每一頁的URL,將查詢參數和頁碼作為QueryString附在URL后面。這種方法的缺陷是在查詢條件比較復雜時難以處理,并且需要指定處理查詢動作的servlet,可能不適合某些定制的查詢操作。
如果對RowSetPage.getHTML()生成的默認分頁代碼不滿意可以編寫自己的分頁處理代碼,RowSetPage提供了很多getter方法用于獲取相關信息(如當前頁碼、總頁數、總記錄數和當前記錄數等)。
在實際應用中可以將分頁查詢和顯示做成jsptaglib,進一步簡化JSP代碼,屏蔽JavaCode。
附:分頁工具類的源代碼,有注釋,應該很容易理解。
1.Page.java
2.RowSetPage.java(RowSetPage繼承Page)
3.PagedStatement.java
4.PagedStatementOracleImpl.java(PagedStatementOracleImpl繼承PagedStatement)
您可以任意使用這些源代碼,但必須保留authorevan_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>
- *@authorevan_zhao@hotmail.com<br>
- *@version1.0
- */
- public class Page implements java.io. Serializable {
- public static final PageEMPTY_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 ());
- }
- /**
- *分頁數據初始方法,由子類調用
- *@paramstart本頁數據在數據庫中的起始位置
- *@paramavaCount本頁包含的數據條數
- *@paramtotalSize數據庫中總記錄條數
- *@parampageSize本頁容量
- *@paramdata本頁包含的數據
- */
- 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){
- //thrownewRuntimeException("記錄條數大于總條數?!");
- }
- 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("StartIndextoPageNo:"+start+"-"+currentPageno);
- }
- public Object getData(){
- return this .data;
- }
- /**
- *取本頁數據容量(本頁能包含的記錄數)
- *@return本頁能包含的記錄數
- */
- public int getPageSize(){
- return this .myPageSize;
- }
- /**
- *是否有下一頁
- *@return是否有下一頁
- */
- public boolean hasNextPage(){
- /*
- if(avaCount==0&&totalSize==0){
- returnfalse;
- }
- return(start+avaCount-1)<totalSize;
- */
- return ( this .getCurrentPageNo()< this .getTotalPageCount());
- }
- /**
- *是否有上一頁
- *@return是否有上一頁
- */
- public boolean hasPreviousPage(){
- /*
- returnstart>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;
- }
- /**
- *獲取任一頁第一條數據在數據庫中的位置,每頁條數使用默認值
- *@parampageNo頁號
- *@return記錄對應的rownum
- */
- public static int getStartOfAnyPage( int pageNo){
- return getStartOfAnyPage(pageNo,DEFAULT_PAGE_SIZE);
- }
- /**
- *獲取任一頁第一條數據在數據庫中的位置
- *@parampageNo頁號
- *@parampageSize每頁包含的記錄數
- *@return記錄對應的rownum
- */
- public static int getStartOfAnyPage( int pageNo, int pageSize){
- int startIndex=(pageNo-1)*pageSize+1;
- if (startIndex<1)startIndex=1;
- //System.out.println("PageNotoStartIndex:"+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;
- }
- /**
- *
- *@paramqueryJSFunctionName實現分頁的JS腳本名字,頁碼變動時會自動回調該方法
- *@parampageNoParamName頁碼參數名稱
- *@return
- */
- public String getHTML( String queryJSFunctionName, String pageNoParamName){
- if (getTotalPageCount()<1){
- return "<inputtype='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("<scriptlanguage=/"Javascript1.2/">/n")
- .append("function").append(gotoPage).append("(pageNo){/n")
- .append("varcurPage=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("returntrue;/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("returnfalse;/n")
- //.append("}/n")
- .append("}/n")
- .append("}")
- .append("</script>/n")
- .append("");
- html.append("<tableborder=0cellspacing=0cellpadding=0align=centerwidth=80%>/n")
- .append("<tr>/n")
- .append("<tdalign=left><br>/n");
- html.append("共").append(getTotalPageCount()).append("頁")
- .append("[").append(getStart()).append("..").append(getEnd())
- .append("/").append( this .getTotalSize()).append("]/n")
- .append("</td>/n")
- .append("<tdalign=right>/n");
- if (hasPreviousPage()){
- html.append("[<ahref='javascript:").append(gotoPage)
- .append("(").append(getCurrentPageNo()-1)
- .append(")'>上一頁</a>]/n");
- }
- html.append("第")
- .append("<selectname='")
- .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("<optionvalue='").append(i).append("'")
- .append(selected).append(">").append(i).append("</option>/n");
- }
- if (getCurrentPageNo()>getTotalPageCount()){
- html.append("<optionvalue='").append(getCurrentPageNo())
- .append("'selected>").append(getCurrentPageNo())
- .append("</option>/n");
- }
- html.append("</select>頁/n");
- if (hasNextPage()){
- html.append("[<ahref='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>
- *@authorevan_zhao@hotmail.com
- *@version1.0
- */
- public class RowSetPage extends Page{
- private javax.sql. RowSet rs;
- /**
- *空頁
- */
- public static final RowSetPageEMPTY_PAGE= new RowSetPage();
- /**
- *默認構造方法,創建空頁
- */
- public RowSetPage(){
- this ( null ,0,0);
- }
- /**
- *構造分頁對象
- *@paramcrs包含一頁數據的OracleCachedRowSet
- *@paramstart該頁數據在數據庫中的起始位置
- *@paramtotalSize數據庫中包含的記錄總數
- */
- public RowSetPage( RowSet crs, int start, int totalSize){
- this (crs,start,totalSize,Page.DEFAULT_PAGE_SIZE);
- }
- /**
- *構造分頁對象
- *@paramcrs包含一頁數據的OracleCachedRowSet
- *@paramstart該頁數據在數據庫中的起始位置
- *@paramtotalSize數據庫中包含的記錄總數
- *@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>
- *@authorevan_zhao@hotmail.com
- *@version1.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 RowSetPagerowSetPage;
- private List boundParams;
- /**
- *構造一查詢出所有數據的PageStatement
- *@paramsqlquerysql
- */
- public PagedStatement( String sql){
- this (sql,1,MAX_PAGE_SIZE);
- }
- /**
- *構造一查詢出當頁數據的PageStatement
- *@paramsqlquerysql
- *@parampageNo頁碼
- */
- public PagedStatement( String sql, int pageNo){
- this (sql,pageNo,Page.DEFAULT_PAGE_SIZE);
- }
- /**
- *構造一查詢出當頁數據的PageStatement,并指定每頁顯示記錄條數
- *@paramsqlquerysql
- *@parampageNo頁碼
- *@parampageSize每頁容量
- */
- 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="selectcount(*)from("+sql+")";
- this .querySQL=intiQuerySQL(sql, this .startIndex,pageSize);
- }
- /**
- *生成查詢一頁數據的sql語句
- *@paramsql原查詢語句
- *@startIndex開始記錄位置
- *@size需要獲取的記錄數
- */
- protected abstract String intiQuerySQL( String sql, int startIndex, int size);
- /**
- *使用給出的對象設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramobj包含參數值的對象
- */
- public void setObject( int index, Object obj) throws SQLException {
- BoundParambp= new BoundParam(index,obj);
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的對象設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramobj包含參數值的對象
- *@paramtargetSqlType參數的數據庫類型
- */
- public void setObject( int index, Object obj, int targetSqlType) throws SQLException {
- BoundParambp= new BoundParam(index,obj,targetSqlType);
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的對象設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramobj包含參數值的對象
- *@paramtargetSqlType參數的數據庫類型(常量定義在java.sql.Types中)
- *@paramscale精度,小數點后的位數
- *(只對targetSqlType是Types.NUMBER或Types.DECIMAL有效,其它類型則忽略)
- */
- public void setObject( int index, Object obj, int targetSqlType, int scale) throws SQLException {
- BoundParambp= new BoundParam(index,obj,targetSqlType,scale);
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的字符串設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramstr包含參數值的字符串
- */
- public void setString( int index, String str) throws SQLException {
- BoundParambp= new BoundParam(index,str);
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的字符串設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramtimestamp包含參數值的時間戳
- */
- public void setTimestamp( int index, Timestamp timestamp) throws SQLException {
- BoundParambp= new BoundParam(index,timestamp);
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的整數設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramvalue包含參數值的整數
- */
- public void setInt( int index, int value) throws SQLException {
- BoundParambp= new BoundParam(index, new Integer (value));
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的長整數設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramvalue包含參數值的長整數
- */
- public void setLong( int index, long value) throws SQLException {
- BoundParambp= new BoundParam(index, new Long (value));
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的雙精度浮點數設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@paramvalue包含參數值的雙精度浮點數
- */
- public void setDouble( int index, double value) throws SQLException {
- BoundParambp= new BoundParam(index, new Double (value));
- boundParams.remove(bp);
- boundParams.add(bp);
- }
- /**
- *使用給出的BigDecimal設置指定參數的值
- *@paramindex第一個參數為1,第二個為2,。。。
- *@parambd包含參數值的BigDecimal
- */
- public void setBigDecimal( int index, BigDecimal bd) throws SQLException {
- BoundParambp= 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 ;
- BoundParamparam;
- 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);
- }
- }
- }
- /**
- *執行查詢取得一頁數據,執行結束后關閉數據庫連接
- *@returnRowSetPage
- *@throwsSQLException
- */
- public RowSetPageexecuteQuery() 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("executeQuerySQLException");
- sqle.printStackTrace();
- throw sqle;
- } catch ( Exception e){
- e.printStackTrace();
- throw new RuntimeException (e.toString());
- } finally {
- //System.out.println("executeQueryfinally");
- DBUtil.close(rs,pst,conn);
- }
- }
- /**
- *將ResultSet數據填充進CachedRowSet
- */
- protected abstract RowSet populate( ResultSet rs) throws SQLException ;
- /**
- *取封裝成RowSet查詢結果
- *@returnRowSet
- */
- public javax.sql. RowSet getRowSet(){
- return this .rowSet;
- }
- /**
- *取封裝成RowSetPage的查詢結果
- *@returnRowSetPage
- */
- public RowSetPagegetRowSetPage(){
- 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)){
- BoundParambp=(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>
- *@authorevan_zhao@hotmail.com
- *@version1.0
- */
- public class PagedStatementOracleImpl extends PagedStatement{
- /**
- *構造一查詢出所有數據的PageStatement
- *@paramsqlquerysql
- */
- public PagedStatementOracleImpl( String sql){
- super (sql);
- }
- /**
- *構造一查詢出當頁數據的PageStatement
- *@paramsqlquerysql
- *@parampageNo頁碼
- */
- public PagedStatementOracleImpl( String sql, int pageNo){
- super (sql,pageNo);
- }
- /**
- *構造一查詢出當頁數據的PageStatement,并指定每頁顯示記錄條數
- *@paramsqlquerysql
- *@parampageNo頁碼
- *@parampageSize每頁容量
- */
- public PagedStatementOracleImpl( String sql, int pageNo, int pageSize){
- super (sql,pageNo,pageSize);
- }
- /**
- *生成查詢一頁數據的sql語句
- *@paramsql原查詢語句
- *@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(selectmy_table.*,rownumasmy_rownumfrom(")
- .append(sql)
- .append(")my_tablewhererownum<").append(startIndex+size)
- .append(")wheremy_rownum>=").append(startIndex);
- } else {
- querySQL.append("select*from(selectmy_table.*,rownumasmy_rownumfrom(")
- .append(sql)
- .append(")my_table")
- .append(")wheremy_rownum>=").append(startIndex);
- }
- return querySQL.toString();
- }
- /**
- *將ResultSet數據填充進CachedRowSet
- */
- protected RowSet populate( ResultSet rs) throws SQLException {
- OracleCachedRowSetocrs= new OracleCachedRowSet();
- ocrs.populate(rs);
- return ocrs;
- }
- }
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
