posts - 2,  comments - 2,  trackbacks - 0
                  前言
          在使用數據庫的過程中,不可避免的需要使用到分頁的功能,可是JDBC的規范對此卻沒有很好的解決。對于這個需求很多朋友都有自己的解決方案,比如使用Vector等集合類先保存取出的數據再分頁。但這種方法的可用性很差,與JDBC本身的接口完全不同,對不同類型的字段的支持也不好。這里提供了一種與JDBC兼容性非常好的方案。
          JDBC和分頁
            Sun的JDBC規范的制定,有時很讓人哭笑不得,在JDBC1.0中,對于一個結果集(ResultSet)你甚至只能執行next()操作,而無法讓其向后滾動,這就直接導致在只執行一次SQL查詢的情況下無法獲得結果集的大小。所以,如果你使用的是JDBC1.0的驅動,那么是幾乎無法實現分頁的。
            好在Sun的JDBC2規范中很好的彌補了這一個不足,增加了結果集的前后滾動操作,雖然仍然不能直接支持分頁,但我們已經可以在這個基礎上寫出自己的可支持分頁的ResultSet了。

          和具體數據庫相關的實現方法
            有一些數據庫,如Mysql, Oracle等有自己的分頁方法,比如Mysql可以使用limit子句,Oracle可以使用ROWNUM來限制結果集的大小和起始位置。這里以Mysql為例,其典型代碼如下:
          // 計算總的記錄條數
          String SQL = "SELECT Count(*) AS total " + this.QueryPart;
          rs = db.executeQuery(SQL);
          if (rs.next())
          Total = rs.getInt(1);
          // 設置當前頁數和總頁數
          TPages = (int)Math.ceil((double)this.Total/this.MaxLine);
          CPages = (int)Math.floor((double)Offset/this.MaxLine+1);
          // 根據條件判斷,取出所需記錄
          if (Total > 0) {
          SQL = Query + " LIMIT " + Offset + " , " + MaxLine;
          rs = db.executeQuery(SQL);
          }
          return rs;
          }
            毫無疑問,這段代碼在數據庫是Mysql時將會是漂亮的,但是作為一個通用的類(事實上我后面要提供的就是一個通用類庫中的一部分),需要適應不同的數據庫,而基于這個類(庫)的應用,也可能使用不同的數據庫,所以,我們將不使用這種方法。

          另一種繁瑣的實現方法
            我看過一些人的做法(事實上包括我在內,一開始也是使用這種方法的),即不使用任何封裝,在需要分頁的地方,直接操作ResultSet滾到相應的位置,再讀取相應數量的記錄。其典型代碼如下:
          <%
          sqlStmt = sqlCon.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,
          java.sql.ResultSet.CONCUR_READ_ONLY);
          strSQL = "select name,age from test";
          //執行SQL語句并獲取結果集
          sqlRst = sqlStmt.executeQuery(strSQL);
          //獲取記錄總數
          sqlRst.last();
          intRowCount = sqlRst.getRow();
          //記算總頁數
          intPageCount = (intRowCount+intPageSize-1) / intPageSize;
          //調整待顯示的頁碼
          if(intPage>intPageCount) intPage = intPageCount;
          %>
          <table border="1" cellspacing="0" cellpadding="0">
          <tr>
          <th>姓名</th>
          <th>年齡</th>
          </tr>
          <%
          if(intPageCount>0){
          //將記錄指針定位到待顯示頁的第一條記錄上
          sqlRst.absolute((intPage-1) * intPageSize + 1);
          //顯示數據
          i = 0;
          while(i<intPageSize && !sqlRst.isAfterLast()){
          %>
          <tr>
          <td><%=sqlRst.getString(1)%></td>
          <td><%=sqlRst.getString(2)%></td>
          </tr>
          <%
          sqlRst.next();
          i++;
          }
          }
          %>
          </table>
            很顯然,這種方法沒有考慮到代碼重用的問題,不僅代碼數量巨大,而且在代碼需要修改的情況下,將會無所適從。


          使用Vector進行分頁
            還見過另一些實現分頁的類,是先將所有記錄都select出來,然后將ResultSet中的數據都get出來,存入Vector等集合類中,再根據所需分頁的大小,頁數,定位到相應的位置,讀取數據。或者先使用前面提到的兩種分頁方法,取得所需的頁面之后,再存入Vector中。
            扔開代碼的效率不說,單是從程序結構和使用的方便性上講,就是很糟糕的。比如,這種做法支持的字段類型有限,int, double, String類型還比較好處理,如果碰到Blob, Text等類型,實現起來就很麻煩了。這是一種更不可取的方案。


          一個新的Pageable接口及其實現
            很顯然,看過上面三種實現方法后,我們對新的分頁機制有了一個目標,即:不與具體數據庫相關;盡可能做到代碼重用;盡可能與原JDBC接口的使用方法保持一致;盡可能高的效率。
            首先,我們需要提供一個與java.sql.ResultSet向下兼容的接口,把它命名為Pageable,接口定義如下:
          public interface Pageable extends java.sql.ResultSet{
          /**返回總頁數
          */
          int getPageCount();
          /**返回當前頁的記錄條數
          */
          int getPageRowsCount();
          /**返回分頁大小
          */
          int getPageSize();
          /**轉到指定頁
          */
          void gotoPage(int page) ;
          /**設置分頁大小
          */
          void setPageSize(int pageSize);
          /**返回總記錄行數
          */
          int getRowsCount();
          /**
          * 轉到當前頁的第一條記錄
          * @exception java.sql.SQLException 異常說明。
          */
          void pageFirst() throws java.sql.SQLException;
          /**
          * 轉到當前頁的最后一條記錄
          * @exception java.sql.SQLException 異常說明。
          */
          void pageLast() throws java.sql.SQLException;
          /**返回當前頁號
          */
          int getCurPage();
          }
            這是一個對java.sql.ResultSet進行了擴展的接口,主要是增加了對分頁的支持,如設置分頁大小,跳轉到某一頁,返回總頁數等等。
            接著,我們需要實現這個接口,由于這個接口繼承自ResultSet,并且它的大部分功能也都和ResultSet原有功能相同,所以這里使用了一個簡單的Decorator模式。
            PageableResultSet2的類聲明和成員聲明如下:
          public class PageableResultSet2 implements Pageable {
          protected java.sql.ResultSet rs=null;
          protected int rowsCount;
          protected int pageSize;
          protected int curPage;
          protected String command = "";
          }
            可以看到,在PageableResultSet2中,包含了一個ResultSet的實例(這個實例只是實現了ResultSet接口,事實上它是由各個數據庫廠商分別實現的),并且把所有由ResultSet繼承來的方法都直接轉發給該實例來處理。
            PageableResultSet2中繼承自ResultSet的主要方法:
          //……
          public boolean next() throws SQLException {
          return rs.next();
          }
          //……
          public String getString(String columnName) throws SQLException {
          try {
          return rs.getString(columnName);
          }
          catch (SQLException e) {//這里是為了增加一些出錯信息的內容便于調試
          throw new SQLException (e.toString()+" columnName="
          +columnName+" SQL="+this.getCommand());
          }
          }
          //……
            只有在Pageable接口中新增的方法才需要自己的寫方法處理。
          /**方法注釋可參考Pageable.java
          */
          public int getCurPage() {
          return curPage;
          }
          public int getPageCount() {
          if(rowsCount==0) return 0;
          if(pageSize==0) return 1;
          //calculate PageCount
          double tmpD=(double)rowsCount/pageSize;
          int tmpI=(int)tmpD;
          if(tmpD>tmpI) tmpI++;
          return tmpI;
          }
          public int getPageRowsCount() {
          if(pageSize==0) return rowsCount;
          if(getRowsCount()==0) return 0;
          if(curPage!=getPageCount()) return pageSize;
          return rowsCount-(getPageCount()-1)*pageSize;
          }
          public int getPageSize() {
          return pageSize;
          }
          public int getRowsCount() {
          return rowsCount;
          }
          public void gotoPage(int page) {
          if (rs == null)
          return;
          if (page < 1)
          page = 1;
          if (page > getPageCount())
          page = getPageCount();
          int row = (page - 1) * pageSize + 1;
          try {
          rs.absolute(row);
          curPage = page;
          }
          catch (java.sql.SQLException e) {
          }
          }
          public void pageFirst() throws java.sql.SQLException {
          int row=(curPage-1)*pageSize+1;
          rs.absolute(row);
          }
          public void pageLast() throws java.sql.SQLException {
          int row=(curPage-1)*pageSize+getPageRowsCount();
          rs.absolute(row);
          }
          public void setPageSize(int pageSize) {
          if(pageSize>=0){
          this.pageSize=pageSize;
          curPage=1;
          }
          }
            PageableResultSet2的構造方法:
          public PageableResultSet2(java.sql.ResultSet rs) throws java.sql.SQLException {
          if(rs==null) throw new SQLException("given ResultSet is NULL","user");

          rs.last();
          rowsCount=rs.getRow();
          rs.beforeFirst();

          this.rs=rs;
          }
            這里只是簡單的取得一個總記錄數,并將記錄游標移回初始位置(before first),同時將參數中的ResultSet賦給成員變量。


          Pageable的使用方法
            因為Pageable接口繼承自ResultSet,所以在使用方法上與ResultSet一致,尤其是在不需要分頁功能的時候,可以直接當成ResultSet使用。而在需要分頁時,只需要簡單的setPageSize, gotoPage,即可。
          PreparedStatement pstmt=null;
          Pageable rs=null;
          ……//構造SQL,并準備一個pstmt.
          rs=new PageableResultSet2(pstmt.executeQuery());//構造一個Pageable
          rs.setPageSize(20);//每頁20個記錄
          rs.gotoPage(2);//跳轉到第2頁
          for(int i=0; i<rs.getPageRowsCount(); i++){//循環處理
          int id=rs.getInt(“ID”);
          ……//繼續處理


          總結
            一個好的基礎類應該是便于使用,并且具備足夠的可移植性,同時要保證其功能的完善。在上面的實現中,我們從java.sql.ResultSet接口繼承出Pageable,并實現了它。這就保證了在使用中與JDBC原有操作的一致性,同時對原有功能沒有縮減。
            同時它也是易于使用的,因為封裝了一切必要的操作,所以在你的代碼中唯一顯得"難看"和"不舒服"的地方就是需要自己去構造一個PageableResultSet2。不過只要你愿意,這也是可以解決的。
            當然它也有具有充分的可移植性,當你將數據庫由Oracle變為Mysql或者SQLServer的時候,你仍然可以使用這些分頁的代碼。它在使用中(或者說在移植的過程中)唯一的限制就是你必須要使用一個支持JDBC2的驅動(現在明白為什么我把類命名為PageableResultSet2了吧。:P),不過,好在JDBC2已經成為標準了,絕大多數的數據庫(如Oracle, Mysql, SQLServer)都有自己的或者第三方提供的JDBC2的驅動。
            OK,這個分頁的實現是否對你的編程有幫助呢?仔細看看,其實真正自己寫的代碼并不多的,大部分都只是簡單的轉發操作。一個合適的模式應用可以幫你很大忙

            想飛到 那最高最遠最灑脫
          posted on 2007-12-08 20:20 fighting 閱讀(67) 評論(0)  編輯  收藏

          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          <2025年6月>
          25262728293031
          1234567
          891011121314
          15161718192021
          22232425262728
          293012345

          常用鏈接

          留言簿(1)

          隨筆檔案

          文章檔案

          搜索

          •  

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 佛冈县| 胶州市| 龙州县| 资阳市| 双城市| 衡东县| 永川市| 车致| 海阳市| 斗六市| 定远县| 句容市| 应城市| 渭源县| 雷波县| 仲巴县| 囊谦县| 重庆市| 雅江县| 如东县| 偏关县| 石嘴山市| 大方县| 临邑县| 邢台县| 合江县| 英超| 临武县| 图木舒克市| 涟源市| 西乌珠穆沁旗| 松江区| 南充市| 吉木萨尔县| 斗六市| 凉城县| 重庆市| 洛川县| 靖远县| 汾阳市| 延津县|