userindexedimpl.java

野蔷薇论坛源码 java 自己看看吧。 学习用

/* 
 * Created on 2007-9-22
 * Last modified on 2007-9-22
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.dao.hibernate.impl;

import java.util.List;

import org.hibernate.HibernateException;

import com.yeqiangwei.club.dao.UserIndexedDAO;
import com.yeqiangwei.club.dao.hibernate.ConnectionProvider;
import com.yeqiangwei.club.dao.hibernate.support.HibernateFacade;
import com.yeqiangwei.club.dao.hibernate.support.HibernateProvider;
import com.yeqiangwei.club.dao.hibernate.support.HibernateUserFacade;
import com.yeqiangwei.club.dao.model.UserIndexed;
import com.yeqiangwei.club.exception.DAOException;

public class UserIndexedImpl implements UserIndexedDAO{
	
	//private static final Logger logger = Logger.getLogger(UserIndexedImpl.class);
	
	private static final String DELETE_USERID = "delete from UserIndexed where userId=?";
	
	private static final String FIND_USERID = "from UserIndexed where userId=?";
	
	private static final String FIND_USERID_SERVERNAME = "from UserIndexed where userId=? and serverName=?";
	
	private HibernateProvider<UserIndexed> getHibernateProvider(){
		if(ConnectionProvider.whichConnection==0){
			//logger.info("HibernateFacade...");
			return new HibernateFacade<UserIndexed>();
		}else{
			//logger.info("HibernateUserFacade...");
			return new HibernateUserFacade<UserIndexed>();
		}
	}

	public void create(UserIndexed item) throws DAOException {
		HibernateProvider<UserIndexed> hibernateProvider = this.getHibernateProvider();
		try{
			hibernateProvider.save(item);
		}catch(HibernateException e){
			throw new DAOException(e);
		}
	}

	public int deleteByUserId(int userId) throws DAOException {
		HibernateProvider<UserIndexed> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(DELETE_USERID);
		hibernateProvider.setInt(0,userId);
		try{
			return hibernateProvider.executeUpdate();
		}catch(HibernateException e){
			throw new DAOException(e);
		}
	}

	public List<UserIndexed> findByUserId(int userId) {
		HibernateProvider<UserIndexed> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(FIND_USERID);
		hibernateProvider.setInt(0,userId);
		return hibernateProvider.executeQuery();
	}

	public UserIndexed findByUserIdAndServerName(int userId, String serverName) {
		HibernateProvider<UserIndexed> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(FIND_USERID_SERVERNAME);
		hibernateProvider.setInt(0,userId);
		hibernateProvider.setString(1, serverName);
		hibernateProvider.setMaxResults(1);
		return hibernateProvider.uniqueResult();
	}

}