Java Spring动态生成Mysql存储过程详解

@Entity
@Table(name=\"qt_interface\")
public class QtInterface {
 @Id
 private String id;
 private String name;
 private String content;
 private String info;
 private String status;
//此处省略get、set…
}

@Entity
@Table(name=\"qt_interface_parameter\")
public class QtInterfaceParameter {
 @Id
 private String id;
 @Column(name=\"inter_id\")
 private String interId;
 private String name; //参数名称
 private String explain_info; //参数描述
 private String type;// 输入输出类型
 private String paraType; // 参数类型
 private Integer paraLen;
//此处省略get、set…
}

  接口名称*:
  

    
  
  接口状态*:
  

    
      保存
      已创建
    
 
  


  接口内容*:
  

    
  


  接口说明:
  

    
  


  接口参数:
  

    

      
    
  

function createProduce(inter_id) {
 var postData = {
    id: $(\"#inter_id\").val(),
    item_id: $(\"#item_id\").val(),
    name: $(\"#name\").val(),
    content: $(\"#content\").val(),
    explain_info: $(\"#explain_info\").val(),
    jsonData: JSON.stringify(jsonData)// 参数明细信息,字段就是接口配置参数bean 中的字段信息
};
 
  $.ajax({
    url: Url + \'test/createPro\',
    type: \'get\', //GET
    async: false,  //或false,是否异步
    data: JSON.stringify(postData),
    timeout: 5000,  //超时时间
    dataType: \'json\',  //返回的数据格式：    success:   function (result, textStatus, jqXHR) {
      if (result.result == \"1\") { // 编辑赋值
        layer.alert(\"创建成功\", {icon: 0});
      } else {
        layer.alert(\"创建失败，请检查sql语句，注意结尾不能有分号！具体错误信息：\"+result.msg, {icon: 5});
      }
    },
    error: function (xhr, textStatus) {
      layer.alert(textStatus);
    }
  });
}

public interface TestService {
    ResultInfo createPro(Map map);
}

@Service
public class TestServiceImpl implements TestService {
 
/**
 * 创建存储过程
 *
 * @param map 接口配置和接口参数信息
 * 参数详解： type 输入输出参数，取值为 in,out
 *       paraType 参数类型。取值为：1：int 2:double 3:varchar 4:datetime
 * @return
 */
@Override
@Transactional
public void createPro(Map map) {
  ResultInfo resultInfo = new ResultInfo();
  QtInterface qtInterface=new QtInterface();
  qtInterface =buildInterface(map, qtInterface);// 加载接口配置信息
  List paraList = new ArrayList();
  paraList = buildParam(map.get(\"jsonData\"));// 加载接口配置信息
  StringBuffer bf = new StringBuffer(); // 建立生成过程的语句
  bf.append(\"create procedure \\t\");
  bf.append(qtInterface.getName());
  bf.append(\"\\n\");
  bf.append(\"(\");
  String para_type = \"\";
  int i = 1;
  for (QtInterfaceParameter qt : paraList) {
    switch (qt.getParaType()) { // 参数类型
      case \"1\":
        para_type = \"int\";
        break;
      case \"2\":
        para_type = \"double\";
        break;
      case \"3\":
        para_type = \"varchar(\" + qt.getParaLen() + \")\";
        break;
      case \"4\":
        para_type = \"datetime\";
        break;
      default:
        para_type = \"varchar(255)\";
        break;
    }
    if (i == paraList.size()) {
      bf.append(\"\" + qt.getType() + \" \" + qt.getName() + \" \" + para_type + \") \");
    } else {
      bf.append(\"\" + qt.getType() + \" \" + qt.getName() + \" \" + para_type + \", \");
    }
 
    i++;
  }
  bf.append(\" COMMENT \'\"+ qtMonitorWarnInterface.getInfo() +\"\'\\n\"); // 添加描述信息
  bf.append(\"BEGIN\\n\");
  bf.append(qtInterface.getContent()); // 存储过程内容
  bf.append(\";\\nEND;\");
  // 先执行删除操作
  jdbcTemplate.execute(\"drop procedure if exists \" + qtInterface.getName() + \" ;\");
  jdbcTemplate.execute(bf.toString());
 
}
 
/**
 * 初始化接口配置信息
 *
 */
private QtInterface buildInterface(Map map, QtInterface qtInterface) {
  // 接口配置名称
  if (map.get(\"name\") != null && !\"\".equals(map.get(\"name \"))) {
    qtInterface.setName((String) map.get(\"name \"));
  }
  //此处省略其他项，其他项的取值方法跟上面的一样 …
  return qtInterface;
}
 
/**
 * 初始化接口配置参数明细
 *
 */
  private List buildParam(String postData) {
    List list = new ArrayList();
    if(postData!=null &&!\"\".equals(postData)){
      List> listParam = (List>) JsonMapper.fromJsonString(postData, ArrayList.class);
      for (Map map : listParam) {
        QtInterfaceParameter para = new QtInterfaceParameter();
        // 接口配置参数名称
        if (map.get(\"name\") != null && !\"\".equals(map.get(\"name \"))) {
          para.setName((String) map.get(\"name \"));
        }
        // 此处省略其他项，其他项的取值方法跟上面的一样 …
        list.add(para);
      }
    }
    return list;
  }

@Controller
@RequestMapping(value = \"/test\")
public class TestController {
@Autowired
private TestService testService;
 
@RequestMapping(value = \"/createPro\", method = RequestMethod.GET)
public ResultInfo createPro(@RequestBody Map map
) {
  ResultInfo resultInfo = new ResultInfo();
  try {
    testService.createPro(Id);
  resultInfo.setResult(1);
    resultInfo.setMsg(\"创建过程成功\");
 
  } catch (Exception e) {
    resultInfo.setResult(-1);
    resultInfo.setMsg(e.getMessage());
  }
  return resultInfo;
 }
}

CREATE PROCEDURE `testbase`.`test`(in a_user_id varchar(100))
  COMMENT \'测试接口\'
BEGIN
select * from userInfo where user_id=a_user_id;
END