userdao.java

一个关于物流的管理系统

package com.shunshi.ssh.dao;

import java.sql.SQLException;
import java.util.*;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.*;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.shunshi.ssh.entity.PersonalUser;
import com.shunshi.ssh.entity.User;

public class UserDAO extends HibernateDaoSupport implements IUserDAO{

	public void save(User user) {
		try {
			getHibernateTemplate().saveOrUpdate(user);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	public void delete(User user) {
		try {
			getHibernateTemplate().delete(user);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	public User findById(Long id) {
		try {
			User user = (User) getHibernateTemplate().get(
					"com.shunshi.ssh.entity.User", id);
			return user;
		} catch (RuntimeException re) {
			throw re;
		}
	}
	
	public User findByUserName(String userName) {
		User user=null;
		try {
			String sql="from User user where userName=?";
			List list=getHibernateTemplate().find(sql, userName);
			if(list!=null && list.size()>0){
				 user = (User)list.get(0);
			}
		} catch (RuntimeException re) {
			throw re;
		}
		return user;
	}

	public Collection findByProperty(String propertyName, Object value) {
		try {
			String queryString = "from User as model where model."
					+ propertyName + "= ?";
			return getHibernateTemplate().find(queryString, value);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	public Collection findAll() {
		try {
			String queryString = "from User";
			return getHibernateTemplate().find(queryString);
		} catch (RuntimeException re) {
			throw re;
		}
	}

	public void update(User user) {
		try {
			getHibernateTemplate().saveOrUpdate(user);
		} catch (RuntimeException re) {
			throw re;
		}
	}
	
	public List findUsersInfoByState(final byte state,final int startRow,final int maxRowNum) {
		List usersInfo=(List)getHibernateTemplate().execute(new HibernateCallback(){
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				Query query=session.createQuery("select users from User users where users.state=:state");
				query.setByte("state",state);
				query.setMaxResults(maxRowNum);
				query.setFirstResult(startRow);
				List usersInfo=new ArrayList();
				List users=query.list();
				for(int i=0;i<users.size();i++){
					User userInfo=(User)users.get(i);
					Map userMap=new HashMap();
					userMap.put("userName",userInfo.getUserName());
					userMap.put("type","p".equals(userInfo.getType()) ? "个人会员":"企业会员");
					userMap.put("groupName",userInfo.getUserGroup().getGroupName());
					userMap.put("loginTimes",userInfo.getLoginTimes());
					userMap.put("state",userInfo.getState()==1 ? "等待审核":"正常");
					userMap.put("id",userInfo.getId());
					usersInfo.add(userMap);
				}
				return usersInfo;
			}
		});
		return usersInfo;
	}

	public Long getTotalRowsByState(int state){
			return (Long)getHibernateTemplate().find("select count(*) from User user where user.state=?",state).get(0);
	}

	public List findUsersInfoByAll(final int startRow,final int maxRowNum) {
		List usersInfo=(List)getHibernateTemplate().execute(new HibernateCallback(){
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				Query query=session.createQuery("select users from User users");
				query.setMaxResults(maxRowNum);
				query.setFirstResult(startRow);
				List usersInfo=new ArrayList();
				List users=query.list();
				for(int i=0;i<users.size();i++){
					User userInfo=(User)users.get(i);
					Map userMap=new HashMap();
					userMap.put("userName",userInfo.getUserName());
					if(userInfo instanceof PersonalUser){
						userMap.put("type","个人会员");
					}else{
						userMap.put("type","企业会员");
					}
					userMap.put("groupName",userInfo.getUserGroup().getGroupName());
					userMap.put("loginTimes",userInfo.getLoginTimes());
					userMap.put("state",userInfo.getState()==1 ? "等待审核":"正常");
					userMap.put("id",userInfo.getId());
					usersInfo.add(userMap);
				}
				return usersInfo;
			}
		});
		return usersInfo;
	}

	public Long getTotalRowsByAll() {
		return (Long)getHibernateTemplate().find("select count(*) from User user").get(0);
	}
	
	public String queryType(Long id){
		User user=null;
		try {
			String sql="from User user where id=?";
			List list=getHibernateTemplate().find(sql, id);
			if(list!=null && list.size()>0){
				 user = (User)list.get(0);
			}
		} catch (RuntimeException re) {
			throw re;
		}
		return user.getType();
	}
}