messageblacklistimpl.java

详细的建站源码 详细的建站源码 详细的建站源码 详细的建站源码

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

import java.util.List;

import org.apache.log4j.Logger;

import com.yeqiangwei.club.dao.MessageBlacklistDAO;
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.MessageBlacklist;
import com.yeqiangwei.club.param.MessageParameter;

public class MessageBlacklistImpl implements MessageBlacklistDAO {
	
	private static final Logger logger = Logger.getLogger(MessageBlacklistImpl.class);
	
	private static final String DELETE_MESSAGEBLACKLISTID = "delete MessageBlacklist where messageBlacklistId = ?";
	
	private static final String DELETES_MESSAGEBLACKLISTID = "delete MessageBlacklist where messageBlacklistId in (:ids)";
	
	private static final String DELETES_MYUSERID = "delete MessageBlacklist where myUserId = ?";
	
	private static final String FIND_MESSAGEBLACKLISTID = "from MessageBlacklist where messageBlacklistId=?";
	
	private static final String FIND_MYUSERID_USERID = "from MessageBlacklist where myUserId=? and userId=?";

	private HibernateProvider<MessageBlacklist> getHibernateProvider(){
		if(ConnectionProvider.whichConnection==0){
			logger.info("HibernateFacade...");
			return new HibernateFacade<MessageBlacklist>();
		}else{
			logger.info("HibernateUserFacade...");
			return new HibernateUserFacade<MessageBlacklist>();
		}
	}
	
	public MessageBlacklist create(MessageBlacklist item) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		item = hibernateProvider.save(item);
		return item;
	}

	public MessageBlacklist update(MessageBlacklist item) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		item = hibernateProvider.update(item);
		return item;
	}

	public int delete(MessageBlacklist item) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(DELETE_MESSAGEBLACKLISTID);
		hibernateProvider.setInt(0,item.getMessageBlacklistId());
		return hibernateProvider.executeUpdate();
	}

	public int delete(List ids) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(DELETES_MESSAGEBLACKLISTID);
		hibernateProvider.setParameterList("ids",ids);
		return hibernateProvider.executeUpdate();
	}

	public MessageBlacklist findById(int id) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(FIND_MESSAGEBLACKLISTID);
		hibernateProvider.setInt(0,id);
		return hibernateProvider.uniqueResult();
	}

	public List<MessageBlacklist> findByParameter(MessageParameter param) {
		StringBuffer sb = new StringBuffer();
		sb.append("from MessageBlacklist where messageBlacklistId>0");
		if(param.getMyUserId()!=null){
			sb.append(" and myUserId=");
			sb.append(param.getMyUserId().intValue());
		}
		//System.out.println(param.getPagination().getStartRow());
		//System.out.println(param.getPagination().getEndRow());
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(sb);
		hibernateProvider.setCacheable(true);
		hibernateProvider.setFirstResult(param.getPagination().getStartRow());
		hibernateProvider.setMaxResults(param.getPagination().getEndRow());
		List<MessageBlacklist> list = hibernateProvider.executeQuery();
		return list;
	}

	public long countByParameter(MessageParameter param) {
		StringBuffer sb = new StringBuffer();
		sb.append("select count(messageBlacklistId) from MessageBlacklist where messageBlacklistId>0");
		if(param.getMyUserId()!=null){
			sb.append(" and myUserId=");
			sb.append(param.getMyUserId().intValue());
		}
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(sb);
		hibernateProvider.setCacheable(true);
		return hibernateProvider.resultTotal();
	}

	public MessageBlacklist findByMyUserIdAndUserId(int myUserId, int userId) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(FIND_MYUSERID_USERID);
		hibernateProvider.setInt(0, myUserId);
		hibernateProvider.setInt(1, userId);
		hibernateProvider.setMaxResults(1);
		hibernateProvider.setCacheable(true);
		return hibernateProvider.uniqueResult();
	}

	public int deleteAllByMyUserId(int myUserId) {
		HibernateProvider<MessageBlacklist> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(DELETES_MYUSERID);
		hibernateProvider.setInt(0,myUserId);
		return hibernateProvider.executeUpdate();
	}

}