rootforumdao.java

基于struts+hibernate的电子商务网站。可运行。数据库mysql

/**
  * @(#)tarena.data.CategoryList.java  2008-11-10  
  * Copy Right Information	: Tarena
  * Project					: xindou
  * JDK version used		: jdk1.6.4
  * Comments				: 此处输入简单类说明
  * Version					: 1.0
  * Sr	Date		Modified By		Why & What is modified
  * 1.	2008-11-17 	陈达     		新建
  **/
package tarena.dao.pages;


import java.util.List;

import org.hibernate.Hibernate;
import org.hibernate.HibernateException;

import tarena.dao.BaseHibernateDAO;
import tarena.data.AbstractReply;

@SuppressWarnings("unchecked")
public class RootForumDAO extends BaseHibernateDAO {
	
	public Integer countPostsBySection(Integer sid){
		StringBuffer sql = new StringBuffer();
		sql.append("select count(p.id) re from post p,topic t ");
		sql.append("where p.tid=t.id and t.sid="+sid);
		
		try {
			return (Integer)getSession()
					.createSQLQuery(sql.toString())
					.addScalar("re",Hibernate.INTEGER)
					.uniqueResult();
		} catch (HibernateException e) {			
			return 0;
		}
	}
	
	public Integer countTopicsBySection(Integer sid){
		StringBuffer sql = new StringBuffer();
		sql.append("select count(t.id) re from topic t ");
		sql.append("where t.sid="+sid);
		
		try {
			return (Integer)getSession()
					.createSQLQuery(sql.toString())
					.addScalar("re",Hibernate.INTEGER)
					.uniqueResult();
		} catch (HibernateException e) {			
			return 0;
		}
	}
	
	public List<AbstractReply> findReply(Integer sid){		
		StringBuffer sql = new StringBuffer();
		sql.append("select new tarena.data.AbstractReply(p.id,t.title,u.username,p.sendtime) ");
		sql.append("from Post p,User u,Topic t ");
		sql.append("where p.user.id=u.id and p.topic.id=t.id and p.sendtime= ");
		sql.append(" (select max(p.sendtime) from Post p,Topic t where p.topic.id = t.id and t.section.id=:sid)");
		try {
			return  (List<AbstractReply>)getSession()
					.createQuery(sql.toString())
					.setInteger("sid", sid)
					.list();			
		} catch (HibernateException e) {			
			return null;
		}		
	}
	
	public AbstractReply findReplyUnique(Integer sid){
		List<AbstractReply> reply = this.findReply(sid);
		return (reply==null||reply.size()==0)?null:reply.get(0);
	}
	
}