abstractexecutebatchaction.java

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

package org.speedframework.action;

import org.speedframework.entity.ParamEntity;
import org.speedframework.exception.SpeedFrameworkException;
import org.speedframework.message.IMessage;
import org.speedframework.utilities.StringUtils;

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

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

		ParamEntity entity = message.getParamEntity();
		Object[][] params = entity.getParams();
		String sql = entity.getSQL();

		try {
			String table = StringUtils.getExecuteTable(sql);

			this.executor.executeBatch(sql, params);
			this.resultCache.removeCache(table, useCache);
		} catch (SpeedFrameworkException e) {
			throw e;
		}
	}
}