bbsreplyinfomanagedaohibernateimple.java

hibernate项目实践

package com.px1987.webbbs.dao;
import java.util.*;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import com.px1987.webbbs.exception.WebBBSException;
public class BBSReplyInfoManageDAOHibernateImple implements
		BBSReplyInfoManageDAOInterface 
{

	public BBSReplyInfoManageDAOHibernateImple() 
	{
		// TODO 自动生成构造函数存根
	}

	public boolean deleteOneBBSReplyInfo(int replyID) throws WebBBSException 
	{
		boolean OKOrNot=false;
		Session session=null;
		Transaction tx=null;
		try
		{
			session = HibernateUtil.currentSession();
			tx = session.beginTransaction();
			BBSReplyInfoPO oneBBSReplyInfoPOTODeleted=(BBSReplyInfoPO)session.get(BBSReplyInfoPO.class,new Integer(replyID));
			if(oneBBSReplyInfoPOTODeleted==null)
			{
				throw new WebBBSException("在数据库表中不存在指定replyID="+replyID+"的数据顶目！");
			}
			session.delete(oneBBSReplyInfoPOTODeleted);
			tx.commit();
			OKOrNot=true;
		}
		catch (HibernateException he)
		{
			throw new WebBBSException("在BBSReplyInfoManageDAOHibernateImple类中的deleteOneBBSReplyInfo方法出现了HibernateException异常");
		}
		finally
		{
			HibernateUtil.closeSession();
		}
		return OKOrNot;
	}
	public boolean insertBBSReplyInfo(BBSReplyInfoPO oneBBSReplyInfoPO)	throws WebBBSException 
	{
		  boolean OKOrNot=false;
		  Session session=null;
		  Transaction tx=null;
		  try
		  {
		    session = HibernateUtil.currentSession();
		    tx = session.beginTransaction();
		    session.save(oneBBSReplyInfoPO);
		    tx.commit();
		    OKOrNot=true;
		  }
		  catch (HibernateException he)
		  {
				throw new WebBBSException("在BBSReplyInfoManageDAOHibernateImple类中的insertBBSReplyInfo方法出现了HibernateException异常");
		  }
		  finally
		  {
		    HibernateUtil.closeSession();
		  }
		  return OKOrNot;
	}
	public boolean updateBBSReplyInfo(BBSReplyInfoPO oneUpdatedBBSReplyInfoPO) throws WebBBSException
	{
	     boolean OKOrNot=false;
	     Session session=null;
	     Transaction tx=null;
	     BBSReplyInfoPO oneReturnBBSReplyInfoPO=null;
	     try
	     {
	       session = HibernateUtil.currentSession();
	       tx = session.beginTransaction();
	       oneReturnBBSReplyInfoPO = (BBSReplyInfoPO) session.get(BBSReplyInfoPO.class, oneUpdatedBBSReplyInfoPO.getId());
	            if(oneReturnBBSReplyInfoPO==null)
	            {
	               throw new WebBBSException("在数据库表中不存在指定bbsReplyID="+oneUpdatedBBSReplyInfoPO.getId().toString()+"的数据顶目！");
	            }	    
	        	oneReturnBBSReplyInfoPO.setId(oneUpdatedBBSReplyInfoPO.getId());
	        	oneReturnBBSReplyInfoPO.setAuthor(oneUpdatedBBSReplyInfoPO.getAuthor());
	        	oneReturnBBSReplyInfoPO.setBbsID(oneUpdatedBBSReplyInfoPO.getBbsID());
	        	oneReturnBBSReplyInfoPO.setContent(oneUpdatedBBSReplyInfoPO.getContent());
	        	oneReturnBBSReplyInfoPO.setReplytime(oneUpdatedBBSReplyInfoPO.getReplytime());
	        	oneReturnBBSReplyInfoPO.setAbstractText(oneUpdatedBBSReplyInfoPO.getAbstractText());
	        	oneReturnBBSReplyInfoPO.setReplyTitle(oneUpdatedBBSReplyInfoPO.getReplyTitle());
	        	oneReturnBBSReplyInfoPO.setBbsReplyIconID(oneUpdatedBBSReplyInfoPO.getBbsReplyIconID());
	               
	       session.flush();
	       tx.commit();
	       OKOrNot=true;
	     }
	     catch (HibernateException he)
	     {
	       throw new WebBBSException("在BBSReplyInfoManageDAOHibernateImple类中的updateBBSReplyInfo方法出现了HibernateException异常");
	     }
	     finally
	     {
	       HibernateUtil.closeSession();
	     }
	     return OKOrNot;

	}
	public ArrayList selectSomeBBSReplyInfo(String HQLSelect) throws    WebBBSException
	{
	    List selectResult = null;
	    ArrayList allBBSReplyInfoPOs = new ArrayList();
	    Session session = null;
	    Transaction tx = null;
	    Query query =null;
	    try
	    {
	      session = HibernateUtil.currentSession();

	      tx = session.beginTransaction();
	      query = session.createQuery(HQLSelect);
	      query.setCacheable(true);      //激活查询缓存
	      selectResult=query.list();
	      Iterator allBBSReplyInfoPOItem=selectResult.iterator();
	      	 while(allBBSReplyInfoPOItem.hasNext())
	      	 {
	      		BBSReplyInfoPO oneBBSReplyInfoPO=(BBSReplyInfoPO)allBBSReplyInfoPOItem.next();
	      		allBBSReplyInfoPOs.add(oneBBSReplyInfoPO);
	      	 }
	      tx.commit();
	    }
	    catch (HibernateException he)
	    {
		       throw new WebBBSException("在BBSReplyInfoManageDAOHibernateImple类中的selectSomeBBSReplyInfo方法出现了HibernateException异常");	    
		}
	    finally
	    {
	      HibernateUtil.closeSession();
	    }
	    return allBBSReplyInfoPOs;		
	}

	public ArrayList getAllBbsReplyInfosByOneBBS(int bbsID)	throws WebBBSException 
	{
		String HQLQuery="from com.px1987.webbbs.dao.BBSReplyInfoPO as oneBBSReplyInfoPO order by oneBBSReplyInfoPO.id asc where oneBBSReplyInfoPO.bbsID="+bbsID;
		return selectSomeBBSReplyInfo(HQLQuery);
	}
}