1. 程式人生 > >解決hibernate對Sql Server分頁慢的問題

解決hibernate對Sql Server分頁慢的問題

不知道 cfg sdn track and web項目 方法封裝 its 增加用戶

一、hibernate分頁 hibernate對MsSql的偽分頁
分頁是web項目中比不可少的一個功能,數據量大的時候不能全部展示必然要用到分頁技術。相信大家對hibernate中的分頁都不陌生:
Java代碼 技術分享
  1. public Query setMaxResults(int maxResults);
  2. public Query setFirstResult(int firstResult);

只要調用了這兩個方法並設置好參數,hibernate自動分頁完全屏蔽了底層數據庫分頁技術,這也是眾多開發者喜歡hibernate的原因之一。
項目開發中遇到一個奇怪的問題。數據庫采用的是Sql Server 2005,也設置了上面兩個參數,可是每次發送到數據庫端的SQL語句都是select top ....語句。即便是查詢第10w條,也只有一個select top 語句,不免引起對hibernate實現sql server分頁的懷疑。hibernate針對不同數據庫實現的分頁方法封裝在對應數據庫的方言裏,通過getLimitString方法轉化成對應數據庫的分頁算法。
以常見的Mysql數據庫的方言MySQLDialect為例:
Java代碼 技術分享
  1. public String getLimitString(String sql, boolean hasOffset) {
  2. return new StringBuffer( sql.length() + 20 )
  3. .append( sql )
  4. .append( hasOffset ? " limit ?, ?" : " limit ?" )
  5. .toString();
  6. }

采用了大家熟悉的mysql的limit進行分頁。
Oracle數據庫的方言Oracle9iDialect:
Java代碼 技術分享
  1. StringBuffer pagingSelect = new StringBuffer( sql.length()+100 );
  2. if (hasOffset) {
  3. pagingSelect.append("select * from ( select row_.*, rownum rownum_ from ( ");
  4. }
  5. else {
  6. pagingSelect.append("select * from ( ");
  7. }
  8. pagingSelect.append(sql);
  9. if (hasOffset) {
  10. pagingSelect.append(" ) row_ where rownum <= ?) where rownum_ > ?");
  11. }
  12. else {
  13. pagingSelect.append(" ) where rownum <= ?");
  14. }

利用Oracle的rownum 結合三層嵌套查詢完成分頁。這個三層是Oracle最經典高效的分頁算法。
可是針對Sql Server的方言SQLServerDialect:
Java代碼 技術分享
  1. public String getLimitString(String querySelect, int offset, int limit) {
  2. if ( offset > 0 ) {
  3. throw new UnsupportedOperationException( "query result offset is not supported" );
  4. }
  5. return new StringBuffer( querySelect.length() + 8 )
  6. .append( querySelect )
  7. .insert( getAfterSelectInsertPoint( querySelect ), " top " + limit )
  8. .toString();
  9. }

揉揉眼睛、再揉揉,沒錯,只出現了一個top語句。這就意味著如果查詢第10w頁的數據,需要把前10w頁數據全部提取出來。hibernate針對sql server的分頁是偽分頁,所以隨著數據量日益增加用戶抱怨系統速度慢,程序員抱怨hibernate性能低,dba抱怨開發人員sql功底太淺。
不知道hibernate開發組,出於什麽目前或情況沒有真正提供sql server的分頁技術,那我們自己來實現。
方言類:
Java代碼 技術分享
  1. public class SQLServer2005Dialect extends SQLServerDialect {
  2. /**
  3. *
  4. * 是否需要綁定limit參數?
  5. *
  6. * 在SQL Server中使用top時不能使用參數表示top條數,而使用ROW_NUMBER()則需要提供limit參數
  7. */
  8. private ThreadLocal<Boolean> supportsVariableLimit = new ThreadLocal<Boolean>();
  9. public SQLServer2005Dialect() {
  10. registerFunction("bitand", new BitAndFunction());
  11. registerFunction("bitxor", new BitXorFunction());
  12. registerFunction("bitor", new BitOrFunction());
  13. setSupportsVariableLimit(false);
  14. }
  15. /**
  16. *
  17. * <p>
  18. * 設置是否先綁定limit參數。
  19. * </p>
  20. *
  21. * @param first
  22. */
  23. private void setSupportsVariableLimit(boolean first) {
  24. this.supportsVariableLimit.set(Boolean.valueOf(first));
  25. }
  26. /**
  27. *
  28. * <p>
  29. * 獲取sql中select子句位置。
  30. * </p>
  31. *
  32. * @param sql
  33. *
  34. * @return int
  35. */
  36. protected static int getSqlAfterSelectInsertPoint(String sql) {
  37. int selectIndex = sql.toLowerCase().indexOf("select");
  38. int selectDistinctIndex = sql.toLowerCase().indexOf("select distinct");
  39. return selectIndex + ((selectDistinctIndex == selectIndex) ? 15 : 6);
  40. }
  41. public boolean supportsLimitOffset() {
  42. return true;
  43. }
  44. /*
  45. * Hibernate在獲得Limit String(已添加了limit子句)後,如果此方法返回true,
  46. *
  47. * 則會添加額外的參數值(ROW_NUMBER()範圍)(策略可能是這樣:有offset設置兩個參數值,沒有設置一個參數值)
  48. */
  49. public boolean supportsVariableLimit() {
  50. return ((Boolean) this.supportsVariableLimit.get()).booleanValue();
  51. }
  52. public boolean useMaxForLimit() {
  53. return true;
  54. }
  55. /**
  56. * 首頁top,以後用ROW_NUMBER
  57. */
  58. public String getLimitString(String query, int offset, int limit) {
  59. setSupportsVariableLimit(offset > 0);
  60. if (offset == 0) {
  61. return new StringBuffer(query.length() + 8).append(query).insert(
  62. getSqlAfterSelectInsertPoint(query), " top " + limit)
  63. .toString();
  64. }
  65. return getLimitString(query, offset > 0);
  66. }
  67. public String getLimitString(String sql, boolean hasOffset) {
  68. int orderByIndex = sql.toLowerCase().lastIndexOf("order by");
  69. if (orderByIndex <= 0) {
  70. throw new UnsupportedOperationException(
  71. "must specify ‘order by‘ statement to support limit operation with offset in sql server 2005");
  72. }
  73. String sqlOrderBy = sql.substring(orderByIndex + 8);
  74. String sqlRemoveOrderBy = sql.substring(0, orderByIndex);
  75. int insertPoint = getSqlAfterSelectInsertPoint(sql);
  76. return new StringBuffer(sql.length() + 100)
  77. .append("with tempPagination as(")
  78. .append(sqlRemoveOrderBy)
  79. .insert(
  80. insertPoint + 23,
  81. " ROW_NUMBER() OVER(ORDER BY " + sqlOrderBy
  82. + ") as RowNumber,")
  83. .append(
  84. ") select * from tempPagination where RowNumber>? and RowNumber<=?")
  85. .toString();
  86. }
  87. }


最後在配置hibernate的時候在 hibernate.cfg.xml 配置 dialect 使用自己的SQLServer2005Dialect類

<property name="dialect"> com.common.SQLServer2005Dialect </property> 或在與spring的集成配置文件中

<prop key="hibernate.dialect">com.common.SQLServer2005Dialect</prop>

在分頁時,就可以達到很好的效率了。


第一頁采用top分頁,以後采用ROW_NUMBER分頁第一頁以上查詢要求sql中必須含有排序子句。
這只是在項目過程中采用的sql server遇到的該問題,如果使用mysql,oracle則不會遇到這個問題。

解決hibernate對Sql Server分頁慢的問題