membersdaoimpl.java

论坛软件系统亦称电子公告板(BBS)系统

			tr = session.beginTransaction();
			conn = session.connection();
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, member.getUid());
			pstmt.setString(2, member.getUsername());
			pstmt.setString(3, member.getPassword());
			pstmt.setString(4, member.getEmail());
			pstmt.setShort(5, member.getGroupid());
			pstmt.executeUpdate();
			tr.commit();
			return true;
		} catch (SQLException e) {
			if(tr!=null){
				tr.rollback();
			}
			e.printStackTrace();
		}finally {
			try {
				if(tr!=null){
					tr=null;
				}
				if(pstmt!=null){
					pstmt.close();
					pstmt=null;
				}
				if(conn!=null){
					conn.close();
					conn=null;
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return false;
	}
	
	public void resetUserCredits(String columeName, Integer resetValue) throws Exception {
		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		Transaction tr =  session.beginTransaction();
		String hql = "from Members";
		try {
			Query query = session.createQuery(hql);
			List<Members> membersListFormDB = query.list();
			for (int i = 0; i < membersListFormDB.size(); i++) {
				Members member = membersListFormDB.get(i);
				if (columeName.equals("extcredits1")) {
					member.setExtcredits1(resetValue);
				} else if (columeName.equals("extcredits2")) {
					member.setExtcredits2(resetValue);
				} else if (columeName.equals("extcredits3")) {
					member.setExtcredits3(resetValue);
				} else if (columeName.equals("extcredits4")) {
					member.setExtcredits4(resetValue);
				} else if (columeName.equals("extcredits5")) {
					member.setExtcredits5(resetValue);
				} else if (columeName.equals("extcredits6")) {
					member.setExtcredits6(resetValue);
				} else if (columeName.equals("extcredits7")) {
					member.setExtcredits7(resetValue);
				} else if (columeName.equals("extcredits8")) {
					member.setExtcredits8(resetValue);
				} else {
					new Exception(
							"表示要更新的积分列的参数不正确（不是 " +
							"extcredits1, extcredits2, extcredits3,extcredits4, " +
							"extcredits5, extcredits6, extcredits7,extcredits8 中的其中一个）");
				}
				session.update(member);
			}
			tr.commit();
		} catch (Exception e) {
			e.printStackTrace();
			if(tr!=null){
				tr.rollback();
			}
			throw new Exception("数据错误");
		}
	}
	

	@SuppressWarnings("unchecked")
	public List<Members> findMembersByHql(String hql,int startrow,int maxrows) {
		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		Transaction tr = null;
		try{
			tr = session.beginTransaction();
			Query query = session.createQuery(hql);
			query.setFirstResult(startrow);
			query.setMaxResults(maxrows);
			List<Members> list = query.list();
			tr.commit();
			return list;
		}catch(HibernateException e){
			if(tr!=null){
				tr.rollback();
			}
			e.printStackTrace();
		}
		return null;
	}

	public int findMembersCount() {
		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		Transaction tr = null;
		try{
			tr = session.beginTransaction();
			Query query = session.createQuery("select count(*) from Members");
			List list = query.list();
			tr.commit();
			if(list!=null && list.size()>0){
				return Integer.valueOf(list.get(0)+"");
			}
		}catch(HibernateException e){
			if(tr!=null){
				tr.rollback();
			}
			e.printStackTrace();
		}
		return 0;
	}

	public boolean updateMembersByHql(String hql) {
		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		Transaction tr = null;
		try{
			tr = session.beginTransaction();
			Query query = session.createQuery(hql);
			query.executeUpdate();
			tr.commit();
			return true;
		}catch(HibernateException e){
			if(tr!=null){
				tr.rollback();
			}
			e.printStackTrace();
		}
		return false;
	}

	@SuppressWarnings("unchecked")
	public List<Profilefields> findprofilefieldByAvaliable(byte avaliable) {
		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		Transaction tr = null;
		try{
			tr = session.beginTransaction();
			Query query = session.createQuery("from Profilefields as p where p.available=?");
			query.setParameter(0, avaliable);
			List<Profilefields> profilelist = query.list();
			tr.commit();
			return profilelist;
		}catch(HibernateException e){
			if(tr!=null){
				tr.rollback();
			}
			e.printStackTrace();
		}
		return null;
	}
	@SuppressWarnings("unchecked")
	public List<Members> findByProperty(String propertyName, Object value) {
		Session session = null;
		Transaction tran = null;
		Query query = null;
		List<Members> members = null;
		try {
			members = new ArrayList<Members>();
			session = HibernateUtil.getSessionFactory().getCurrentSession();
			tran = session.beginTransaction();
			query = session.createQuery("from Members as m where m."+ propertyName + "=?");
			query.setString(0, value.toString());
			members = query.list();
			tran.commit();
		} catch (HibernateException e) {
			if(tran!=null){
				tran.rollback();
			}
			e.printStackTrace();
		}
		return members;
	}
	
	public List<Members> getMemberListWithMemberIdList(List<Integer> memberIdList) {
		if(memberIdList.size()<1){
			return null;
		}
		StringBuffer hqlBuffer = new StringBuffer("FROM Members AS m WHERE m.uid IN (");
		for(int i : memberIdList){
			hqlBuffer.append(i+",");
		}
		hqlBuffer.replace(hqlBuffer.length()-1, hqlBuffer.length(), ")");
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			Query query = session.createQuery(hqlBuffer.toString());
			List<Members> list = query.list();
			transaction.commit();
			return list;
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public int findMemberCountByHql(String hql) {
		Session session = HibernateUtil.getSessionFactory().getCurrentSession();
		Transaction tr = null;
		try{
			tr = session.beginTransaction();
			Query query = session.createQuery(hql);
			List list = query.list();
			tr.commit();
			if(list!=null && list.size()>0){
				return (Integer)list.get(0);
			}
		}catch(HibernateException e){
			if(tr!=null){
				tr.rollback();
			}
			e.printStackTrace();
		}
		return 0;
	}
	
	public Integer getAdminCount() {
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			String hql = "SELECT COUNT(*) FROM Members WHERE adminid>?";
			Query query = session.createQuery(hql);
			query.setByte(0, (byte)0);
			List list = query.list();
			if(list.size()<=0){
				throw new Exception();
			}
			transaction.commit();
			return (Integer)list.get(0);
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public Integer getMembersCount(){
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			String hql = "SELECT COUNT(*) FROM Members";
			Query query = session.createQuery(hql);
			List list = query.list();
			if(list.size()<=0){
				throw new Exception();
			}
			transaction.commit();
			return (Integer)list.get(0);
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public Integer getMembersaddtoday(){
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			String hql = "SELECT COUNT(*) FROM Members WHERE regdate>=?";
			Query query = session.createQuery(hql);
			Integer nowTime = Integer.valueOf((Calendar.getInstance().getTimeInMillis()+"").substring(0,10));
			query.setInteger(0, nowTime-86400);
			List list = query.list();
			if(list.size()<=0){
				throw new Exception();
			}
			transaction.commit();
			return (Integer)list.get(0);
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public Integer getMemnonpost(){
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			String hql = "SELECT COUNT(*) FROM Members WHERE posts=?";
			Query query = session.createQuery(hql);
			query.setInteger(0, 0);
			List list = query.list();
			if(list.size()<=0){
				throw new Exception();
			}
			transaction.commit();
			return (Integer)list.get(0);
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public Members getLastMember() {
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction  = session.beginTransaction();
			String hql = "FROM Members ORDER BY uid DESC";
			Query query  = session.createQuery(hql);
			query.setMaxResults(1);
			List<Members> members = query.list();
			transaction.commit();
			if(members!=null&&members.size()>0){
				return members.get(0);
			}
		}catch (Exception e) {
			e.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
		}
		return null;
	}
	public List<Members> getMembersByNames(List<String> membersNames) {
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			
			String hql = "FROM Members as m WHERE m.username=?";
			Query query = session.createQuery(hql);
			
			List<Members> memberList = new ArrayList<Members>();
			for(int i = 0;i<membersNames.size();i++){
				String membersName = membersNames.get(i);
				if(membersName!=null){
					query.setString(0, membersName);
					List<Members> listTemp = query.list();
					if(listTemp.size()>0){
						Members members = listTemp.get(0);
						memberList.add(members);
					}
				}
			}
			transaction.commit();
			return memberList;
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public List<Members> getAllMembers() {
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			String hql =  "FROM Members";
			Query query = session.createQuery(hql);
			List<Members> resultList = query.list();
			transaction.commit();
			return resultList;
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
			return null;
		}
	}
	public void updateMembers(List<Members> memberList) {
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			for(int i = 0;i<memberList.size();i++){
				Members members = memberList.get(i);
				if(members!=null){
					session.update(members);
				}
			}
			transaction.commit();
		}catch(Exception exception){
			exception.printStackTrace();
			if(transaction!=null){
				transaction.rollback();
			}
		}
	}
	public void updateMembers(String hql) {
		Transaction transaction = null;
		try{
			Session session = HibernateUtil.getSessionFactory().getCurrentSession();
			transaction = session.beginTransaction();
			Query query = session.createQuery(hql);
			query.executeUpdate();
			transaction.commit();
		}catch(Exception exception){
			if(transaction!=null){
				transaction.rollback();
			}
			exception.printStackTrace();
		}
	}
}