abstractresultcache.java

羽量级数据持久层开发框架

package org.speedframework.cache;

import org.speedframework.exception.SpeedFrameworkException;
import org.speedframework.utilities.StringUtils;

/**
 * Class AbstractResultCache
 *
 * @author <a href="mailto:[e-mail]"> lizf </a>
 * @version $Revision:1.0.0, $Date: 2007-10-9 8:21:53 $
 */
public abstract class AbstractResultCache implements IResultCache {

	private ResultSetCacheAction rsc = new ResultSetCacheActionImpl();

	/* （非 Javadoc）
	 * @see org.speedframework.cache.IResultCache#getResults(java.lang.String, java.lang.Object[], boolean)
	 */
	public Object getResults(String sql, Object[] params, boolean useCache)
			throws SpeedFrameworkException {
		try {
			if (useCache) {
				return rsc.get(sql, params);
			}

			return null;
		} catch (Exception e) {
			throw new SpeedFrameworkException("Result Cache error ", e);
		}
	}

	/* （非 Javadoc）
	 * @see org.speedframework.cache.IResultCache#removeCache(java.lang.Object, boolean)
	 */
	public void removeCache(Object object, boolean useCache)
			throws SpeedFrameworkException {
		try {
			if (useCache) {
				String tableName = StringUtils.getExcuteTableName(object
						.getClass());

				rsc.remove(tableName);
			}
		} catch (Exception e) {
			throw new SpeedFrameworkException("Result Cache error ", e);
		}
	}

	/* （非 Javadoc）
	 * @see org.speedframework.cache.IResultCache#removeCache(java.lang.String, boolean)
	 */
	public void removeCache(String tableName, boolean useCache)
			throws SpeedFrameworkException {
		try {
			if (useCache) {
				rsc.remove(tableName);
			}
		} catch (Exception e) {
			throw new SpeedFrameworkException("Result Cache error ", e);
		}
	}

	/* （非 Javadoc）
	 * @see org.speedframework.cache.IResultCache#putResults(java.lang.String, java.lang.Object[], java.lang.Object, boolean)
	 */
	public void putResults(String sql, Object[] params, Object results,
			boolean useCache) throws SpeedFrameworkException {
		try {
			if (useCache) {
				rsc.save(sql, params, results);
			}
		} catch (Exception e) {
			throw new SpeedFrameworkException("Result Cache error ", e);
		}
	}
}