tquestiondao.java

持久层hibernate技术使用的一个例子

package cn.hope.front.pojo.dao;


import java.util.List;

import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Query;


import org.apache.log4j.Logger;


import cn.hope.front.pojo.TQuestion;






import cn.hope.front.pojo.base.BaseTQuestionDAO;


public class TQuestionDAO extends BaseTQuestionDAO {

	Logger log = Logger.getLogger(StudentDAO.class.getName());

	
	

	/**
	 * Default constructor.  Can be used in place of getInstance()
	 */
	public TQuestionDAO () {}

	
	
	public List searchQuesinfo(TQuestion tQuestion,int start, int range, boolean isEq)throws HibernateException{
		StringBuffer sqlStr = new StringBuffer();// 长字符串的拼合一定要用StringBuffer.append()
		StringBuffer sqlCnt = new StringBuffer();// 取总记录数
		StringBuffer condition = new StringBuffer();// 查询条件
		
		
		sqlCnt.append("select count(tQuestion.tqId) from TQuestion tQuestion where tQuestion.flag='0' ");//计算结果总和
		List list = null;
	
		try{
			initialize();
			Query query = this.getSession().createQuery(sqlStr.toString());
			//System.out.println(tQuestion.getCSubject().getSSid()+"********************************************************dao");
			//System.out.println(tQuestion.getTQtype().getTqtId()+"********************************************************dao");
			//System.out.println(tQuestion.getCSubject()+"&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&");
			if(tQuestion!=null&&tQuestion.getCSubject()!=null){
				sqlStr.append("select tQuestion from TQuestion tQuestion where tQuestion.flag='0' ");
				condition.append("and tQuestion.CSubject.SSid='"+tQuestion.getCSubject().getSSid()+"' ");
				//System.out.println(tQuestion.getCSubject()+"*************************************************************************");
				query = this.getSession().createQuery(sqlStr.toString()+condition);
			
				if(tQuestion!=null&&tQuestion.getTQtype()!=null){
					condition.append("and tQuestion.TQtype.tqtId='"+tQuestion.getTQtype().getTqtId()+"' ");
					//System.out.println(tQuestion.getTqId()+"tQuestion.getTqId()tQuestion.getTqId()tQuestion.getTqId()tQuestion.getTqId()");
					query = this.getSession().createQuery(sqlStr.toString()+condition);
				
			
					//System.out.println(sqlStr+"#################################");
					Query queryCnt = this.getSession().createQuery(
							sqlCnt.toString() + condition);// 通过hibernate的Query方法查询数据库(自己看文档)
					Integer count = (Integer) queryCnt.uniqueResult();// 得到总记录数
					this.count = count.intValue();
					query.setFirstResult(start);// 设置查询起始记录数
					query.setMaxResults(range);// 设置查询总记录数
					
					list = query.list();
					System.out.println(list);
				}
			}
			else{
				sqlStr.append("select tQuestion from TQuestion tQuestion where tQuestion.flag='10' ");
				query = this.getSession().createQuery(sqlStr.toString()+condition);
				//Query queryCnt = this.getSession().createQuery(
					//	sqlCnt.toString() + condition);// 通过hibernate的Query方法查询数据库(自己看文档)
				//Integer count = (Integer) queryCnt.uniqueResult();// 得到总记录数
				//this.count = count.intValue();
				//query.setFirstResult(start);// 设置查询起始记录数
				//query.setMaxResults(range);// 设置查询总记录数
				list = query.list();
			}
		}
		catch(HibernateException e){
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		}
		finally{
			closeCurrentThreadSessions();
		}
		return list;
	}
	
	private int count = 0;
	
	public int getCount() {
		return this.count;
	}

	




}