userinfoserviceimpl.java

这是《Struts网络编程实例》一书zhogn 的源代码部分

package org.ithinking.strutsExample.serviceImpl;

import java.util.List;

import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.criterion.Expression;
import org.ithinking.datamanager.HibernateSessionFactory;
import org.ithinking.strutsExample.entity.Userinfo;
import org.ithinking.strutsExample.service.UserInfoService;

public class UserInfoServiceImpl implements UserInfoService {

	public Userinfo getUserInfoByLoginId(String userLoginId) {

		if (userLoginId == null || userLoginId.trim().length() <= 0)
			return null;
		Session session = null;
		try {
			session = HibernateSessionFactory.currentSession();
			Criteria criteria = session.createCriteria(Userinfo.class);
			criteria.add(Expression.eq("userloginid", userLoginId));
			List list = criteria.list();
			if (list == null || list.isEmpty()) {
				return null;
			} else {
				HibernateSessionFactory.closeSession();
				return (Userinfo) list.get(0);
			}
		} catch (Exception ex) {
			ex.printStackTrace();

		} finally {
			if (session != null) {
				HibernateSessionFactory.closeSession();
			}
		}
		return null;
	}

	public Userinfo getUserInfoById(Integer id) {
		if (id == null || id.intValue() < 0)
			return null;
		Session session = null;
		try {
			session = HibernateSessionFactory.currentSession();
			Criteria criteria = session.createCriteria(Userinfo.class);
			criteria.add(Expression.eq("id", id));
			List list = criteria.list();
			if (list == null || list.isEmpty()) {
				return null;
			} else {
				HibernateSessionFactory.closeSession();
				return (Userinfo) list.get(0);
			}
		} catch (Exception ex) {
			ex.printStackTrace();

		} finally {
			if (session != null) {
				HibernateSessionFactory.closeSession();
			}
		}
		return null;
	}

	public List getUserInfoList() {
		Session session = null;
		try {
			session = HibernateSessionFactory.currentSession();
			Criteria criteria = session.createCriteria(Userinfo.class);
			List list = criteria.list();
			return list;
		} catch (Exception ex) {
			ex.printStackTrace();

		} finally {
			if (session != null) {
				HibernateSessionFactory.closeSession();
			}
		}
		return null;
	}

	public boolean saveUser(Userinfo userInfo) {
		//如果是新数据，并且该登陆名已存在，则返回错误信息
		if (this.getUserInfoByLoginId(userInfo.getUserloginid()) != null&&userInfo.getId() == null)
			return false;
		Session session = null;
		try {
			session = HibernateSessionFactory.currentSession();
			if (userInfo.getId() != null) {
				session.update(userInfo);
			} else {
				session.save(userInfo);
			}
			session.flush();
			return true;
		} catch (Exception ex) {
			ex.printStackTrace();

		} finally {
			if (session != null) {
				HibernateSessionFactory.closeSession();
			}
		}
		return false;
	}

	public boolean deleteUser(Userinfo userInfo) {
		if (this.getUserInfoByLoginId(userInfo.getUserloginid()) == null)
			return false;
		Session session = null;
		try {
			session = HibernateSessionFactory.currentSession();
			session.delete(userInfo);
			session.flush();
			return true;
		} catch (Exception ex) {
			ex.printStackTrace();

		} finally {
			if (session != null) {
				HibernateSessionFactory.closeSession();
			}
		}
		return false;
	}
}