topicdao.java

在线读书交流平台

package com.olr.dao;

import java.util.Date;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.Criteria;
import org.hibernate.LockMode;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.MatchMode;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.springframework.context.ApplicationContext;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.olr.beans.Book;
import com.olr.beans.Forum;
import com.olr.beans.Message;
import com.olr.beans.Topic;
import com.olr.util.Pager;

/**
 * A data access object (DAO) providing persistence and search support for Topic
 * entities. Transaction control of the save(), update() and delete() operations
 * can directly support Spring container-managed transactions or they can be
 * augmented to handle user-managed Spring transactions. Each of these methods
 * provides additional information for how to configure it for the desired type
 * of transaction control.
 * 
 * @see com.olr.beans.Topic
 * @author MyEclipse Persistence Tools
 */

public class TopicDAO extends HibernateDaoSupport implements ITopicDAO{

	public void deleteTopic(int topicId) {
		Object t=this.getHibernateTemplate().load(Topic.class,new Integer(topicId));
		this.getHibernateTemplate().delete(t);
		
	}

	public List<Topic> getChildTopics(int topicId) {
		Session session=this.getHibernateTemplate().getSessionFactory().openSession();
		Criteria criteria=session.createCriteria(Topic.class);
		criteria.add(Restrictions.eq("parentId", topicId));
		criteria.addOrder(Order.asc("postdate"));
		List<Topic> result=criteria.list();
		return result;
	}

	public Pager getParentTopicsPager(int forumId,int pageSize,int pageNo) {
         Session session=this.getHibernateTemplate().getSessionFactory().openSession();
         Criteria criteria=session.createCriteria(Topic.class);
         criteria.add(Restrictions.eq("forumId", forumId));
         criteria.add(Restrictions.eq("parentId", 0));
		int rowCount=((Integer)criteria.setProjection(
				Projections.rowCount()).uniqueResult()).intValue();
		criteria.setProjection(null);
		int startIndex=pageSize*(pageNo-1);
		criteria.addOrder(Order.desc("postdate"));
		criteria.setFirstResult(startIndex);
		criteria.setMaxResults(pageSize);
		List result=criteria.list();
		session.close();
		return new Pager(pageSize,pageNo,rowCount,result); 
	}
	
	public List<Topic> getTopTopic(int topNum){
		Session session=this.getHibernateTemplate().getSessionFactory().openSession();
		Criteria criteria=session.createCriteria(Topic.class);
		 criteria.add(Restrictions.eq("parentId", 0));
		criteria.addOrder(Order.asc("replies"));
		List<Topic> result=criteria.list();
		return result;
	}

	public void insertTopic(Topic topic) {
		this.getHibernateTemplate().save(topic);
		
	}
	
	public void updateTopic(Topic topic){
		this.getHibernateTemplate().update(topic);
	}
	

	public Pager searchParentTopicPager(String titleLike, String contentLike,int pageSize,int pageNo) {
		 Session session=this.getHibernateTemplate().getSessionFactory().openSession();
			
			Criteria criteria=session.createCriteria(Topic.class);
			criteria.add(Restrictions.ilike("topicName","%"+titleLike+"%",MatchMode.ANYWHERE));
			criteria.add(Restrictions.ilike("content","%"+contentLike+"%",MatchMode.ANYWHERE));
			int rowCount=((Integer)criteria.setProjection(
					Projections.rowCount()).uniqueResult()).intValue();
			criteria.setProjection(null);
			int startIndex=pageSize*(pageNo-1);
			criteria.addOrder(Order.desc("postdate"));
			criteria.setFirstResult(startIndex);
			criteria.setMaxResults(pageSize);
			List result=criteria.list();
			session.close();
			return new Pager(pageSize,pageNo,rowCount,result); 
	}

	public Topic getTopic(int topicId) {
		return (Topic) this.getHibernateTemplate().load(Topic.class,topicId);
	}
	
}