priceserviceimpl.java

来自「电信计费项目 该系统在Sun Solaris下开发,运行于Apache Tom」· Java 代码 · 共 121 行

package com.tarena.netctoss.model.biz;

import java.util.List;
import org.hibernate.*;
import com.tarena.util.*;
import com.tarena.netctoss.model.persist.*;
import com.tarena.netctoss.model.biz.entity.Price;

public class PriceServiceImpl implements IPriceService {

	public void add(Price price) {
		Session session = HibernateFactoryManager.getSession();
		IPriceDAO dao = DAOFactory.getPriceDAO();
		Transaction t = session.beginTransaction();
		try {
			dao.insert(price);
			t.commit();
		} catch (PriceException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}

	public void delete(Long price_id) {
		Session session = HibernateFactoryManager.getSession();
		IPriceDAO dao = DAOFactory.getPriceDAO();
		Transaction t = session.beginTransaction();
		try {
			Price price =dao.findByID(price_id);
			dao.delete(price);
			t.commit();
		} catch (PriceException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}

	public void delete(String[] price_id) {
		Session session = HibernateFactoryManager.getSession();
		IPriceDAO dao = DAOFactory.getPriceDAO();
		Transaction t = session.beginTransaction();
		try {
			for(int i=0;i<price_id.length;i++){
				Price price =dao.findByID(Long.valueOf(price_id[i]));
				dao.delete(price);
			}
			t.commit();
		} catch (PriceException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}

	public List<Price> findAll() {
		List<Price> prices = null;
		Session session = HibernateFactoryManager.getSession();
		IPriceDAO dao = DAOFactory.getPriceDAO();
		Transaction t = session.beginTransaction();
		try {
			prices = dao.findAll();
			t.commit();
		} catch (PriceException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		} finally{
			HibernateFactoryManager.releaseSession();
		}
		return prices;
	}

	public void modify(Price price) {
		Session session = HibernateFactoryManager.getSession();
		IPriceDAO dao = DAOFactory.getPriceDAO();
		Transaction t = session.beginTransaction();
		try {
			dao.update(price);
			t.commit();
		} catch (PriceException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
	}
	
	public Price findByID(Long price_id){
		Price price = null;
		Session session = HibernateFactoryManager.getSession();
		IPriceDAO dao = DAOFactory.getPriceDAO();
		Transaction t = session.beginTransaction();
		try {
			price = dao.findByID(price_id);
			t.commit();
		} catch (PriceException e) {
			e.printStackTrace();
			if(t!=null){
				t.rollback();
			}
		}finally{
			HibernateFactoryManager.releaseSession();
		}
		return price;
	}
}