forumdaoimp.java

用Hibernate开发的JiveJdon

package com.jdon.jivejdon.dao.hibernate;

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

import org.apache.log4j.Logger;

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

public class ForumDaoImp implements ForumDao {
	
	private final static Logger logger = Logger.getLogger(ForumDaoImp.class);

	private DaoCRUD daoCRUD;
	
	public ForumDaoImp(DaoCRUD daoCRUD) {
		this.daoCRUD = daoCRUD;
	}


	public void createForum(Forum forum) throws Exception {
		daoCRUD.insert(forum);
	}
	

	public void updateForum(Forum forum) throws Exception{
		daoCRUD.update(forum);
	}


	public void deleteForum(Forum forum)throws Exception {
		daoCRUD.delete(forum);
	}


	public Forum getForum(Long forumId) {
		logger.debug(" get forum " + forumId);
		Forum forum = null;
         try {
        	 forum = (Forum)daoCRUD.loadById(Forum.class, forumId);
		} catch (Exception e) {
			e.printStackTrace();
		}
         return forum;
	}
	
	public int getMessageCount(Long forumId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select count(message) from ForumMessage message where forum.forumId = ?",forumId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}
		return allcount.intValue();
	}

	
	public int getThreadCount(Long forumId)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();
		}
		return allcount.intValue();
	}
	
	public Long getLastPostMessageId(Long forumId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		Iterator results = hibernateTemplate.find("select message.messageId from ForumMessage message where forum.forumId = ? order by modifiedDate ASC",forumId)
		                   .iterator();
		Long allcount = new Long(0);
		while ( results.hasNext() ) {
			allcount = (Long) results.next();
		}
		return allcount;
	}


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

		hibernateTemplate.setFirstResult(start);
		hibernateTemplate.setMaxResults(count);
		List pageIds = hibernateTemplate.find("select forum.forumId from Forum forum order by forum.forumId");
		hibernateTemplate.setFirstResult(0);
		hibernateTemplate.setMaxResults(0);
        return new PageIterator(allcount.intValue(), pageIds.toArray());
	}
	
	public List getAllThreadIdByForum(Long forumId)throws Exception {
		HibernateTemplate hibernateTemplate = ((HibernateCRUDTemplate)daoCRUD).getHibernateTemplate();
		hibernateTemplate.setCacheQueries(true);
		List messageIds = hibernateTemplate.find("select thread.threadId from ForumThread thread where forum.forumId = ?",forumId);
		return messageIds;
	}

}