abstractresultsaction.java

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

package org.speedframework.action;

import org.speedframework.entity.Pagination;
import org.speedframework.entity.ParamEntity;
import org.speedframework.exception.SpeedFrameworkException;
import org.speedframework.message.IMessage;
import org.speedframework.sql.ISelectSQL;

/**
 * Class AbstractResultsAction
 * 
 * @author <a href="mailto:[e-mail]"> lizf </a>
 * @version $Revision:1.0.0, $Date: 2007-10-10 1:45:20 $
 */
public abstract class AbstractResultsAction extends AbstractAction implements
		IResultsAction {

	/*
	 * （非 Javadoc）
	 * 
	 * @see org.speedframework.action.IAction#doAction(org.speedframework.message.IMessage)
	 */
	public void doAction(IMessage message) {
		log.debug("Speed Query is GetResults...");

		String limitSql;
		String count;
		ParamEntity entity = message.getParamEntity();
		Object pojo = entity.getEntity();
		String sql = entity.getSQL();
		Object[] params = entity.getParam();
		Pagination pagination = entity.getPagination();
		Class vo = entity.getLoadclass();

		try {
			ISelectSQL sOffer = factory.getSelectSQL();
			sOffer.setTableObject(pojo);
			String countSql = sOffer.getCountSQL(sql);

			count = (String) resultCache.getResults(countSql, params,
					this.useCache);

			if (count == null) {
				count = Integer.toString(this.executor.getDataCount(countSql,
						params));
				resultCache.putResults(countSql, params, count, this.useCache);
			}

			pagination.setTotalCount(Integer.parseInt(count));
			limitSql = sOffer.getLimitSQL(sql);

			Object[] param = sOffer.getQueryLimitParam(params, pagination);

			this.result = this.resultCache.getResults(limitSql, param,
					this.useCache);

			if (this.result == null) {
				this.result = this.executor.select(limitSql, param, vo);
				this.resultCache.putResults(limitSql, param, result,
						this.useCache);
			}
		} catch (Exception e) {
			throw new SpeedFrameworkException("AbstractSelectAction error ", e);
		}
	}
}