10.4.動(dòng)作

概述

操作

擴(kuò)展

package com.bstek.bdf2.rapido.action;
import java.util.Collection;
import java.util.Map;
import com.bstek.bdf2.rapido.domain.Parameter;
/**
 * 用于定義前后臺(tái)交互時(shí)要執(zhí)行的具體動(dòng)作,<br>
 * 動(dòng)作可以累加，也就是說可以一次性執(zhí)行多個(gè)當(dāng)前接口的實(shí)現(xiàn)類,<br>
 *
用戶可以通過實(shí)現(xiàn)該接口，在execute方法中添加具體的需要執(zhí)行的具體邏輯代碼，然后將實(shí)現(xiàn)類配置到spring當(dāng)中即
可
 * @author jacky.gao@bstek.com
 * @since 2012-7-5
 */
public interface IAction {
 /**
 * 返回當(dāng)前動(dòng)作的名稱
 * @return 返回動(dòng)作名稱
 */
 String getName();
 /**
 * 具體要執(zhí)行的動(dòng)作代碼，這里的參數(shù)只有一個(gè)Map，<br>
 * 在這個(gè)Map當(dāng)中包含了當(dāng)前業(yè)務(wù)數(shù)據(jù)的ID(key為businessId)以及所有在動(dòng)作定義時(shí)定義的參數(shù)
 * @param map 外部傳入的參數(shù)
 */
 Map<String,Object> execute(Map<String,Object> map);
 /**
 * 執(zhí)行這個(gè)實(shí)現(xiàn)時(shí)需要哪些參數(shù)
 * @return 返回一個(gè)Parameter對(duì)象實(shí)例集合
 */
 Collection<Parameter> requiredParameters();
}

package com.bstek.bdf.bsh;
import java.util.Map;
/**
 * 注冊(cè)BeanShell腳本中要使用的變量信息,實(shí)現(xiàn)類需要配置到Spring環(huán)境當(dāng)中，<br>
 * 因此在注冊(cè)時(shí)可使用Spring環(huán)境中各種類型的Bean對(duì)象
 * @author jacky.gao@bstek.com
 * @since 2012-8-28
 */
public interface VariableRegister {
 /**
 * 返回注冊(cè)到BeanShell上下文中的變量集合
 * @return 返回一個(gè)變量集合的Map，Map中key為變量名，Value就是一個(gè)VariableInfo對(duì)象，用于描述變量信息
 */
 Map<String,VariableInfo> register();
}

擴(kuò)展示例

package com.bstek.rapido.demo;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Types;
import java.util.HashMap;
import java.util.Map;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.CallableStatementCreator;
import com.bstek.bdf.rapido.RapidJdbcDaoSupport;
/**
 * 存儲(chǔ)過程執(zhí)行對(duì)象
 * @author Lucas
 * 
 */
public class ProcedureTemplate extends RapidJdbcDaoSupport {
 /**
 * @param procedureSql
 * 執(zhí)行存儲(chǔ)過程語句
 * @param param
 * 向存儲(chǔ)過程傳遞的參數(shù)
 * @return
 */
 @SuppressWarnings({ "unchecked", "rawtypes" })
 public Map<String, Object> call(final String procedureSql,
 final Map<String, Object> param) {
 final Map<String, Object> outParam = new HashMap<String, Object>();
 this.getJdbcTemplate().execute(new CallableStatementCreator() {
 @Override
 public CallableStatement createCallableStatement(Connection con)
 throws SQLException {
 CallableStatement cs = con.prepareCall(procedureSql);
 int i = 1;
 for (String key : param.keySet()) {
 Object obj = param.get(key);
 if (obj instanceof String) {
 int j = i++;
 cs.setString(j, (String) obj);
 cs.registerOutParameter(j, Types.VARCHAR);
 } else if (obj instanceof Integer) {
 int j = i++;
 cs.registerOutParameter(j, Types.INTEGER);
 cs.setInt(j, (Integer) obj);
 } else if (obj instanceof Long) {
 int j = i++;
 cs.registerOutParameter(j, Types.INTEGER);
 cs.setLong(j, (Long) obj);
 }
 }
 return cs;
 }
 }, new CallableStatementCallback() {
 @Override
 public Object doInCallableStatement(CallableStatement cs)
 throws SQLException, DataAccessException {
 cs.execute();
 int i = 1;
 for (String key : param.keySet()) {
 Object obj = param.get(key);
 if (obj instanceof String) {
 outParam.put(key, cs.getString(i++));
 } else if (obj instanceof Integer) {
 outParam.put(key, cs.getInt(i++));
 } else if (obj instanceof Long) {
 outParam.put(key, cs.getLong(i++));
 }
 }
 return null;
 }
 });
 return outParam;
 }
 /**
 * 執(zhí)行無參存儲(chǔ)過程
 * 
 * @param procedureSql
 * 執(zhí)行存儲(chǔ)過程語句
 */
 public void execute(final String procedureSql) {
 this.getJdbcTemplate().execute(procedureSql);
 }
}

package com.bstek.rapido.demo;
import java.util.HashMap;
import java.util.Map;
import com.bstek.bdf.d7.bsh.VariableExecutor;
import com.bstek.bdf.d7.bsh.VariableInfo;
import com.bstek.bdf.d7.bsh.VariableRegister;
/**
 * 注冊(cè)ProcedureTemplate對(duì)象實(shí)例
 * @author Lucas
 * 
 */
public class ProcedureTemplateRegister implements VariableRegister {
 private ProcedureTemplate procedureTemplate;
 public ProcedureTemplate getProcedureTemplate() {
 return procedureTemplate;
 }
 public void setProcedureTemplate(ProcedureTemplate procedureTemplate) {
 this.procedureTemplate = procedureTemplate;
 }
 @Override
 public Map<String, VariableInfo> register() {
 Map<String, VariableInfo> map = new HashMap<String, VariableInfo>();
 VariableInfo procedureTemplateInfo = new VariableInfo();
 procedureTemplateInfo.setName("procedureTemplate");
 procedureTemplateInfo.setDesc("自定義的執(zhí)行存儲(chǔ)過程的ProcedureTemplate對(duì)象實(shí)例");
 procedureTemplateInfo.setVariableExecutor(new VariableExecutor() {
 public Object execute() {
 return procedureTemplate;
 }
 });
 map.put("procedureTemplate", procedureTemplateInfo);
 return map;
 }
}

<bean id="procedureTemplate" class="com.bstek.rapido.demo.ProcedureTemplate" />
<bean class="com.bstek.rapido.demo.ProcedureTemplateRegister">
 <property name="procedureTemplate" ref="procedureTemplate" />
</bean>

Map resultMap=new HashMap();
Map paramMap=new HashMap();
 paramMap.put("id","123");
 paramMap.put("name","beanShell");
 resultMap = procedureTemplate.call("exec test_insert ?,?",paramMap);
 resultMap.put("id_test",resultMap.get("id"));
return resultMap;