productdaoimpl.java

Struts2.0整合Hibernate3实例

package com.dao;

import java.util.Iterator;
import java.util.List;


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

import com.po.Product;
import com.util.HibernateUtil;

public class ProductDaoImpl  implements ProductDao{
	
	//添加产品
	public void save(Product p) {
		//创建Session
		Session session = HibernateUtil.getSession();
		
		//开启事务
		session.beginTransaction();
		//保存数据
		session.save(p);
		
		//事务提交
		session.getTransaction().commit();
		
		//关闭session
		HibernateUtil.closeSession(session);
	}

	//删除产品
	public void delete(String id) {
		//创建Session
		Session session = HibernateUtil.getSession();
		
		//开启事务
		session.beginTransaction();
		
		// 使用HQL查询
		String hql = "DELETE Product WHERE id=?";
		Query q = session.createQuery(hql);
		q.setString(0, id);
		q.executeUpdate();
		
		//事务提交
		session.getTransaction().commit();
		
		//关闭session
		HibernateUtil.closeSession(session);
	}


	//更新产品
	public void update(Product p) {
		//创建Session
		Session session = HibernateUtil.getSession();
		
		//开启事务
		session.beginTransaction();
		//保存数据
		session.update(p);
		
		//事务提交
		session.getTransaction().commit();
		
		//关闭session
		HibernateUtil.closeSession(session);
	}
	
	//查询所有产品
	public List queryAll() {
		
		// 创建Session
		Session session = HibernateUtil.getSession();
		
		// 使用HQL查询
		String hql = "FROM Product as pro";
		
		// 通过Query方法查询
		Query q = session.createQuery(hql);

		//查询结果保存到list中
		List list = q.list();
		
		//关闭session
		HibernateUtil.closeSession(session);
		
		return list;

	}

	//按id查询产品
	public Product queryByID(String id) {
		// 创建Session
		Session session = HibernateUtil.getSession();
		
		// 使用HQL查询
		String hql = "FROM Product as pro WHERE pro.id=?";
		
		// 通过Query方法查询
		Query q = session.createQuery(hql);
		q.setString(0, id);
		
		//查询结果保存到list中
		List list = q.list();
		
		Product p = null;
		
		//遍历是否存在该id的产品，如果存在则进行输出
		Iterator iter = list.iterator();
		if(iter.hasNext()) {
			p = (Product) iter.next();
		}
		
		//关闭session
		HibernateUtil.closeSession(session);
		
		return p;
		
	}

}