usersimpl.java

学校新闻发布系统

package org.users.impl;

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

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.news.hsf.HibernateSessionFactory;
import org.users.dao.IUsers;
import org.users.pojo.Users;

public class UsersImpl implements IUsers {
	private Session session;
	private Transaction tx;

	@Override
	public void create(Users user) {
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		session.save(user);
		tx.commit();
		HibernateSessionFactory.closeSession();
	}

	@Override
	public boolean delete(Users user) {
		boolean flag = false;
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		try {
			session.delete(user);
			flag = true;
		} catch (Exception ex) {
			ex.printStackTrace();
			flag = false;
		}
		tx.commit();
		HibernateSessionFactory.closeSession();
		return flag;
	}

	@Override
	public Users findByUsernameAndPassword(String username, String password) {
		Users user = null;
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		Query query = session
				.createQuery("from Users users where users.username=? and users.password=?");
		query.setString(0, username);
		query.setString(1, password);
		List newsList = query.list();
		tx.commit();
		for (Iterator iterator = newsList.iterator(); iterator.hasNext();) {
			user = (Users) iterator.next();
		}
		return user;
	}

	@Override
	public void update(Users user) {
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		session.update(user);
		tx.commit();
		HibernateSessionFactory.closeSession();
	}

	@Override
	public Users load(int id) {
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		Query q = session.createQuery("from Users where id=" + id);
		tx.commit();
		if (q.list().iterator().hasNext()) {

			return (Users) q.list().iterator().next();
		}
		return null;
	}

	@Override
	public List query(String hql) {
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		Query q = session.createQuery("from Users");
		tx.commit();
		return q.list();
	}

	@Override
	public boolean updateUser(Users user) {
		boolean flag = false;
		session = HibernateSessionFactory.getSession();
		tx = session.beginTransaction();
		try {
			session.update(user);
			flag = true;
		} catch (Exception ex) {
			ex.printStackTrace();
			flag = false;
		}
		return flag;
	}
}