messagesendimpl.java

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

/* 
 * Created on 2005-11-4
 * Last modified on 2007-5-9
 * 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.MessageSendDAO;
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.MessageSend;
import com.yeqiangwei.club.param.MessageParameter;

public class MessageSendImpl implements MessageSendDAO{
	
	private static final Logger logger = Logger.getLogger(MessageSendImpl.class);
	
	private static final String FIND_SENDID = "from MessageSend where sendId=?";
	
	private static final String FIND_ALL = "from MessageSend order by sendId desc";
	
	private static final String COUNT_ALL = "select count(sendId) from MessageSend";
	
	private static final String DELETES_SENDID = "delete from MessageSend where sendId in (:ids)";
	
	private static final String DELETE_SENDID = "delete from MessageSend where sendId = ?";
	
	private static final String UPDATE_THATISOPENED = "update MessageSend set thatOpened=? where takeId = ?";
	
	private HibernateProvider<MessageSend> getHibernateProvider(){
		if(ConnectionProvider.whichConnection==0){
			logger.info("HibernateFacade...");
			return new HibernateFacade<MessageSend>();
		}else{
			logger.info("HibernateUserFacade...");
			return new HibernateUserFacade<MessageSend>();
		}
	}

	public int deleteByUserId(int userId) {
		return 0;
	}

	public int updateToIsSend(int sendId, boolean isSent) {
		return 0;
	}

	public MessageSend create(MessageSend item) {
		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
		item = hibernateProvider.save(item);		
		return item;
	}


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

	public int delete(MessageSend item) {
    	HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(DELETE_SENDID);
		hibernateProvider.setInt(0, item.getSendId());
		return hibernateProvider.executeUpdate();
	}

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

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

	public List<MessageSend> findByParameter(MessageParameter param) {
		StringBuffer sb = new StringBuffer();
		sb.append("from MessageSend where sendId>0");
		if(param.getSendId()!=null&&param.getSendId()>0){
			sb.append(" and sendId=");
			sb.append(param.getSendId());
		}
		if(param.getUserIdOfSend()!=null){
			sb.append(" and userIdOfSend=");
			sb.append(param.getUserIdOfSend());
		}
		if(param.getUserIdOfTake()!=null){
			sb.append(" and userIdOfTake=");
			sb.append(param.getUserIdOfTake());
		}
		sb.append(" order by sendId desc");
		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(sb);
    	hibernateProvider.setFirstResult(param.getPagination().getStartRow());
        hibernateProvider.setMaxResults(param.getPagination().getEndRow());
		List<MessageSend> list = hibernateProvider.executeQuery();   
		return list;
	}

	public long countByParameter(MessageParameter param) {
		StringBuffer hql = new StringBuffer();
        hql.append("select count(sendId) from MessageSend where sendId>0 ");
		if(param.getUserIdOfSend()!=null){
			hql.append(" and userIdOfSend=");
			hql.append(param.getUserIdOfSend());
		}
		if(param.getUserIdOfTake()!=null){
			hql.append(" and userIdOfTake=");
			hql.append(param.getUserIdOfTake());
		}
 		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
    	hibernateProvider.createQuery(hql);
    	hibernateProvider.setCacheable(true);
		return hibernateProvider.resultTotal();
	}

	public List<MessageSend> findAll(MessageParameter param) {
		List<MessageSend> list = null;
		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
    	hibernateProvider.createQuery(FIND_ALL);
    	hibernateProvider.setFirstResult(param.getPagination().getStartRow());
        hibernateProvider.setMaxResults(param.getPagination().getEndRow());
        list = hibernateProvider.executeQuery();  
		return list;
	}

	public long countAll(MessageParameter param) {
		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
    	hibernateProvider.createQuery(COUNT_ALL);
    	long c = hibernateProvider.resultTotal();
		return c;
	}

	public int update_thatIsOpened(int takeId, boolean thatOpened) {
		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(UPDATE_THATISOPENED);
		hibernateProvider.setBoolean(0,thatOpened);
		hibernateProvider.setInt(1, takeId);
		int c = hibernateProvider.executeUpdate();
		return c;
	}


	/*
	public MessageSend findOnlyByParameter(MessageParameter param) {
		StringBuffer sb = new StringBuffer();
		sb.append("from MessageSend where sendId>0");
		if(param.getUserIdOfSend()!=null){
			sb.append(" and userIdOfSend=");
			sb.append(param.getUserIdOfSend());
		}
		if(param.getUserIdOfTake()!=null){
			sb.append(" and userIdOfTake=");
			sb.append(param.getUserIdOfTake());
		}
		if(param.getSendId()!=null){
			sb.append(" and sendId=");
			sb.append(param.getSendId());
		}
		HibernateProvider<MessageSend> hibernateProvider = this.getHibernateProvider();
		hibernateProvider.createQuery(sb);
		hibernateProvider.setMaxResults(1);
		MessageSend item = hibernateProvider.uniqueResult();
		return item;
	}
	*/
}