user1dao.java

只是一个宽带的收费管理系统 很值得大家学习

package cn.handson.dao;

import java.io.UnsupportedEncodingException;
import java.util.Iterator;
import java.util.List;

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

import cn.handson.base.*;
import cn.handson.utils.*;

public class User1Dao {
	
	
	/*
	 * 此方法用来得到所有的用户对象。。。
	 * 
	 * 
	 */
	
	public List loadAllUser1() {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定义一个事务 
		String sql="select b from User1 as b";
		Query query=session.createQuery(sql);
		List list=query.list();
		tx.commit();//提交事务
		//HibernateUtil.closeSession();
		return list;
		
	}
	/*
	 * 此方法用来删除用户对象.....
	 * 
	 */
	public boolean deleteUser1(User1 user){
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定义一个事务 
		session.delete(user);
		tx.commit();//提交事务
		//HibernateUtil.closeSession();
		return true;
	}
	
	/*
	 * 此方法用来通过ID来得到一个用户的对象。。。
	 * 
	 * 
	 */
	
	public User1 getUser1ById(Integer id) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定义一个事务 
        User1 us=(User1)session.get(User1.class, id);
		tx.commit();//提交事务
		//HibernateUtil.closeSession();
		return us;
	}
    
	/*
	 * 此方法用来更新数据库中的用户。。。
	 * 
	 */
	
	public void updateUser1(User1 user) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定义一个事务 
        User1 us=(User1)session.get(User1.class, user.getUserId());
		us.setUserName(user.getUserName());
		us.setUserDepart(user.getUserDepart());
		us.setUserWork(user.getUserWork());
		us.setUserAddress(user.getUserAddress());
		us.setUserPhone(user.getUserPhone());
		us.setUserOfficePhone(user.getUserOfficePhone());
		us.setUserMes(user.getUserMes());
		us.setUserMobel(user.getUserMobel());
		us.setUserType(user.getUserType());
		us.setUsesRemark(user.getUsesRemark());
		session.save(us);
		tx.commit();//提交事务
		//HibernateUtil.closeSession();
	}
	
	/*
	 * 此方法用来添加用户。。。。
	 * User是页面传来的属性。。。
	 * 
	 */
	
	public void addUser1(User1 user) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定义一个事务 
		session.save(user);
		tx.commit();//提交事务
		//HibernateUtil.closeSession();
		
	}
	
	
	

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		/*List list=new User1Dao().loadAllUser1();
		Iterator iter=list.iterator();
		while(iter.hasNext()){
			User1 aa=(User1)iter.next();
			System.out.println(aa.getUserName());
		}
		*/
		User1 user=new User1();
		user.setUserName("userName");
		user.setUserDepart("userDepart");
		user.setUserWork("userWork");
		user.setUserAddress("userAddress");
		user.setUserPhone("userPhone");
		user.setUserOfficePhone("userOfficePhone");
		user.setUserMes("userMes");
		user.setUserMobel("userMobel");
		user.setUserType(new Integer(1));
		user.setUsesRemark("usesRemark");
		new User1Dao().addUser1(user);
	}
	
	/*
	 * 此方法是通过用户名子来得到一个用户对象。。。
	 * 
	 */
	public List getUser1Byname(String name) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定义一个事务 
        System.out.println(name);
        List list=null;
        try {
			String critname=new String(name.getBytes("ISO-8859-1"),"GBK");
		
        String sql="select b from User1 as b where USER_NAME =:n";
		Query query=session.createQuery(sql);
		query.setParameter("n",name);
		list=query.list();
		tx.commit();//提交事务
		HibernateUtil.closeSession();
        } catch (UnsupportedEncodingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}

}