hibernate分頁處理

openkk 13年前發布 | 3K 次閱讀 報表工具

分頁在任何系統中都是非常頭疼的事情，有的數據庫在語法上支持分頁，而有的數據庫則需要使用可滾動游標來實現，并且在不支持可滾動游標的系統上只能使用單向游標逐步接近要取得的數據。
Hibernate提供了一個支持跨系統的分頁機制，這樣無論底層是什么樣的數據庫都能用統一的接口進行分頁操作。比如下面的代碼就是從第500條開始取出100條記錄:

  1. Query q = session.createQuery("from FooBar as f");    
  2. q.setFirstResult(500);    
  3. q.setMaxResults(100);    
  4. List l = q.list();   

那么Hibernate底層如何實現分頁的呢？Hibernate根據Query拼裝SQL語句的地方是在org.hibernate.loader.Loader類的prepareQueryStatement方法中，對分頁支持的代碼在這一段中可以發現：

  1. if (useLimit)    
  2. {   
  3. sql = dialect.getLimitString(    
  4.      sql.trim(), //use of trim() here is ugly?   
  5.      useOffset ? getFirstRow(selection) : 0,    
  6.      getMaxOrLimit(selection, dialect)    
  7.     );   
  8.  }   

 此處調用Dialect的getLimitString方法來得到不同平臺的分頁語句。
在MySQLDialect中是如下實現getLimitString方法的：

  1. public String getLimitString(String sql, boolean hasOffset)    
  2. {   
  3. return new StringBuffer( sql.length()+20 )   
  4. .append(sql)   
  5. .append( hasOffset ? " limit ?, ?" : " limit ?")   
  6. .toString();   
  7. }   

 這是MySQL的專用分頁語句，再來看Oracle9Dialect：

  1. public String getLimitString(String sql, boolean hasOffset) {   
  2.     
  3.  sql = sql.trim();   
  4.  boolean isForUpdate = false;   
  5.  if ( sql.toLowerCase().endsWith(" for update") ) {   
  6.   sql = sql.substring( 0, sql.length()-11 );   
  7.   isForUpdate = true;   
  8.  }   
  9.     
  10.  StringBuffer pagingSelect = new StringBuffer( sql.length()+100 );   
  11.  if (hasOffset) {   
  12.   pagingSelect.append("select * from ( select row_.*, rownum rownum_ from ( ");   
  13.  }   
  14.  else {   
  15.   pagingSelect.append("select * from ( ");   
  16.  }   
  17.  pagingSelect.append(sql);   
  18.  if (hasOffset) {   
  19.   pagingSelect.append(" ) row_ where rownum <= ?) where rownum_ > ?");   
  20.  }   
  21.  else {   
  22.   pagingSelect.append(" ) where rownum <= ?");   
  23.  }   
  24.   
  25.  if ( isForUpdate ) {   
  26.   pagingSelect.append( " for update" );   
  27.  }   
  28.     
  29.  return pagingSelect.toString();   
  30. }    

Oracle采用嵌套3層的查詢語句結合rownum來實現分頁，這在Oracle上是最好的方式，因為如果只是一層或者兩層的查詢語句的rownum不能支持order by。
此外Interbase，PostgreSQL，HSQL等也在語法級別上支持分頁，具體實現可以查看相應的Dialect實現。如果數據庫不支持分頁的 SQL語句，那么如果數據庫支持可滾動游標，那么Hibernate就會采使用ResultSet的absolute方法直接移到查詢起點；否則使用循環語句，通過rs.next一步步移動到要查詢的數據處：

  1. final int firstRow = getFirstRow( selection );   
  2. if ( firstRow != 0 )    
  3. {   
  4. if ( getFactory().getSettings().isScrollableResultSetsEnabled() )    
  5. {   
  6. // we can go straight to the first required row   
  7. rs.absolute( firstRow );   
  8. }   
  9. else    
  10. {   
  11. // we need to step through the rows one row at a time (slow)   
  12. for ( int m = 0; m < firstRow; m++ ) rs.next();   
  13. }   
  14. }   

可見使用Hibernate，在進行查詢分頁的操作上，是具有非常大的靈活性，Hibernate會首先嘗試用特定數據庫的分頁sql，如果沒用，再嘗試Scrollable，如果不支持Scrollable再采用rset.next()移動的辦法。這樣既兼顧了查詢分頁的性能，同時又保證了代碼在不同的數據庫之間的可移植性。 

 本文由用戶 openkk 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
 轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！