package com.hibernate.dao.impl;

import java.util.List;

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

import com.hibernate.dao.UserDao;
import com.hibernate.po.User;

/*
 * 实现类
 */
public class UserDaoImpl implements UserDao {
	private SessionFactory sessionFactory;

	public SessionFactory getSessionFactory() {
		return sessionFactory;
	}

	public void setSessionFactory(SessionFactory sessionFactory) {
		this.sessionFactory = sessionFactory;
	}

	// 登录
	public User canLogin(int id, String password) {
		User user = null;
		Session session = sessionFactory.openSession();
		String hql = "from User u where u.id=" + id + " and u.password='"
				+ password + "'";
		Query query = session.createQuery(hql);
		user = (User) query.uniqueResult();
		session.close();
		return user;
	}

	// 查询个人信息
	public User querydetail(int id) {
		User user = null;
		Session session = sessionFactory.openSession();
		String hql = "from User u where u.id=" + id;
		System.out.println(hql);
		Query query = session.createQuery(hql);
		user = (User) query.uniqueResult();
		session.close();
		return user;
	}

	// 修改个人信息详情
	public boolean updatedetail(int id, String nickname, int age, String sex,
			String mobile, String address) {
		Session session = sessionFactory.openSession();
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
			String hql = "update User u set u.nickname='" + nickname
					+ "',u.age=" + age + ",u.sex='" + sex + "',u.mobile='"
					+ mobile + "',u.address='" + address + "' where u.id=" + id;
			Query query = session.createQuery(hql);
			int i = query.executeUpdate();
			if (i == 1) {
				tx.commit();
				return true;
			}
		} catch (HibernateException e) {
			if (tx != null) {
				tx.rollback();// 回滚事务
				return false;
			}
			e.printStackTrace();
		} finally {
			session.close();// 关闭Session,释放资源
		}
		return false;
	}

	// 修改个人账户
	public boolean updateaccount(int id, String password, String nickname) {
		Session session = sessionFactory.openSession();
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
			String hql = "update User u set u.id=" + id + ",u.password='"
					+ password + "' where u.nickname='" + nickname + "'";
			Query query = session.createQuery(hql);
			int i = query.executeUpdate();
			if (i == 1) {
				tx.commit();
				return true;
			}
		} catch (HibernateException e) {
			if (tx != null) {
				tx.rollback();// 回滚事务
				return false;
			}
			e.printStackTrace();
		} finally {
			session.close();// 关闭Session,释放资源
		}
		return false;
	}

	// 修改昵称相关字段
	public void updateothers(String oldname, String newname) {
		Session session = sessionFactory.openSession();
		Transaction tx = null;
		try {
			String hql1 = "update Email e set e.receivers='" + newname
					+ "' where e.receivers='" + oldname + "'";
			String hql2 = "update Email e set e.sender='" + newname
					+ "' where e.sender='" + oldname + "'";
			String hql3 = "update Vocation v set v.nickname='" + newname
					+ "' where v.nickname='" + oldname + "'";
			String hql4 = "update Vocation v set v.examname='" + newname
					+ "' where v.examname='" + oldname + "'";
			tx = session.beginTransaction();
			Query query1 = session.createQuery(hql1);
			query1.executeUpdate();
			tx.commit();
			tx = session.beginTransaction();
			Query query2 = session.createQuery(hql2);
			query2.executeUpdate();
			tx.commit();
			tx = session.beginTransaction();
			Query query3 = session.createQuery(hql3);
			query3.executeUpdate();
			tx.commit();
			tx = session.beginTransaction();
			Query query4 = session.createQuery(hql4);
			query4.executeUpdate();
			tx.commit();
		} catch (Exception e) {
			if (tx != null) {
				tx.rollback();// 回滚事务
			}
			e.printStackTrace();
		} finally {
			session.close();// 关闭Session,释放资源
		}
	}

	// 查询全部账户列表
	@SuppressWarnings("unchecked")
	public List<User> getaccountsList() {
		List<User> accountlist = null;
		Session session = sessionFactory.openSession();
		String hql = "from User";
		Query query = session.createQuery(hql);
		accountlist = query.list();
		session.close();
		return accountlist;
	}

	// 添加账户
	public boolean addaccount(User user) {
		Session session = sessionFactory.openSession();
		Transaction tx = null;
		try {
			tx = session.beginTransaction();
			session.save(user);
			tx.commit();
			return true;
		} catch (HibernateException e) {
			if (tx != null) {
				tx.rollback();// 回滚事务
				return false;
			}
			e.printStackTrace();
		} finally {
			session.close();// 关闭Session,释放资源
		}
		return false;
	}
}