tblogdao.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.TBlog;
import cn.hope.front.pojo.base.BaseTBlogDAO;


public class TBlogDAO extends BaseTBlogDAO {
	Logger log = Logger.getLogger(TBlogDAO.class.getName());
	/**
	 * Default constructor.  Can be used in place of getInstance()
	 */
	public TBlogDAO () {
		
	}
	
	private int count = 0;

	public int getCount() {
		return this.count;
	}
	
	
//查查询所有Blog

	public List searchTBlog() throws HibernateException{
		List list = null;
		String sqlStr = "select tBlog from TBlog tBlog where tBlog.flag='0'";
		try {
			initialize();
		    list= this.getSession().find(sqlStr);

		} catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} finally {
			closeCurrentThreadSessions();
		}
		return list;
	}
	
//	通过主键查询出一个Blog
	public TBlog searchTBlogByKey(Integer tbid) throws HibernateException{
		TBlog tBlog = null;
		String sqlStr = "select tBlog from TBlog tBlog where tBlog.flag='0' and tBlog.tbId="+tbid;
		try {
			initialize();
			tBlog= (TBlog)(this.getSession().find(sqlStr).get(0));
		} catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} finally {
			closeCurrentThreadSessions();
		}
		return tBlog;
	}
//删除Blog
	public void deleteByKey(TBlog tBlog) throws HibernateException {
		try {
			initialize();
			this.update(tBlog);
		} catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} finally {
			closeCurrentThreadSessions();
		}
	}
//查询所点击blog的详细信息
	public TBlog viewTBlogByKey(Integer id) throws HibernateException{
		TBlog tBlog = null;
		String sqlStr = "select tBlog from TBlog tBlog where tBlog.flag='0' and tBlog.tbId="+id;
		try {
			initialize();
			tBlog= (TBlog)(this.getSession().find(sqlStr).get(0));
		} catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} finally {
			closeCurrentThreadSessions();
		}
		return tBlog;
	}
	
	
//分页	
	public List search(TBlog tBlog, int start, int range, boolean isEq)
			throws HibernateException {
		List list = null;
		StringBuffer sqlCnt = new StringBuffer();// 取总记录数
		StringBuffer sqlStr = new StringBuffer();// 长字符串的拼合一定要用StringBuffer.append()
		StringBuffer condition = new StringBuffer();// 查询条件
		sqlCnt.append("select count(tBlog.tbId) from TBlog tBlog where tBlog.flag='0' ");
		sqlStr.append("select tBlog from TBlog tBlog where tBlog.flag='0' ");
		
		/* 通过tFile中存储的条件组装HQL语句 */
		
		try {
			initialize();
			Query queryCnt = this.getSession().createQuery(
					sqlCnt.toString() + condition);// 通过hibernate的Query方法查询数据库(自己看文档)
			Integer count = (Integer) queryCnt.uniqueResult();// 得到总记录数
			this.count = count.intValue();
		
			condition.append(" order by tBlog.tbTime desc");// 加入排序条件
			Query query = this.getSession().createQuery(
					sqlStr.toString() + condition);
			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;
	}
}