sqluserfactory.java

JSP＋Struts＋Hibernate实现的用户登录系统。

package cn.com.zzb.eshopping.model.sql;

//import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
//import java.util.Set;
//import java.util.Set;

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

import cn.com.zzb.eshopping.db.HibernateUtil;
import cn.com.zzb.eshopping.model.Product;
import cn.com.zzb.eshopping.model.User;
import cn.com.zzb.eshopping.model.UserFactory;
public class SqlUserFactory extends UserFactory{

	public String ChkUser(String userid,String password) {
		String info = "0";
		User user = this.ListUser(userid);
		if(user != null){
				if((user.getPassword()).equals(password))
					info = "success";
				else
					info = "2";
		}
		else
			info = "1";
		return info;
	}
	public List listMyProducts(int id) throws HibernateException
	{
		Session session = HibernateUtil.currentSession();
		Transaction tx = session.beginTransaction();
		Query query = session.createQuery("select u,p from SqlUser as u,SqlProduct as p where p in elements(u.products) and u.id=:id");
		query.setInteger("id",id);
		List list = query.list();
		tx.commit();
		HibernateUtil.closeSession();
		return list;
	}
	public int countProduct(int user_id,int p_id) throws HibernateException
	{
		User user = new SqlUser();
		Product product = new SqlProduct();
		
		Session session = HibernateUtil.currentSession();
		Transaction tx = session.beginTransaction();
		Query query = session.createQuery("from SqlUser as u where u.id=:id");
		query.setInteger("id",user_id);
		int count = 0;
		List list = query.list();
		Iterator iterator = null;		
		if(!list.isEmpty())
		{
			user = (User)list.get(0);
			list = user.getProducts();
			iterator = list.iterator();
			while(iterator.hasNext())
			{
				product = (Product)iterator.next();
				if(product.getId() == p_id)
					count++;
			}			
		}
		tx.commit();
		HibernateUtil.closeSession();
		return count;		
	}
	public void buyProduct(User user,Product product) throws HibernateException
	{
		Session session = HibernateUtil.currentSession();
		Transaction tx = session.beginTransaction();
		//System.out.println(product.getName());
		//System.out.println(user.getName());
		//Set set = new HashSet();
		//set = user.getProducts();
		//if(!set.isEmpty())
		//{
		//    Product product1 = (Product)set.iterator().next();
		//	System.out.println(product1.getId());
			
		//}

		//set.add(product);
		//user.getProducts().add(product);
		
		//session.update(user);
		user = (User)session.load(SqlUser.class,new Integer(user.getId()));
		user.getProducts().add(product);
		session.update(user);
		tx.commit();
		HibernateUtil.closeSession();
		
	}
	
	public void delProduct(User user,Product product) throws HibernateException
	{
		Session session = HibernateUtil.currentSession();
		Transaction tx = session.beginTransaction();
		Product product1 = new SqlProduct();
		user = (User)session.load(SqlUser.class,new Integer(user.getId()));
		//user.getProducts().remove(product);
		//if(!user.getProducts().contains(product))
		//	System.out.println("none contains");
		List list = user.getProducts();
		Iterator iterator = list.iterator();
		while(iterator.hasNext())
		{
			product1 = (Product)iterator.next();
			if(product1.getId() == product.getId())
				user.getProducts().remove(product1);
		}
		session.update(user);
		tx.commit();
		HibernateUtil.closeSession();
	}
	
}