userdaohibernateimpl.java

实现留言薄和发表文章的功能

package com.test.bbs.dao.impl;

import org.hibernate.Criteria;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Restrictions;

import com.test.bbs.dao.UserDao;
import com.test.bbs.domain.User;

public class UserDaoHibernateImpl implements UserDao {

/*	public void demo() {
		Session session = null;
		Transaction tx = null;
		try {
			session = null;//
			tx = session.beginTransaction();
			// ...
			tx.commit();
		} catch (HibernateException e) {
			tx.rollback();
			throw e;
		} finally {
			session.close();
		}
	}*/

	public void addUser(User user) {
		HibernateTools.getSessionFactory().getCurrentSession().save(user);
	}

	public User findUserById(Integer id) {
		Session session = HibernateTools.getSessionFactory()
				.getCurrentSession();
		User user = (User) session.get(User.class, id);
		return user;
	}

	public User findUserByLogonName(String logonName) {
		Session session = HibernateTools.getSessionFactory()
				.getCurrentSession();
		Criteria c = session.createCriteria(User.class);
		c.add(Restrictions.eq("logonName", logonName));
		User user = (User) c.uniqueResult();
		return user;
	}

	public User findUserByLogonNameAndPassword(String logonName, String password) {
		Session session = HibernateTools.getSessionFactory()
				.getCurrentSession();
		Criteria c = session.createCriteria(User.class);
		c.add(Restrictions.eq("logonName", logonName));
		c.add(Restrictions.eq("password", password));
		User user = (User) c.uniqueResult();
		return user;
	}

	public void update(User user) {
		HibernateTools.getSessionFactory().getCurrentSession().update(user);
	}

}