u01mnouncebo.java

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

package cn.hope.mana.bo;

import java.util.Date;
import java.util.List;

import javax.servlet.http.HttpServletRequest;

import net.sf.hibernate.HibernateException;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.apache.struts.action.ActionForm;
import org.apache.struts.validator.DynaValidatorForm;

import cn.hope.mana.pojo.MNounce;
import cn.hope.mana.pojo.MNtype;
import cn.hope.mana.pojo.U01CommonListVO;
import cn.hope.mana.pojo.dao.MNounceDAO;
import cn.hope.mana.pojo.dao.MNtypeDAO;
import cn.hope.mana.util.U01Page;
import cn.hope.mana.util.Utility;


public class U01MNounceBO {
	Logger log = Logger.getLogger(U01MNounceBO.class.getName());
	
	public static void main(String[] args) {
	}
	
	private MNounceDAO mNounceDAO = new MNounceDAO();
	private MNtypeDAO  mNtypeDAO = new MNtypeDAO();
	
	public U01CommonListVO serach(MNounce mNounce, int start, boolean isEq)
	throws Exception {
		U01CommonListVO cl_vo = new U01CommonListVO();
		int range = 3;// 每页显示记录数
		int count = 0;// 总记录数
		List list = null;// 查询得到的结果集
		U01Page page = new U01Page();// 分页
		String fenyeStr = "";
		try {
			list = mNounceDAO.search(mNounce, start, range, isEq);
			count = mNounceDAO.getCount();
			cl_vo.setRs(list);
			cl_vo.setCount(count);
			cl_vo.setStart(start);
			cl_vo.setRange(range);
		
			fenyeStr = page.fenye(cl_vo);
			cl_vo.setFenye(fenyeStr);
			cl_vo.setCurrentPage(page.getCurrentPage());
			cl_vo.setTotalPage(page.getTotalPage());
			cl_vo.setStartSub(page.getStartSub());
			cl_vo.setOverSub(page.getOverSub());
		} catch (Exception e) {
			log.error(e);
			e.printStackTrace();
			throw new Exception(e);
		}
		return cl_vo;
	}
	public DynaValidatorForm changeForm(HttpServletRequest request,ActionForm form) {
		DynaValidatorForm mnForm = (DynaValidatorForm) form;
		MNounce mNounce = new MNounce();
		MNtype mNtype = new MNtype();
		String flag = request.getParameter("flag");
		try {
			if (flag.equals("0")){				
				mnForm.set("mNounce",mNounce);
				mnForm.set("mNtype",mNtype);
				mnForm.set("startTime","");
				mnForm.set("endTime","");
			}
			if (flag.equals("1")){
				if (StringUtils.isNotEmpty(request.getSession().getAttribute("mNounceList").toString())){
					U01CommonListVO vo = (U01CommonListVO) request.getSession().getAttribute("mNounceList");
					mnForm = (DynaValidatorForm) vo.getCondition();
				}
			}
			if (flag.equals("2")){
				if (StringUtils.isNotEmpty(mnForm.get("startTime").toString())){
					mNounce.setStartTime(Utility.stringToDate(mnForm.get("startTime").toString()));
				}
				if (StringUtils.isNotEmpty(mnForm.get("endTime").toString())){
					mNounce.setEndTime(Utility.stringToDate((String)mnForm.get("endTime").toString()));
				}
				mNounce = (MNounce) mnForm.get("mNounce");
				mNounce.setMNtype((MNtype) mnForm.get("mNtype"));
				mnForm.set("mNounce",mNounce);
			}
		}catch (Exception e) {
			log.error(e);
			e.printStackTrace();
		}
		return mnForm;
	}
	
	public void delete(MNounce mNounce) throws HibernateException {
		String[] nids = mNounce.getNIds();
		try {
			for (int i = 0 ; i < nids.length ; i ++) {
				MNounce mn = mNounceDAO.searchByKey(new Integer(nids[i]));
				mn.setFlag("1");
				mNounceDAO.delete(mn);
			}
		}catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} 
	}
	public boolean insert(MNounce mNounce,MNtype mNtype) throws HibernateException {
		mNounce.setNTitle(mNounce.getNTitle().trim());
		int count = 0;
		try {
			count = mNounceDAO.searchByName(mNounce);
			if (count == 0){
				mNounce.setFlag("0");
				mNtype.setFlag("0");
				mNounce.setNTime(new Date());
				if (mNtype.getNType()==null || mNtype.getNType().equals("")){
					mNounce.setMNtype(mNtypeDAO.load(mNtype.getTypeId()));
				}
				else{
					mNtype.setNType(mNtype.getNType().trim());
					mNounce.setMNtype(mNtypeDAO.load(mNtypeDAO.insert(mNtype)));
				}			
				mNounceDAO.insert(mNounce);
				return true;
			}
		}catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} 
		return false;
	}
	public MNounce find(Integer nId) throws HibernateException {
		try{
			return mNounceDAO.find(nId);
		}catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} 
	}
	public boolean update(MNounce mNounce,MNtype mNtype) throws HibernateException {
		String nTitle = mNounce.getNTitle().trim();
		int nid = mNounce.getNId().intValue();
		mNounce.setNTitle(nTitle);
		int count = 0;
		try {
			count = mNounceDAO.search(nTitle,nid);
			if (count == 0){
				mNounce.setFlag("0");
				mNtype.setFlag("0");
				mNounce.setNTime(new Date());
				if (mNtype.getNType()==null || mNtype.getNType().equals("")){
					mNounce.setMNtype(mNtypeDAO.load(mNtype.getTypeId()));
				}
				else{
					mNtype.setNType(mNtype.getNType().trim());
					mNounce.setMNtype(mNtypeDAO.load(mNtypeDAO.insert(mNtype)));
				}			
				mNounceDAO.delete(mNounce);
				return true;
			}
		}catch (HibernateException e) {
			log.error(e);
			e.printStackTrace();
			throw new HibernateException(e);
		} 
		return false;
	}
}