messagedaoimpl.java

Jaoso新闻文章发布系统 0.9.1final 程序架构: Struts+Spring+Hibernate 主要功能： ·新闻采用在线编辑器,可以象使用word一样编辑新闻,可简繁

package jaoso.guestbook.dao.hibernate;

import jaoso.framework.dao.BaseDAO;
import jaoso.framework.dao.MyQuery;

import jaoso.framework.exception.DAOException;

import jaoso.framework.util.MyUtils;

import jaoso.guestbook.dao.MessageDAO;

import jaoso.guestbook.domain.Message;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import java.io.Serializable;

/**
 * @author Administrator
 * @version 0.9.1
 * @since 2004-5-29 Message DAO, persistent Message.
 */
public class MessageDAOImpl implements MessageDAO {
	/** log */
	private static Log log = LogFactory.getLog(MessageDAOImpl.class);

	/** baseDAO */
	private BaseDAO baseDAO;

	/**
	 * Creates a new MessageDAOImpl object.
	 */
	public MessageDAOImpl() {
		super();
	}

	/**
	 * @param dao
	 *            dao
	 */
	public final void setBaseDAO(final BaseDAO dao) {
		baseDAO = dao;
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#getMessage(java.io.Serializable)
	 */
	public final Message getMessage(final Serializable id) {
		return (Message) baseDAO.loadEntity(Message.class, id);
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#getMessageByName(java.lang.String)
	 */
	public final Message[] getMessageByCatalog(final Serializable id) {
		if (MyUtils.isBlank(id)) {
			return null;
		}

		return findMessage("from Message a where a.catalog='" + id
				+ "' order by a.createDate desc");
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#createMessage(jaoso.framework.domain.Message)
	 */
	public final void createMessage(final Message message) {
		baseDAO.saveEntity(message);
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#findAllMessage()
	 */
	public final Message[] findAllMessage() {
		return (Message[]) findMessage("from Message a order by a.desc");
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#findMessage(java.lang.String)
	 */
	public final Message[] findMessage(final String query) {
		MyQuery myquery = new MyQuery();
		myquery.setQueryString(query);

		return findMessage(myquery);
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#findMessage(jaoso.framework.baseDAO.MyQuery)
	 */
	public final Message[] findMessage(final MyQuery query) {
		Object[] os = baseDAO.findEntity(query);

		if (MyUtils.isBlank(os)) {
			return null;
		}

		Message[] entitys = new Message[os.length];
		System.arraycopy(os, 0, entitys, 0, os.length);

		return entitys;
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#removeMessage(java.io.Serializable)
	 */
	public final void removeMessage(final Serializable id) {
		if (id == null) {
			throw new DAOException("id can't be null");
		}

		removeMessage(getMessage(id));
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#removeMessage(java.io.Serializable[])
	 */
	public final void removeMessage(final Serializable[] ids) {
		if (ids == null) {
			throw new DAOException("id can't be null");
		}

		for (int i = 0, n = ids.length; i < n; i++) {
			removeMessage(ids[i]);
		}
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.MessageDAO#updateMessage(jaoso.framework.domain.Message)
	 */
	public final void updateMessage(final Message message) {
		baseDAO.updateEntity(message);
	}
}