admindaoimpl.java

来自「电信计费项目 该系统在Sun Solaris下开发,运行于Apache Tom」· Java 代码 · 共 96 行

package com.tarena.netctoss.model.persist;

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

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

	public void delete(Long amd_id) throws UserException {
		Session session = HibernateFactoryManager.getSession();
		try {
			Admin admin = findAdmiByID(amd_id);
			session.delete(admin);
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("delete admin error");
		}
	}
	
	public Admin findAdmiByID(Long amd_id) throws UserException {
		Admin admin = null;
		Session session = HibernateFactoryManager.getSession();
		String hql = "from Admin admin where admin.amd_id=?";
		try {
			Query q = session.createQuery(hql);
			q.setLong(0, amd_id);
			admin=(Admin) q.uniqueResult();
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("find admin by id error");
		}
		return admin;
	}

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

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

	public void insert(Admin admin) throws UserException {
		Session session = HibernateFactoryManager.getSession();
                System.out.println("sddsdsfsdfsdfdsfds");
		try {
			session.saveOrUpdate(admin);
		} catch (HibernateException e) {
			e.printStackTrace();
			throw new UserException("insert admin error");
		}
	}

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

}