学习struts2建bbs总结六：hibernate分页查询的问题--分页后程序定时无响应_Tomcat, WebLogic及J2EE讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛_联动北方技术论坛  
网站首页 | 关于我们 | 服务中心 | 经验交流 | 公司荣誉 | 成功案例 | 合作伙伴 | 联系我们 |
联动北方技术论坛-国内领先的Weblogic、Tuxedo中间件技术论坛
联动北方-国内领先的云技术服务提供商
»  游客             当前位置：  论坛首页 »  自由讨论区 »  Tomcat, WebLogic及J2EE讨论区 »
总帖数
1
每页帖数
101/1页1
返回列表
0
发起投票  发起投票 发新帖子
查看: 4415 | 回复: 0   主题： 学习struts2建bbs总结六：hibernate分页查询的问题--分页后程序定时无响应        下一篇 
fangdingyu
注册用户
等级：少校
经验：1238
发帖：55
精华：25
注册：2013-3-6
状态：离线
发送短消息息给fangdingyu 加好友    发送短消息息给fangdingyu 发消息
发表于： IP：您无权察看 2013-3-12 12:07:47 | [全部帖] [楼主帖] 楼主
 在bbs、电子商务等众多系统中，分页是一个必不可少的功能。在hibernate中，setFirstResult以及setMaxResults方法给分页的实现带来了极大方便。参考了不少网上资源，结合我自己的系统需要，新建了一个pageDAO类，实现分页查询功能，有生成了接口以供调用。我并没有建pageBean，我下了不少网上的代码，估计对分页太不了解吧，看的头大，最后选择了比较简单的方法，后台实现分页查询，前台用el表达式慢慢判断、分页输出吧。

   但是，当我认为成功的实现了分页功能时，忽然发现一个问题，就是每当程序运行，没多久程序就似乎死机一样，失去了响应。只能重启tomcat，然而重启后，我连续发帖7、8个，又变成无响应状态。为此，我在网上请教了不少朋友。
  其中，我的分页函数是：
[java]view plaincopyprint?

  1. //注意：这个函数是有问题的，下文说明改进。 
  2. public List findByPropertyPage(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) { 
  3.        StringBuffer strBuffer = new StringBuffer(); 
  4.        strBuffer.append("from "); 
  5.        strBuffer.append(Whichclass); 
  6.        strBuffer.append(" as model where "); 
  7.       for (int i = 0; i < propertyNames.length; i++) 
  8.        { 
  9.             if (i != 0) 
  10.              strBuffer.append(" and"); 
  11.              strBuffer.append(" model."); 
  12.              strBuffer.append(propertyNames[i]); 
  13.              strBuffer.append("="); 
  14.              strBuffer.append("? "); //Topic 
  15.        } 
  16.       if (Whichclass.equals("Topic")) { 
  17.              strBuffer.append("order by postTime desc "); 
  18.        } 
  19.       
  20.        String queryString = strBuffer.toString(); 
  21.       int firstResult = (page - 1) * pageSize; 
  22.        List list=null; 
  23.       try { 
  24.              Query query =<SPAN style="FONT-FAMILY: simsun">this.getSession()</SPAN><SPAN style="FONT-FAMILY: simsun">.createQuery(queryString);</SPAN> 
  25.              query.setFirstResult(firstResult); 
  26.              query.setMaxResults(pageSize); 
  27.             for (int i = 0; i < values.length; i++) 
  28.              { 
  29.                    query.setParameter(i, values[i]); 
  30.              } 
  31.              list =query.list(); 
  32.        } finally { 
  33.       
  34.  } 
  35. return list; 
  36.  } 


//注意：这个函数是有问题的，下文说明改进。
public List findByPropertyPage(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) {
       StringBuffer strBuffer = new StringBuffer();
       strBuffer.append("from ");
       strBuffer.append(Whichclass);
       strBuffer.append(" as model where ");
       for (int i = 0; i < propertyNames.length; i++)
       {
             if (i != 0)
             strBuffer.append(" and");
             strBuffer.append(" model.");
             strBuffer.append(propertyNames[i]);
             strBuffer.append("=");
             strBuffer.append("? "); //Topic
       }
       if (Whichclass.equals("Topic")) {
             strBuffer.append("order by postTime desc ");
       }

       String queryString = strBuffer.toString();
       int firstResult = (page - 1) * pageSize;
       List list=null;
       try {
             Query query =this.getSession().createQuery(queryString);
             query.setFirstResult(firstResult);
             query.setMaxResults(pageSize);
             for (int i = 0; i < values.length; i++)
             {
                   query.setParameter(i, values[i]);
             }
             list =query.list();
       } finally {

}
return list;
}


当我在网上请教时，一位朋友告知，大概是因为使用了setFirstResult以及setMaxResults方法，说这2个方法常常引发这样的问题，即程序长时间无响应。我大喜过望，询问后试着用sql的limit直接实现分页，不用hibernate那2个方法。代码如下：

[java]view plaincopyprint?

  1. //注意：这个函数是有问题的，下文说明改进。 
  3. public List findByPropertyPageSQL(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) { 
  4.        StringBuffer strBuffer = new StringBuffer(); 
  5.        strBuffer.append("select * from "); 
  6.        strBuffer.append(Whichclass); 
  7.        strBuffer.append(" as model where "); 
  8.       for (int i = 0; i < propertyNames.length; i++) 
  9.        { 
  10.             if (i != 0) 
  11.              strBuffer.append(" and"); 
  12.              strBuffer.append(" model."); 
  13.              strBuffer.append(propertyNames[i]); 
  14.              strBuffer.append("="); 
  15.              strBuffer.append("? "); //Topic 
  16.        } 
  17.       if (Whichclass.equals("Topic")) { 
  18.              strBuffer.append("order by postTime desc "); 
  19.        } 
  20.        strBuffer.append("limit "); 
  21.        strBuffer.append((page - 1) * pageSize);//limit是从0开始的 
  22.        strBuffer.append(","); 
  23.        strBuffer.append(pageSize); 
  24.       
  25.        String queryString = strBuffer.toString(); 
  26.        List list = new ArrayList(); 
  27.       try{ 
  28.              Query query = this.getSession().createSQLQuery(queryString).addEntity(Class.forName("pengbbs.dao."+Whichclass)); 
  29.             for (int i = 0; i < values.length; i++) 
  30.              { 
  31.                    query.setParameter(i, values[i]); 
  32.              } 
  33.              list=query.list(); 
  34.             
  35.        }catch (Exception e) { 
  36.       // TODO: handle exception 
  37.        e.printStackTrace(); 
  38.  } 
  39. return list; 
  40. } 


//注意：这个函数是有问题的，下文说明改进。

public List findByPropertyPageSQL(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) {
       StringBuffer strBuffer = new StringBuffer();
       strBuffer.append("select * from ");
       strBuffer.append(Whichclass);
       strBuffer.append(" as model where ");
       for (int i = 0; i < propertyNames.length; i++)
       {
             if (i != 0)
             strBuffer.append(" and");
             strBuffer.append(" model.");
             strBuffer.append(propertyNames[i]);
             strBuffer.append("=");
             strBuffer.append("? "); //Topic
       }
       if (Whichclass.equals("Topic")) {
             strBuffer.append("order by postTime desc ");
       }
       strBuffer.append("limit ");
       strBuffer.append((page - 1) * pageSize);//limit是从0开始的
       strBuffer.append(",");
       strBuffer.append(pageSize);

       String queryString = strBuffer.toString();
       List list = new ArrayList();
       try{
             Query query = this.getSession().createSQLQuery(queryString).addEntity(Class.forName("pengbbs.dao."+Whichclass));
             for (int i = 0; i < values.length; i++)
             {
                   query.setParameter(i, values[i]);
             }
             list=query.list();

       }catch (Exception e) {
       // TODO: handle exception
       e.printStackTrace();
}
return list;
}


可是我发现问题依旧！后来我查询了许多资料，也怪自己没深入学习，其实上面的代码和第一个setFirstResult方法是一样的，setFirstResult方法内部其实正是像上面那样执行limit，我只不过是无事找事，写了sql语句出来徒劳而已。如果真的不要setFirstResult，除非直接用jdbc吧。但如果这样，还用hibernate何用？所以下意识才知道，应该不是setFirstResult方法的问题。

又有朋友猜测，说肯定没有关闭数据库连接导致的。但是又说，我既然已经用了hibernate模版实现，则数据库的连接与关闭则并不需要我们来干涉啊。此问题我甚至以为是某些bug吧，后来终于在一篇博客上发现了问题，问题就在：

 Query query =this.getSession().createQuery(queryString);


这句代码，发现创建了一个session，但是程序最末却并未关闭他它，果然是没有关闭数据库连接导致的。终于解决了。最终代码如下：

[java]view plaincopyprint?

  1. public List findByPropertyPageSQL(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) { 
  2.        StringBuffer strBuffer = new StringBuffer(); 
  3.        strBuffer.append("select * from "); 
  4.        strBuffer.append(Whichclass); 
  5.        strBuffer.append(" as model where "); 
  6.       for (int i = 0; i < propertyNames.length; i++) 
  7.        { 
  8.             if (i != 0) 
  9.              strBuffer.append(" and"); 
  10.              strBuffer.append(" model."); 
  11.              strBuffer.append(propertyNames[i]); 
  12.              strBuffer.append("="); 
  13.              strBuffer.append("? "); //Topic 
  14.        } 
  15.       if (Whichclass.equals("Topic")) { 
  16.              strBuffer.append("order by postTime desc "); 
  17.        } 
  18.        strBuffer.append("limit "); 
  19.        strBuffer.append((page - 1) * pageSize);//limit是从0开始的 
  20.        strBuffer.append(","); 
  21.        strBuffer.append(pageSize); 
  22.       
  23.        String queryString = strBuffer.toString(); 
  24.        List list = new ArrayList(); 
  25.        Session s=this.getSession(); 
  26.       try{ 
  27.              Query query = s.createSQLQuery(queryString).addEntity(Class.forName("pengbbs.dao."+Whichclass)); 
  28.             for (int i = 0; i < values.length; i++) 
  29.              { 
  30.                    query.setParameter(i, values[i]); 
  31.              } 
  32.              list=query.list(); 
  33.             
  34.        }catch (Exception e) { 
  35.       // TODO: handle exception 
  36.        e.printStackTrace(); 
  37.  }finally { 
  38.  s.close(); //此要记得关闭连接关闭session，不然问题大了，死机的。 
  39.  } 
  41. return list; 
  42.  } 
  44. @Override
  45. public List findByPropertyPage(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) { 
  46.        StringBuffer strBuffer = new StringBuffer(); 
  47.        strBuffer.append("from "); 
  48.        strBuffer.append(Whichclass); 
  49.        strBuffer.append(" as model where "); 
  50.       for (int i = 0; i < propertyNames.length; i++) 
  51.        { 
  52.             if (i != 0) 
  53.              strBuffer.append(" and"); 
  54.              strBuffer.append(" model."); 
  55.              strBuffer.append(propertyNames[i]); 
  56.              strBuffer.append("="); 
  57.              strBuffer.append("? "); //Topic 
  58.        } 
  59.       if (Whichclass.equals("Topic")) { 
  60.              strBuffer.append("order by postTime desc "); 
  61.        } 
  62.       
  63.        String queryString = strBuffer.toString(); 
  64.       int firstResult = (page - 1) * pageSize; 
  65.        Session s=this.getSession(); 
  66.        List list=null; 
  67.       try { 
  68.              Query query = s.createQuery(queryString); 
  69.              query.setFirstResult(firstResult); 
  70.              query.setMaxResults(pageSize); 
  71.             for (int i = 0; i < values.length; i++) 
  72.              { 
  73.                    query.setParameter(i, values[i]); 
  74.              } 
  75.              list =query.list(); 
  76.        } finally { 
  77.        s.close(); //此要记得关闭连接关闭session，不然问题大了，死机的。 
  78.  } 
  79. return list; 
  80.  } 


public List findByPropertyPageSQL(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) {
       StringBuffer strBuffer = new StringBuffer();
       strBuffer.append("select * from ");
       strBuffer.append(Whichclass);
       strBuffer.append(" as model where ");
       for (int i = 0; i < propertyNames.length; i++)
       {
             if (i != 0)
             strBuffer.append(" and");
             strBuffer.append(" model.");
             strBuffer.append(propertyNames[i]);
             strBuffer.append("=");
             strBuffer.append("? "); //Topic
       }
       if (Whichclass.equals("Topic")) {
             strBuffer.append("order by postTime desc ");
       }
       strBuffer.append("limit ");
       strBuffer.append((page - 1) * pageSize);//limit是从0开始的
       strBuffer.append(",");
       strBuffer.append(pageSize);

       String queryString = strBuffer.toString();
       List list = new ArrayList();
       Session s=this.getSession();
       try{
             Query query = s.createSQLQuery(queryString).addEntity(Class.forName("pengbbs.dao."+Whichclass));
             for (int i = 0; i < values.length; i++)
             {
                   query.setParameter(i, values[i]);
             }
             list=query.list();

       }catch (Exception e) {
       // TODO: handle exception
       e.printStackTrace();
}finally {
s.close(); //此要记得关闭连接关闭session，不然问题大了，死机的。
}

return list;
}

@Override
public List findByPropertyPage(String Whichclass, String []propertyNames, Object []values,int page, int pageSize) {
       StringBuffer strBuffer = new StringBuffer();
       strBuffer.append("from ");
       strBuffer.append(Whichclass);
       strBuffer.append(" as model where ");
       for (int i = 0; i < propertyNames.length; i++)
       {
             if (i != 0)
             strBuffer.append(" and");
             strBuffer.append(" model.");
             strBuffer.append(propertyNames[i]);
             strBuffer.append("=");
             strBuffer.append("? "); //Topic
       }
       if (Whichclass.equals("Topic")) {
             strBuffer.append("order by postTime desc ");
       }

       String queryString = strBuffer.toString();
       int firstResult = (page - 1) * pageSize;
       Session s=this.getSession();
       List list=null;
       try {
             Query query = s.createQuery(queryString);
             query.setFirstResult(firstResult);
             query.setMaxResults(pageSize);
             for (int i = 0; i < values.length; i++)
             {
                   query.setParameter(i, values[i]);
             }
             list =query.list();
       } finally {
       s.close(); //此要记得关闭连接关闭session，不然问题大了，死机的。
}
return list;
}



其实在这个分页函数的解决过程中，有一插曲，差点我就没能真正解决。我曾发帖http://topic.csdn.net/u/20120808/11/8607d338-595e-40b5-85d2-5d7e55fa201b.html询问，有不少朋友均指出是没有关闭数据库连接，但由于我使用了hibernate，大概又没看到getSession（）这行代码，所以暂时并无解决方案。我后来看到一篇文章，设计spring中的配置数据库连接，我加了这样一段：

[html]view plaincopyprint?

  1. <propertyname="maxIdle"value="50"></property>
  2. <propertyname="maxWait"value="5000"></property>
  3. <propertyname="maxActive"value="50"></property>
  4. <propertyname="defaultAutoCommit"value="true"></property>
  5. <propertyname="removeAbandonedTimeout"value="600"></property>


<property name="maxIdle" value="50"></property>
<property name="maxWait" value="5000"></property>
<property name="maxActive" value="50"></property>
<property name="defaultAutoCommit" value="true"></property>
<property name="removeAbandonedTimeout" value="600"></property>


发现死机的情况没了，我竟以为解决了，辛亏ldh911朋友指出，我这段代码其实就是增加了数据库连接数量而已，如改为

[html]view plaincopyprint?

  1. <propertyname="maxIdle"value="5"></property>
  2. <propertyname="maxWait"value="5000"></property>
  3. <propertyname="maxActive"value="5"></property>
  4. <propertyname="defaultAutoCommit"value="true"></property>
  5. <propertyname="removeAbandonedTimeout"value="600"></property>


<property name="maxIdle" value="5"></property>
<property name="maxWait" value="5000"></property>
<property name="maxActive" value="5"></property>
<property name="defaultAutoCommit" value="true"></property>
<property name="removeAbandonedTimeout" value="600"></property>

问题其实依旧。

所以我才有继续寻找问题关键，终于找到是上面session没有关闭，这个问题。关于session没关闭，网上有文章说也可以通过spring事务解决，即把这个连接让spring管理即可，并且响应速度似乎更快。这个我没有去试。在以后的学习中，再深入学习spring吧。

不过庆幸的是，分页函数问题终于解决了，如哪位大哥看到还有问题还望不吝指导。

后面action、jsp页面就简单了。希望大家都别再犯和我一样的错误了。

    在action中，我定义了三个变量就好（我在网上看到许多文章中自己创建的pageBean那么多的变量，那么多的函数，我十分的头大....）

private Integer page;//当前页
private Integer allpage;//总页数
private Integer pageSize=5;//每页显示的数目


生成get，set方法。我习惯用session，在action返回值前，写上了

session.put("allPage", allPage);
session.put("page", page);


其中，当第一次打开主题页，肯定显示第一页，所以action里，如果page=null，就把page=1，其中计算总页数方法：

allPage= (allRows+pageSize-1) / pageSize; // 计算总页数，allRows是符合条件的记录总数


当打开第一页的主题页后，即这个jsp文件，使用el表达式做一些if，else判断，总的说，当存在上一页或下一页，则显示出超链接，不然则无链接，且颜色显示也不一样。
代码如下：

[html]view plaincopyprint?

  1. <center>
  2.                             总共有${allPage}页,     当前是第${page}页   
  3. <c:choose>
  4. <c:whentest="${allPage<=1}">
  5. <fontsize="2"color="blue">首页</font>
  6. <fontsize="2"color="blue">上一页</font>
  7. <fontsize="2"color="blue">下一页</font>
  8. <fontsize="2"color="blue">末页</font>
  9. </c:when>
  11. <c:otherwise>
  12. <c:choose>
  13. <c:whentest="${page==1}">
  14. <fontsize="2"color="blue">首页</font></a>
  15. <fontsize="2"color="blue">上一页</font></a>
  16. <ahref="post_viewTopics.action?page=${page+1}&boardName=<%=str%>"><fontsize="2"color="red">下一页</font></a>
  17. <ahref="post_viewTopics.action?page=${allPage}&boardName=<%=str%>"><fontsize="2"color="red">末页</font></a>
  18. </c:when>
  19. <c:whentest="${page>1}">
  20. <ahref="post_viewTopics.action?page=1&boardName=<%=str%>"><fontsize="2"color="red">首页</font></a>
  21. <ahref="post_viewTopics.action?page=${page-1}&boardName=<%=str%>"><fontsize="2"color="red">上一页</font></a>
  22. <c:choose>
  23. <c:whentest="${allPage>page}">
  24. <ahref="post_viewTopics.action?page=${page+1}&boardName=<%=str%>"><fontsize="2"color="red">下一页</font></a>
  25. <ahref="post_viewTopics.action?page=${allPage}&boardName=<%=str%>"><fontsize="2"color="red">末页</font></a>
  26. </c:when>
  27. <c:otherwise>
  28. <fontsize="2"color="blue">下一页</font>
  29. <fontsize="2"color="blue">末页</font>
  30. </c:otherwise>
  31. </c:choose>
  32. </c:when>
  33. </c:choose>
  34. </c:otherwise>
  37. </c:choose>
  38. </center>

<center>
总共有${allPage}页, 当前是第${page}页
<c:choose>
<c:when test="${allPage<=1}">
<font size="2" color="blue">首页</font>
<font size="2" color="blue">上一页</font>
<font size="2" color="blue">下一页</font>
<font size="2" color="blue">末页</font>
</c:when>

<c:otherwise>
<c:choose>
<c:when test="${page==1}">
<font size="2" color="blue">首页</font></a>
<font size="2" color="blue">上一页</font></a>
<a href="post_viewTopics.action?page=${page+1}&boardName=<%=str%>"><font size="2" color="red">下一页</font></a>
<a href="post_viewTopics.action?page=${allPage}&boardName=<%=str%>"><font size="2" color="red">末页</font></a>
</c:when>
<c:when test="${page>1}">
<a href="post_viewTopics.action?page=1&boardName=<%=str%>"><font size="2" color="red">首页</font></a>
<a href="post_viewTopics.action?page=${page-1}&boardName=<%=str%>"><font size="2" color="red">上一页</font></a>
<c:choose>
<c:when test="${allPage>page}">
<a href="post_viewTopics.action?page=${page+1}&boardName=<%=str%>"><font size="2" color="red">下一页</font></a>
<a href="post_viewTopics.action?page=${allPage}&boardName=<%=str%>"><font size="2" color="red">末页</font></a>
</c:when>
<c:otherwise>
<font size="2" color="blue">下一页</font>
<font size="2" color="blue">末页</font>
</c:otherwise>
</c:choose>
</c:when>
</c:choose>
</c:otherwise>

</c:choose>
</center>



这样就可以了。当然，这里似乎缺少一个gotoPage的实现，但这个只是调用action时page赋值不一样而已，就不想费时间做了。


赞(0)    操作        顶端 
总帖数
1
每页帖数
101/1页1
返回列表
发新帖子
请输入验证码： 点击刷新验证码
您需要登录后才可以回帖 登录 | 注册
技术讨论

Weblogic中间件技术论坛

 |

Tuxedo中间件技术论坛

 |

数据库论坛

 |

Java论坛

 |

Linux/unix论坛

 |

网站地图


Powered by LandingBJ     @ 2008-2018     联动北方   
京ICP证号090597    京ICP备案09017624号    京公网安备110112000093号    
400-810-2327     Email：service@landingbj.com   

Powered by landingbj @ 2008-2015 联动北方
京ICP证号090597 京ICP备案09017624号 京公网安备110112000093号
86-27-87056338 Email：service@landingbj.com