messagedaoimpl.java

版本信息：Jaoso新闻文章发布系统 0.9.1beta1 原POPTEN新闻发布系统现更名为Jaoso,不兼容popten,目前不提供popten升级Jaoso的程序.

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 {

    //~ Static fields/initializers =============================================

    /**  log */
    private static Log log = LogFactory.getLog(MessageDAOImpl.class);

    //~ Instance fields ========================================================

    /**  baseDAO */
    private BaseDAO baseDAO;

    //~ Constructors ===========================================================

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

    //~ Methods ================================================================

    /**
     * @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);
    }
}