roleinfoservice.java

这是本人曾经在公司里用的,内部开发框架,基于struts+hibernate今天分享给大家

/**
 * 
 */
package cn.bway.admin.dao;

import java.io.Serializable;
import java.sql.*;
import java.util.*;
import org.apache.log4j.*;
import org.hibernate.Session;
import org.hibernate.Transaction;

import cn.bway.admin.model.Roles;
import cn.bway.admin.vo.RoleAndStaffVO;
import cn.bway.admin.vo.RoleInfoVO;
import cn.bway.common.BwayHibernateException;
import cn.bway.common.PageList;
import cn.bway.common.PlatformException;
import cn.bway.common.dao.BaseDAOHibernate;

/**
 * @author Kson
 *
 */
public class RoleInfoService extends BaseDAOHibernate {
	
	protected final Logger log = LogManager.getLogger(getClass());
	Connection conn = null;
	
	public PageList queryRoleInfo(RoleInfoVO vo) throws BwayHibernateException {
		List arrayList = new ArrayList();
		PageList list = new PageList();
		try {
			 conn = currentSession().connection();
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			arrayList = dao.queryRoleInfo(vo);
			list.setPageSize(vo.getPageSize());
			list.setRealPage(vo.getPageNo());
			list.setList(dao.queryRoleInfo(vo));
			list.setTotalItems(dao.queryRoleInfoCount(vo).intValue());
		} catch (BwayHibernateException ex) {
			System.out.println("��ѯ��ɫ���:" + ex.getMessage());
			throw ex;
		} catch (Exception ex2) {
			System.out.println("��ѯ��ɫ���:" + ex2.getMessage());
		} finally {
			closeSession();
		}
		return list;
	}

	/**
	 * �޸Ľ�ɫ
	 * @param vo RoleInfoVO
	 * @throws BwayHibernateException
	 */
	public void modifyRoleInfo(RoleInfoVO vo) throws BwayHibernateException {
		try {
			conn = currentSession().connection();
			conn.setAutoCommit(false);
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			dao.updateRoleInfo(vo);
			conn.commit();
		} catch (BwayHibernateException ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
			throw ex;
		} catch (Exception ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
		} finally {
			closeSession();
		}
	}

	public void deleteRoleInfo(RoleInfoVO vo) throws BwayHibernateException {
		try {
			conn = currentSession().connection();
			conn.setAutoCommit(false);
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			dao.deleteRoleInfo(vo);
			conn.commit();
		} catch (BwayHibernateException ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
			throw ex;
		} catch (Exception ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
		} finally {
			closeSession();
		}
	}
	
	//ɾ���ɫ
	public void removeRoleInfoObject(RoleInfoVO vo) throws BwayHibernateException {
		Transaction tx=null;
		try {
			tx=session.beginTransaction();
			Session sess = currentSession();
			String id = String.valueOf(getLongId(vo.getRoleId(),sess));
			Object object=session.get(Roles.class, id);
			session.delete(object);
			session.flush();
			tx.commit();
		} catch (BwayHibernateException ex) {
			tx.rollback();
			throw ex;
		} catch (Exception ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
		} finally {
			closeSession();
		}
	}
	
	private static long getLongId(String roleid,Session sess) throws BwayHibernateException {
		long id = 0;
	    ResultSet rs = null;
	    PreparedStatement stat = null;
	    String sql = "";
	    try{
	    	sql = "select * from roles where roleid = '"+roleid+"' ";
	    	stat = sess.connection().prepareStatement(sql);
	    	rs = stat.executeQuery();
	    	if(rs.next()){
	    		id = rs.getLong("id");
	    	}
	    }catch(Exception e){
	    	e.printStackTrace();
	    } finally {
	    	try {
				rs.close();
		    	stat.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
	    }
		return id;
	}
	

	/**
	 * ��ӽ�ɫ
	 * @param vo RoleInfoVO
	 * @throws BwayHibernateException
	 */
	public void addRoleInfo(RoleInfoVO vo) throws BwayHibernateException {
		try {
			conn = currentSession().connection();
			conn.setAutoCommit(false);
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			dao.insertRoleInfo(vo);
			conn.commit();
		} catch (BwayHibernateException ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
			throw ex;
		} catch (Exception ex) {
			try {
				conn.rollback();
			} catch (SQLException ey) {
			}
		} finally {
			closeSession();
		}
	}
	
	

	public PageList getRoleInfo(RoleInfoVO vo) throws BwayHibernateException {
//		List pageList = new ArrayList();
		PageList pageList = new PageList();
		try {
			conn = currentSession().connection();
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			List list = dao.getRoleInfo(vo);
			
			pageList.setList(list);
			
		} catch (BwayHibernateException ex) {
			System.out.println("��ѯ��ɫ���:" + ex);
			throw ex;
		} catch (Exception ex2) {
			System.out.println("��ѯ��ɫ���:" + ex2.getMessage());
		} finally {
			closeSession();
		}
		return pageList;
	}
	
	public String querySeq(String tmpTableName) throws BwayHibernateException {
		String ret ="0";
		try {
			conn = currentSession().connection();
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			ret = String.valueOf(dao.querySeq(tmpTableName));
			conn.commit();
		} catch (BwayHibernateException ex) {
			try {
				conn.rollback();
			} catch (SQLException ex1) {
			}
			throw ex;
		} catch (Exception ex2) {
			System.out.println("Exception ��ӽ�ɫ���:" + ex2.getMessage());
		} 
		finally {
			closeSession();
		}
		return ret;
	}
	
	/**
	 * ��ݽ�ɫID��ѯ�ý�ɫ���е�Ա���б� added by liuwei 2006/08/20
	 * @param vo RoleAndStaffVO
	 * @return List
	 * @throws BwayHibernateException
	 */
	public List queryStaffFromRoleId(RoleAndStaffVO vo) throws BwayHibernateException {
		List lst = null;
		try {
			conn = currentSession().connection();
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			lst = dao.queryStaffFromRoleId(vo);
		} catch (BwayHibernateException ex) {
			System.out.println("��ѯ�ý�ɫ���е�Ա���б��쳣: "+ ex.getMessage());
			throw ex;
		} catch (Exception ex2) {
			System.out.println("��ѯ�ý�ɫ���е�Ա���б��쳣: "+ ex2.getMessage());
		} finally {
			closeSession();
		}
		return lst;
	}

	/**
	 * ��ݽ�ɫID��ѯ�ý�ɫ�����е�Ա���б� added by liuwei 2006/08/20
	 * @param vo RoleAndStaffVO
	 * @return List
	 * @throws BwayHibernateException
	 */
	public List queryStaffExceptRoleId(RoleAndStaffVO vo) throws BwayHibernateException {
		List lst = null;
		try {
			conn = currentSession().connection();
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			lst = dao.queryStaffExceptRoleId(vo);
		} catch (BwayHibernateException ex) {
			System.out.println("��ѯ�ý�ɫ�����Ա���б��쳣: "+ ex.getMessage());
			throw ex;
		} catch (Exception ex2) {
			System.out.println( "��ѯ�ý�ɫ�����Ա���б��쳣: "+ ex2.getMessage());
		} finally {
			closeSession();
		}
		return lst;
	}

	/**
	 * �޸Ľ�ɫ��Ա���Ĺ�ϵ added by liuwei 2006-8-17
	 * @param relationlst ArrayList
	 * @return int
	 * @throws BwayHibernateException
	 */
	public int UpdateRoleAndStaffRelation(ArrayList relationlst) throws BwayHibernateException {
		int ret = 0;
		try {
			conn = currentSession().connection();
			conn.setAutoCommit(false);
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			if (null != relationlst) {
				RoleAndStaffVO rVo = (RoleAndStaffVO) relationlst.get(0);
				//��ѯ�Ƿ���Ȩ��
				if(dao.selectRoleAndStaffRelation(rVo)){
					//ɾ��ԭ�н�ɫ��Ա���Ĺ�ϵ
					dao.deleteRoleAndStaffRelation(rVo);
				}
				Iterator iter = relationlst.iterator();
				//���²����ɫ��Ա���Ĺ�ϵ
				while (iter.hasNext()) {
					RoleAndStaffVO vo = (RoleAndStaffVO) iter.next();
					dao.saveRoleAndStaffRelation(vo);
					ret++;
				}
				conn.commit();
			}
		} catch (BwayHibernateException ex) {
			try {
				conn.rollback();
			} catch (SQLException ex1) {
			}
			System.out.println("�޸Ľ�ɫ��Ա���Ĺ�ϵ�쳣: "+ ex.getMessage());
			throw ex;
		} catch (Exception ex2) {
			System.out.println( "�޸Ľ�ɫ��Ա���Ĺ�ϵ�쳣��"+ ex2.getMessage());
			ex2.printStackTrace();
		} finally {
			try {
				if(null !=conn)
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			closeSession();
		}
		return ret;
	}

	/**
	 * �õ�Ȩ����ϸ��Ϣ
	 * @param vo RoleInfoVO
	 * @return RoleInfoVO
	 * @throws BwayHibernateException
	 */
	public RoleInfoVO queryRoleInfoVO(RoleInfoVO qvo) throws BwayHibernateException {
		RoleInfoVO rvo = null;
		try {
			conn = currentSession().connection();
			RoleInfoDAO dao = new RoleInfoDAO(conn);
			rvo = dao.queryRoleInfoVO(qvo);
		} catch (BwayHibernateException ex) {
			System.out.println("�õ�Ȩ����ϸ��Ϣ���쳣: "+ ex.getMessage());
			throw ex;
		} catch (Exception ex2) {
			System.out.println("�õ�Ȩ����ϸ��Ϣ�쳣: "+ ex2.getMessage());
		} finally {
			closeSession();
		}
		return rvo;
	}
	
    public int querySeq() throws    PlatformException {
    Connection conn = null;
    try {
    	conn = currentSession().connection();
        RoleInfoDAO dao = new RoleInfoDAO(conn);
        return dao.querySeq();
    } catch (PlatformException ex) {
        throw ex;
    } catch (Exception ex) {
        throw new PlatformException("��ӽ�ɫҵ���߼��������", ex);
    } finally {    	
    	closeSession();
    }
}
	

}