userdao.java

gensou.rar为某渔具厂的一个简单ERP系统。为比较基础的工程

package com.gensou.dao.mange.user;

import java.util.ArrayList;
import java.util.List;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;


import com.gensou.hibernate.model.Quanxianzubiao;
import com.gensou.hibernate.model.Yonghubiao;
import com.gensou.hibernate.util.HibernateSessionFactory;
import com.gensou.logic.manage.user.AddUser;
import com.gensou.util.Pagination;

public class UserDao {
   /**
    * 对用户的操作
    * **/
	//添加用户
	public boolean addUser (AddUser addUser) throws Exception{
		String num = addUser.getNum();
		String name = addUser.getName();
		String password = addUser.getPassword();
		String beizhu = addUser.getBeizhu();
		int quanxianzuId = addUser.getQuanxianzuId();
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
		Query query = session.createQuery("from Yonghubiao where yonghuId=?");
		query.setString(0,num);
		List list = new ArrayList();
		list = query.list();
		if(list == null || list.isEmpty()){
			Quanxianzubiao qxz = (Quanxianzubiao)session.get(Quanxianzubiao.class,new Integer(quanxianzuId));
			Yonghubiao yonghu = new Yonghubiao();
			yonghu.setYonghuId(num);
			yonghu.setYonghuName(name);
			yonghu.setPassword(password);
			yonghu.setBeizhu(beizhu);
			yonghu.setQuanxianzubiao(qxz);
			session.save(yonghu);
			tx.commit();
			session.flush();
			session.close();
			return true;
		}
		return false;
	}
	//查询用户信息
	public List queryUser (String way,String trams,int pag,int max)throws Exception{
		Yonghubiao yhb = null;
		Query query = null;
	    List list = new ArrayList();
	    List l = new ArrayList();
		Session session = HibernateSessionFactory.getSession();
		session.flush();
		if(trams == null || trams.equals("")){
			query = session.createQuery(" from Yonghubiao");
			Pagination pagination=new Pagination();
			l=pagination.getNowlist(query,pag,max);
		}else{
			String tra = "%"+trams+"%";
		    query = session.createQuery(" from Yonghubiao yonghu where yonghu."+way+" like ?");
		    query.setString(0,tra);
		    Pagination pagination=new Pagination();
			l=pagination.getNowlist(query,pag,max);
		}
	    if(l != null || !l.isEmpty()){
	    	for(int i=0;i<l.size();i++){	
	    			yhb = (Yonghubiao) l.get(i);
	    	    	AddUser add = new AddUser();
	    	    	add.setId(yhb.getId().intValue());
	    	    	add.setNum(yhb.getYonghuId());
	    	    	add.setName(yhb.getYonghuName());
	    	    	add.setPassword(yhb.getPassword());
	    	    	add.setBeizhu(yhb.getBeizhu());
	    	    	add.setQuanxianzuId(yhb.getQuanxianzubiao().getId().intValue());
	    	    	add.setQuanxianzuName(yhb.getQuanxianzubiao().getQuanxianzuName());
	    	    	list.add(add);
	    	}
	    	session.flush();
	    	session.close();
	    	return list;
	    }else{
	    	session.flush();
	    	session.close();
	    	return list;
	    }
	}
	//更新用户信息
	public boolean updateUser(AddUser add) throws Exception{
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
//		Query query = session.createQuery("from Yonghubiao where yonghuName=?");
//		query.setString(0,add.getName());
//		List l = query.list();
//		if(l != null){
//			Yonghubiao yh = (Yonghubiao) l.get(0);
//			if(yh.getId() != add.getId()){
//				return false;
//			}
//		}
		Quanxianzubiao qxz = (Quanxianzubiao)session.get(Quanxianzubiao.class,new Integer(add.getQuanxianzuId()));
		Yonghubiao yhb = (Yonghubiao)session.get(Yonghubiao.class,new Integer(add.getId()));
        yhb.setYonghuId(add.getNum());
        yhb.setYonghuName(add.getName());
        yhb.setBeizhu(add.getBeizhu());
        yhb.setQuanxianzubiao(qxz);
        session.update(yhb);
        tx.commit();
        
        session.flush();
    	session.close();
		return true;
	}
	//通过用户id查询用户信息
//	public List queryUser(int pag,int max)throws Exception{
//		List list = new ArrayList();
//		List l = new ArrayList();
//		Session session = HibernateSessionFactory.getSession();
//		Query query = session.createQuery("from Yonghubiao");
//		Pagination pagination=new Pagination();
//		l=pagination.getNowlist(query,pag,max);
//		for(int i=0;i<l.size();i++){
//			Yonghubiao yhb = (Yonghubiao) l.get(i);
//			AddUser addUser = new AddUser();
//		    addUser.setId(yhb.getId().intValue());
//		    addUser.setNum(yhb.getYonghuId());
//		    addUser.setName(yhb.getYonghuName());
//		    addUser.setBeizhu(yhb.getBeizhu());
//		    addUser.setQuanxianzuId(yhb.getQuanxianzubiao().getId().intValue());
//		    addUser.setQuanxianzuName(yhb.getQuanxianzubiao().getQuanxianzuName());
//		    list.add(addUser);
//		}
//		session.flush();
//    	session.close();
//	    return list;
//	}
	//删除用户
	public List deleteUser(int id,int pag,int max,String way,String trams) throws Exception{
		List list = new ArrayList();
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
		Yonghubiao yhb = (Yonghubiao)session.get(Yonghubiao.class,new Integer(id));
		session.delete(yhb);
		tx.commit();
		session.flush();
    	session.close();
		list = queryUser(way,trams,pag,max);
		return list;
	}
}