package module.dao.impl;

import java.util.List;

import module.dao.UserDao;
import module.pojo.UserPo;

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

public class UserDaoImpl implements UserDao {

	SessionFactory sf;
	public SessionFactory getSf() {
		return sf;
	}

	public void setSf(SessionFactory sf) {
		this.sf = sf;
	}

	/**
	 * Hibernate: insert into Hibernate_User (U_name, U_password, U_id) values (?, ?, ?)
	 */
	public boolean userSave(UserPo user) {
		//之前我们自己写的sf工具
//		Session session = HibernateUtil.getSession();
		//使用Spring整合Hibernate之后,Springioc帮我们注入进来了该sf
		Session session = sf.openSession();
		
		//开启事务(Hibernate的)
		Transaction tc = session.beginTransaction();
		try {
			session.save(user);
			tc.commit();
		} catch (Exception e) {
			System.out.println("保存异常");
			e.printStackTrace();
			return false;
		}finally{
			session.close();
		}
		
		return true;
	}
	
	/**
	 * //Hibernate: update Hibernate_User set U_name=?, U_password=? where U_id=?
	 */
	public boolean userUpdate(UserPo user) {
		
		return true;
	}
	
	/**
	 * Hibernate: delete from Hibernate_User where U_id=?
	 */
	public boolean userDelete(UserPo user) {
		
		return true;
	}
	
	//查询全部记录
	public List<UserPo> userSearchAll() {
		
		String hql = "from UserPo"; 
		Session session = sf.openSession();
		System.out.println(session);
		Query query = session.createQuery(hql);
		
		List<UserPo> list = query.list();//hibenrate 内部给我们进行数据封装成对象
		session.close();
		return list;
	}
	
	//根据id查询一个user
	public UserPo userGetUserPoById(int id) {
		return null;
	}

}