userinfodaohibernate.java

来自「这个是完整的wap项目的源码 开发语言 Java 系统架构 Struts +」· Java 代码 · 共 159 行

package com.longtime.wap.module.cost.dao.hibernate;

import java.sql.SQLException;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.HibernateCallback;

import com.longtime.wap.common.BaseDao;
import com.longtime.wap.common.web.Page;
import com.longtime.wap.model.UserInfo;
import com.longtime.wap.module.cost.dao.UserInfoDao;

/**
 * 用户信息Dao层实现代码
 * 
 * @author chenxq
 * @date 2007-11-30
 */
public class UserInfoDaoHibernate extends BaseDao implements UserInfoDao {

	/**
	 * 用来实现“创建用户对象”的功能
	 * 
	 * @param userInfo
	 *            用户对象
	 */
	public void createUserInfo(UserInfo userInfo) {
		this.getHibernateTemplate().saveOrUpdate(userInfo);
	}

	/**
	 * 用来实现“批量删除用户对象”的功能
	 * 
	 * @param userInfoList
	 *            用户对象集合
	 */
	public void deleteUserInfosByIds(List userInfoList) {
		this.getHibernateTemplate().deleteAll(userInfoList);
	}

	/**
	 * 用来实现“根据用户id获取用户对象”的功能
	 * 
	 * @param id
	 *            用户id
	 * @return 用户对象
	 */
	public UserInfo retrieveUserInfoById(Long id) {
		return (UserInfo) this.getHibernateTemplate().get(UserInfo.class, id);
	}

	/**
	 * 用来实现“根据用户id数组获取用户对象集合”的功能。该方法在批量删除的时候需要用到
	 * 
	 * @param ids
	 *            用户id数组
	 * @return 用户对象集合
	 */
	public List retrieveUserInfosByIds(final String[] ids) {
		return this.getHibernateTemplate().executeFind(new HibernateCallback() {

			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				StringBuilder hql = new StringBuilder("from UserInfo where ");
				for (int i = 0; i < ids.length; i++) {
					hql.append("userId=" + ids[i]);
					if (i < ids.length - 1) {
						hql.append(" or ");
					}
				}
				Query query = session.createQuery(hql.toString());
				return query.list();
			}

		});
	}

	/**
	 * 用来实现“获取用户中是Cp管理员的记录数”的功能。Cp管理员的groupId为1
	 * 
	 * @return Cp管理员的记录数
	 */
	public int retrieveUserInfosCount() {
		return (Integer) this.getHibernateTemplate().execute(
				new HibernateCallback() {
					public Object doInHibernate(Session session)
							throws HibernateException, SQLException {
						StringBuilder hql = new StringBuilder(
						    "select count(*) from UserInfo where groupId=1");
						Query query = session.createQuery(hql.toString());
						return query.uniqueResult();
					}
				});
	}

	/**
	 * 用来实现“更新用户对象”的功能
	 * 
	 * @param userInfo
	 *            用户对象
	 */
	public void updateUserInfo(UserInfo userInfo) {
		this.getHibernateTemplate().saveOrUpdate(userInfo);
	}

	/**
	 * 获取用户信息列表
	 * 
	 * @param page
	 *            分页对象
	 * @return 用户信息列表
	 */
	public List retrieveUserInfos(final Page page) {
		return this.getHibernateTemplate().executeFind(new HibernateCallback() {

			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				StringBuilder hql = new StringBuilder(
						"from UserInfo where groupId=1 order by userId");
				Query query = session.createQuery(hql.toString());
				return query.setFirstResult(page.getFirstResult())
						.setMaxResults(page.getPageSize()).list();
			}

		});
	}

	/**
	 * 检查添加或编辑cp管理员时，是否存在重复的登录名或者昵称
	 * 
	 * @param username
	 *            用户名
	 * @param nickname
	 *            昵称
	 * @return 存在的列表
	 */
	public List checkUserInfoExisted(final String username,
			final String nickname) {
		return this.getHibernateTemplate().executeFind(new HibernateCallback() {

			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				StringBuilder hql = new StringBuilder(
						"from UserInfo where userName=? or nickname=?");
				Query query = session.createQuery(hql.toString());
				query.setString(0, username);
				query.setString(1, nickname);
				return query.list();
			}

		});

	}

}