userdaoimpl.java

电信计费项目 该系统在Sun Solaris下开发,运行于Apache Tomcat平台,采用J2EE架构

package com.tarena.netctoss.model.persist;

import java.util.List;
import org.hibernate.*;
import com.tarena.netctoss.model.biz.entity.User;
import com.tarena.util.HibernateFactoryManager;

/**
 * 持久层，用来查询数据库，并将得到的结果进行包装.
 * 这个主要是对User用户所对应的数据库表进行操作
 * @author wangdandan
 *
 */

public class UserDAOImpl implements IUserDAO {

	public void delete(User user) throws UserException {
		Session session = HibernateFactoryManager.getSession();
		try {
			session.delete(user);
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("delete user error");
		}
	}

	@SuppressWarnings("unchecked")
	public List<User> findAll() throws UserException {
		List<User> users = null;
		Session session = HibernateFactoryManager.getSession();
		String hql = "from User";
		try {
			Query q = session.createQuery(hql);
			users = q.list();
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("findall user error");
		}
		return users;
	}

	public User findUser(String login_name, String login_password)
			throws UserException {
		User user = null;
		Session session = HibernateFactoryManager.getSession();
		String hql = "from User user where user.login_name=? and user.login_password=?";
		try {
			Query q = session.createQuery(hql);
			q.setString(0, login_name);
			q.setString(1, login_password);
			user = (User) q.uniqueResult();
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("findUser user error");
		}
		return user;
	}

	public void insert(User user) throws UserException {
		Session session = HibernateFactoryManager.getSession();
		try {
			session.saveOrUpdate(user);
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("insert user error");
		}
	}

	public void update(User user) throws UserException {
		Session session = HibernateFactoryManager.getSession();
		try {
			session.saveOrUpdate(user);
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("update user error");
		}
	}
	
	public User findUserByID(Long user_id) throws UserException{
		User user = null;
		Session session = HibernateFactoryManager.getSession();
		String hql = "from User user where user.user_id=?";
		try {
			Query q = session.createQuery(hql);
			q.setLong(0, user_id);
			user = (User) q.uniqueResult();
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("findUser user error");
		}
		return user;
	}
	
	public User findUserByLogin_Name(String login_name) throws UserException{
		User user = null;
		Session session = HibernateFactoryManager.getSession();
		String hql = "from User user where user.login_name=?";
		try {
			Query q = session.createQuery(hql);
			q.setString(0, login_name);
			user = (User) q.uniqueResult();
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("findUser user error");
		}
		return user;
	}
}