messagequerydaoimp.java

用Hibernate开发的JiveJdon

package com.jdon.jivejdon.dao.hibernate;

import java.util.Iterator;
import java.util.List;

import com.jdon.controller.model.PageIterator;
import com.jdon.jivejdon.dao.MessageQueryDao;
import com.jdon.persistence.DaoCRUD;
import com.jdon.persistence.hibernate.HibernateCRUDTemplate;
import com.jdon.persistence.hibernate.HibernateTemplate;

public class MessageQueryDaoImp implements MessageQueryDao {

	private DaoCRUD daoCRUD;

	public MessageQueryDaoImp(DaoCRUD daoCRUD) {
		this.daoCRUD = daoCRUD;
	}
	
	public PageIterator getMessages(Long threadId, int start, int count)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select count(message) from ForumMessage message where forumThread.threadId = ?",threadId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}

		hibernateTemplate.setFirstResult(start);
		hibernateTemplate.setMaxResults(count);
		List pageIds = hibernateTemplate.find("select message.messageId from ForumMessage message where forumThread.threadId = ? order by message.messageId",threadId);
		hibernateTemplate.setFirstResult(0);
		hibernateTemplate.setMaxResults(0);
        return new PageIterator(allcount.intValue(), pageIds.toArray());
	}
	
	public PageIterator getMessagesByUser(Long userId, int start, int count)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select count(message) from ForumMessage message where account.userId = ?",userId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}

		hibernateTemplate.setFirstResult(start);
		hibernateTemplate.setMaxResults(count);
		List pageIds = hibernateTemplate.find("select message.messageId from ForumMessage message where userId = ? order by message.messageId",userId);
		hibernateTemplate.setFirstResult(0);
		hibernateTemplate.setMaxResults(0);
        return new PageIterator(allcount.intValue(), pageIds.toArray());
	}


	public PageIterator getThreads(Long forumId, int start, int count)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select count(thread) from ForumThread thread where forum.forumId = ?",forumId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}

		hibernateTemplate.setFirstResult(start);
		hibernateTemplate.setMaxResults(count);
		List pageIds = hibernateTemplate.find("select thread.threadId from ForumThread thread where forum.forumId = ? order by thread.modifiedDate DESC",forumId);
		hibernateTemplate.setFirstResult(0);
		hibernateTemplate.setMaxResults(0);
        return new PageIterator(allcount.intValue(), pageIds.toArray());
	}
	
	public int getMessageCount(Long threadId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select count(message) from ForumMessage message where forumThread.threadId = ?",threadId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}
		return allcount.intValue();
	}
	
	public Long getLastPostMessageId(Long threadId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select message.messageId from ForumMessage message where forumThread.threadId = ? order by modifiedDate ASC",threadId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}
		return allcount;
	}
	
	public List getAllMessageIdByThread(Long threadId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		List messageIds = hibernateTemplate.find("select message.messageId from ForumMessage message where forumThread.threadId = ?",threadId);
		return messageIds;
	}
	
	
	public int getMessageCountOfUser(Long userId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select count(message) from ForumMessage message where account.userId = ?",userId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}
		return allcount.intValue();
	}
	
	public Long getRootMessageId(Long threadId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select message.messageId from ForumMessage message where forumThread.threadId = ? and isRoot =1",threadId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}
		return allcount;
	}

}