taskimpl.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.Task;
import factory.HibernateSessionFactory;
import service.TaskService;

public class TaskImpl implements TaskService {
    Session session=null;
	public void CreateTask(Task task) {
		 session=HibernateSessionFactory.getSession();
		 Transaction tx=session.beginTransaction();
		 tx.begin();
		 session.save(task);
		 tx.commit();
		 session.close();
		 		
	}

	public void deleteTask(Integer id) {
		
		Session session = HibernateSessionFactory.getSession();
		Task task=(Task)session.load(Task.class, id);
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
			session.delete(task);
			tx.commit();
		} catch (HibernateException e) {
			e.printStackTrace();
			tx.rollback();
		} finally {
			session.close();
		}
		
	}

	public List findAllTask() {
		session=HibernateSessionFactory.getSession();
	    Query query=session.getNamedQuery("findAllTask");
	    List list=query.list();
	    session.close();
	    return list;
	    
	}

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

	}

	public List findTaskByState(String state) {
		Session session=HibernateSessionFactory.getSession();
	    Query query = session.createQuery("from Task where task_state=?");
	    query.setParameter(0,state);
	    List list=query.list();
		return list;
		
	}

	public void updateTask(Task task) {
		Session session=HibernateSessionFactory.getSession();
		Transaction tx=session.beginTransaction();
		
		tx.begin();
		session.update(task);
		session.close();
	}

	public List findTaskByMyUsername(String username) {
		Session session=HibernateSessionFactory.getSession();
	    Query query = session.createQuery("from Task where user_name=?");
	    query.setParameter(0, username);
	    List list=query.list();
	   
		return list;
	}

	public List findUndoTaskByLoadId(String sql) {
		Session session= HibernateSessionFactory.getSession();
		Query query=session.createQuery(sql);
		List list=query.list();
		session.close();
		return list;
		
	}
	
	
	
	

	
}