catalogdaoimpl.java

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

package jaoso.news.dao.hibernate;

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

import jaoso.framework.exception.DAOException;

import jaoso.framework.util.MyUtils;

import jaoso.news.dao.CatalogDAO;

import jaoso.news.domain.Catalog;

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

import java.io.Serializable;

/**
 * @author Edgeloner
 * @version 0.9.1
 * @since 2004-5-29 Catalog DAO, persistent Catalog.
 */
public class CatalogDAOImpl implements CatalogDAO {
	/** log */
	private static Log log = LogFactory.getLog(CatalogDAOImpl.class);

	/** baseDAO */
	private BaseDAO baseDAO;

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

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

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

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#getCatalogByTitle(java.lang.String)
	 */
	public final Catalog getCatalogByTitle(final String name) {
		if (MyUtils.isBlank(name)) {
			return null;
		}

		Catalog[] catalogs = findCatalog("from Catalog a where a.tile='" + name
				+ "'");

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

		return catalogs[0];
	}

	/**
	 * find catalog with parent
	 * 
	 * @param parent
	 *            parent catalog id
	 * 
	 * @return catalog array
	 */
	public final Catalog[] getCatalogsByParent(final Serializable parent) {
		return findCatalog("from Catalog catalog where catalog.parent ='"
				+ parent + "'");
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#isExist(java.lang.String)
	 */
	public final boolean isExist(final String name) {
		boolean flage = false;

		if (MyUtils.isBlank(name)) {
			return flage;
		}

		try {
			// flage = getCatalogByDesc(name) != null;
			flage = ((Integer) baseDAO
					.findEntity("select count(*) from Catalog a where a.catalogTitle='"
							+ name + "'")[0]).intValue() > 0;
		} catch (DAOException e) {
			log.error("Catalog isExist error: ", e);
			throw e;
		}

		return flage;
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#isExist(java.lang.String,
	 *      java.io.Serializable)
	 */
	public final boolean isExist(final String name, final Serializable id) {
		boolean flage = false;

		if (MyUtils.isBlank(name) || (id == null)) {
			return flage;
		}

		try {
			flage = ((Integer) baseDAO
					.findEntity("select count(*) from Catalog a where a.catalogTitle='"
							+ name + "' and a.catalogId<>'" + id + "'")[0])
					.intValue() > 0;
		} catch (DAOException e) {
			log.error("Catalog isExist error: ", e);
			throw e;
		}

		return flage;
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#createCatalog(jaoso.framework.domain.Catalog)
	 */
	public final void createCatalog(final Catalog catalog) {
		baseDAO.saveEntity(catalog);
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#findAllCatalog()
	 */
	public final Catalog[] findAllCatalog() {
		return (Catalog[]) findCatalog("from Catalog a order by a.desc");
	}

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

		return findCatalog(myquery);
	}

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

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

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

		return entitys;
	}

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#removeCatalog(jaoso.framework.domain.Catalog)
	 */
	public final void removeCatalog(final Catalog catalog) {
		Catalog parent = catalog.getParent();

		if (parent != null) {
			parent.getChildren().remove(catalog);
			baseDAO.updateEntity(parent);
			baseDAO.removeEntity(catalog);
		} else {
			baseDAO.removeEntity(catalog);
		}

		baseDAO.removeEntity(catalog);
	}

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

		removeCatalog(getCatalog(id));
	}

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

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

	/**
	 * (non-Javadoc)
	 * 
	 * @see jaoso.framework.baseDAO.CatalogDAO#updateCatalog(jaoso.framework.domain.Catalog)
	 */
	public final void updateCatalog(final Catalog catalog) {
		baseDAO.updateEntity(catalog);
	}
}