userdao.java

利用javaEE开发而实现图书的购买的一个系统

package org.yangkang.bookshop.dao.impl;

import java.util.List;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.yangkang.bookshop.dao.BaseDao;
import org.yangkang.bookshop.dao.IUserDao;
import org.yangkang.bookshop.vo.User;

public class UserDao extends BaseDao implements IUserDao {

	@SuppressWarnings("unchecked")
	public User user_login(User user) {	
		String hql = "from User u where username=? and password=?";
		Session session = getSession();
		Query query;
		try{
			query = session.createQuery(hql);
			query.setParameter(0, user.getUsername());
			query.setParameter(1, user.getPassword());
			List list = query.list();
			if(list.size() != 0){
				User u = (User)list.get(0);				
				return u;
			}
			else 
				return null;
			
		}
		catch(Exception e){			
			e.printStackTrace();
			return null;
		}		
		finally{
			session.close();
		}
		
	}

	public User user_regist(User user) {
		String hql = "from User u where u.username=?";
		Session session = getSession();
		try{
			Query query = session.createQuery(hql);
			query.setParameter(0, user.getUsername());
			List list = query.list();
			if(list.size() != 0){	
				user = (User)list.get(0);
				return null;
			}
			else{
				Transaction tx = session.beginTransaction();
				session.save(user);
				tx.commit();
				Query _query = session.createQuery(hql);
				_query.setParameter(0, user.getUsername());
				List _list = query.list();
				user = (User)list.get(0);
				return user;
			}	
		}
		catch(Exception e){
			e.printStackTrace();
			return null;
		}
		finally{
			try{
				session.close();
			}
			catch(Exception e){
				e.printStackTrace();
			}
			
		}				
	}

//	public boolean user_rework(User user) {
//		
//		String hql = "from user as u where u.userId='"+user.getUserId()+"'";
//		Session session = getSession();
//		Query query = session.createQuery(hql);
//		List list = query.list();
//		if(list.size() != 0){
//			Transaction tx = session.beginTransaction();
//			session.update(user);
//			tx.commit();
//			session.close();
//			return true;
//			
//		}
//		else{
//			session.close();
//			return false;
//		}		
//
//	}

}