planimpl.java

大唐电信的管理系统

package realize;

import java.util.List;

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

import domain.Plan;
import factory.HibernateSessionFactory;
import service.PlanService;

public class PlanImpl implements PlanService {
     
	 Session session=null;
	public void createPlan(Plan plan) {
		 session=HibernateSessionFactory.getSession();
		
		 Transaction tx=session.beginTransaction();
		 tx.begin();
		 session.save(plan);
		 tx.commit();
		 session.close();
		
	}

	public void deletePlan(Plan plan) {
		session=HibernateSessionFactory.getSession();
		 Transaction tx=session.beginTransaction();
		 tx.begin();
		 session.delete(plan);
		 tx.commit();
		 session.close();
		
	}

	public Plan findPlanById(Integer id) {
		session=HibernateSessionFactory.getSession();
	    Query query=session.getNamedQuery("findPlanById");
	    query.setParameter(0, id);
	    List list=query.list();
	    session.close();
	    if(list.size()==0){
	    	return null;
	    }else{
	    	return (Plan)list.get(0);
	    }
	  
	}

	public List findPlanByTaskId(Integer id) {
		session=HibernateSessionFactory.getSession();
	    Query query=session.getNamedQuery("findPlanByTaskId");
	    query.setParameter(0, id);
	    List list=query.list();
	    session.close();
	    return list;
		
	}

	public void findPlanByTime() {
		
		
	}

	public void updatePlan(Plan plan) {
		session=HibernateSessionFactory.getSession();
		 Transaction tx=session.beginTransaction();
		 tx.begin();
		 session.update(plan);
		 tx.commit();
		 session.close();
		
	}
	

	public List queryPlan(String sql) {
		Session session=HibernateSessionFactory.getSession();
		
		Query query = session.createQuery(sql);
		List planlist=query.list();
		
		return planlist;
	}
	
	 public void deletePlan(Integer id){
		 Session session=HibernateSessionFactory.getSession();
		 Plan plan=(Plan)session.load(Plan.class,id );
			Transaction tx = null;
			
				tx = session.beginTransaction();
				session.delete(plan);
				tx.commit();
			
				session.close();
			
	 }
   
	
}