package cn.handson.dao;

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

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


import cn.handson.base.*;
import cn.handson.utils.*;

public class EmployeeDao {
	
	/*
	 * 此方法用來驗證登陸用戶的合法性。。。
	 * 
	 */
	
	
	public String login(Employee user) {
		// TODO Auto-generated method stub
		String hefa;
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定義一個事務 
		String sql="select b from Employee as b where b.employeeUsername='"+user.getEmployeeUsername()+"' and b.employeePassword='"+user.getEmployeePassword()+"'";
		Query query=session.createQuery(sql);
		List list=query.list();
		tx.commit();//提交事務
		HibernateUtil.closeSession();
		int i=list.size();
		if(i==0){
			hefa="";
		}else{
			hefa="ok";
			System.out.println(hefa);
		}
		return hefa;
	}
	
	
	/*
	 * 此方法用來驗證登陸用戶的合法性。。。
	 * 
	 */
	
	
	public List getEmployeeIteam() {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定義一個事務 
		String sql="select b from Employee as b where b.depart.departId=3";
		Query query=session.createQuery(sql);
		List list=query.list();
		tx.commit();//提交事務
		HibernateUtil.closeSession();
		return list;
	}
	
	
	/*
	 * 此方法用來得到所有的員工表對象。。。
	 * 
	 * 
	 */
	
	public List loadAllEmployee() {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定義一個事務 
		String sql="select b from Employee as b";
		Query query=session.createQuery(sql);
		List list=query.list();
		tx.commit();//提交事務
		//HibernateUtil.closeSession();
		return list;
		
	}
	/*
	 * 此方法用來刪除員工表對象.....
	 * 
	 */
	public boolean deleteEmployee(Employee ey){
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定義一個事務 
		session.delete(ey);
		tx.commit();//提交事務
		//HibernateUtil.closeSession();
		return true;
	}
	
	/*
	 * 此方法用來通過ID來得到一個員工表的對象。。。
	 * 
	 * 
	 */
	
	public Employee getEmployeeById(Integer id) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定義一個事務 
        Employee us=(Employee)session.get(Employee.class, id);
		tx.commit();//提交事務
		//HibernateUtil.closeSession();
		return us;
	}
    
	
	/*
	 * 此方法用來通過ID來得到一個員工表的對象。。。
	 * 
	 * 
	 */
	
	public Employee getEmployeeByName(String name) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定義一個事務 
        String sql="select b from Employee as b where b.employeeUsername='"+name+"'";
        Query query=session.createQuery(sql);
		List list=query.list();
		tx.commit();//提交事務
		Iterator it=list.iterator();
		Employee ww=new Employee();
		while(it.hasNext()){
			ww=(Employee)it.next();
		}
		HibernateUtil.closeSession();
		return ww; 
	}
	
	
	/*
	 * 此方法用來更新數據庫中的員工。。。
	 * 
	 */
	
	public void updateEmployee(Employee ey) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定義一個事務 
        Employee us=(Employee)session.get(Employee.class, ey.getEmployeeId());
		us.setEmployeeName(ey.getEmployeeName());
		us.setEmployeeUsername(ey.getEmployeeUsername());
		us.setEmployeePassword(ey.getEmployeePassword());
		us.setDepart(ey.getDepart());
		us.setEmployeeRemark(ey.getEmployeeRemark());
		session.save(us);
		tx.commit();//提交事務
		//HibernateUtil.closeSession();
	}
	
	/*
	 * 此方法用來添加員工。。。。
	 *
	 * 
	 */
	
	public void addEmployee(Employee ey) {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
        Transaction tx=session.beginTransaction();//定義一個事務 
		session.save(ey);
		tx.commit();//提交事務
		//HibernateUtil.closeSession();
		
	}
	
	
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		
		List list=new EmployeeDao().getEmployeeIteam();
		Iterator iter=list.iterator();
		while(iter.hasNext()){
			Employee aa=(Employee)iter.next();
			System.out.println(aa.getEmployeeName());
		}
		/*
		Employee wu=new EmployeeDao().getEmployeeByName("wuhaibao");
		System.out.println(wu.getEmployeeUsername());
		*/
	}
	
	
	public List loadAll() {
		// TODO Auto-generated method stub
		Session session=HibernateUtil.currentSession();
		Transaction tx=session.beginTransaction();//定義一個事務 
		String sql="select b from Employee as b where b.depart.departId=3";
		Query query=session.createQuery(sql);
		List list=query.list();
		tx.commit();//提交事務
		//HibernateUtil.closeSession();
		return list;
		
	}

}