sgradedao.java

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

package cn.hope.front.pojo.dao;

import java.util.List;

import org.apache.log4j.Logger;

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


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


public class SGradeDAO extends BaseSGradeDAO {
	Logger log = Logger.getLogger(TTestInfoDAO.class.getName());
	
	public SGradeDAO () {}
	private int count = 0;

	public int getCount() {
		return this.count;
	}

public List searchTest(String id, int start, int range, boolean isEq)throws HibernateException{
	    StringBuffer sqlStr = new StringBuffer();
	    StringBuffer condition = new StringBuffer();
	    StringBuffer sqlCnt = new StringBuffer();// 取总记录数
		sqlCnt.append("select count(sGrade.sgId) from SGrade sGrade where sGrade.flag='0' and sGrade.student.SUsername='"+id+"'");//计算结果总和
		sqlStr.append("select sGrade from SGrade sGrade where sGrade.flag='0' and sGrade.student.SUsername='"+id+"'");
		System.out.println(sqlStr+"!!!!!!!!!!!!!!!!");
		List list = null;
		try {
			initialize();
			Query queryCnt = this.getSession().createQuery(
					sqlCnt.toString() + condition);// 通过hibernate的Query方法查询数据库(自己看文档)
			Integer count = (Integer) queryCnt.uniqueResult();// 得到总记录数
			this.count = count.intValue();
			
			Query query = this.getSession().createQuery(sqlStr.toString());
			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;
	}
	
public List searchID(String id)throws HibernateException{
	List list = null;
	String sqlStr = null;
	sqlStr="select sGrade from SGrade sGrade where sGrade.flag='0' and sGrade.TTestInfo.TTestid='"+id+"'";
	try {
		initialize();
		list = this.getSession().find(sqlStr);//从数据库提取名字和密码
		System.out.println(list+"@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
	}
	catch(HibernateException e){
		log.error(e);
		e.printStackTrace();
		throw new HibernateException(e);
	}
	finally{
		closeCurrentThreadSessions();
	}
	return list;
}
}