扩展activiti原表增长新字段

时间  2019-11-19
标签 扩展 activiti 增长 字段 繁體版
原文   原文链接

本人博客开始迁移，博客整个架构本身搭建及编码 http://www.cookqq.com/listBlog.action java

activiti自带了不少表，如图：sql

Activiti工做流引擎的数据库表中的表名称都是以 ACT_.第二部分两个字母表示表的类型。使用模糊匹配的方式说明表的类型匹配activiti的服务API.数据库

·         ACT_RE_*: RE表明仓储(Repository).这种表前缀以“static”表示流程定义信息或者流程资源信息（如流程的图表和规则等）.mybatis

·         ACT_RU_*: RU标识为运行(Runtime)时表。包含流程实例，用户任务和变量任务等在运行时的数据信息。这些表只存储Activiti在流程实例运行执行的数据，在流程结束的时候从表中去除数据。从而保持运行时候数据的表的快速和小数据量.架构

·         ACT_ID_*:ID标识为惟一(Identity)的。包含一些惟一的信息如用户，用户作等信息。app

·         ACT_HI_*:HI表示历史数据(History)表，包括过时的流程实例，过时的变量和过时的任务等。post

·         ACT_GE_*:GE表示公用(General data)的数据库表类型。测试

        ACT_GE_BYTEARRAY 表保存了开发时候的文件，在工做流部署的时候须要上传相关的工做流文件到相关的项目中。其中若是是文件采用方式以下，将图片和或者文件转换为二进制字节流存储。ui

    bytes_字段保存了文件内容，若是是图片，则是保存了二进制。编码

    因为各个项目的业务特殊性，想扩展ACT_GE_BYTEARRAY 的字段，增长2个新字段SYS_,SWITCHBOARD_字段。

怎么把数据保存到表中，这里采用的是修改源码的办法：

步骤1：修改ACT_GE_BYTEARRAY 表对应实体org.activiti.engine.impl.persistence.entity.ResourceEntity，添加SYS_,SWITCHBOARD_字段： 

public class ResourceEntity implements Serializable, PersistentObject {

  private static final long serialVersionUID = 1L;

  protected String id;
  protected String name;
  protected byte[] bytes;
  protected String deploymentId;
  protected boolean generated = false;
  
  //-------------------------------
  private String switchboard;
  private boolean sys;
  ...
}

步骤2：修改相应的sql的配置，添加SYS_,SWITCHBOARD_字段。

文件org.activiti.db.mapping.entity.Resource.xml: 


<?xml version="1.0" encoding="UTF-8" ?> 

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> 
  
<mapper namespace="org.activiti.engine.impl.persistence.entity.ResourceEntity">
  
  <!-- RESOURCE INSERT -->

  <insert id="insertResource" parameterType="org.activiti.engine.impl.persistence.entity.ResourceEntity">
    insert into ${prefix}ACT_GE_BYTEARRAY(ID_, REV_, NAME_, BYTES_, DEPLOYMENT_ID_, GENERATED_,SWITCHBOARD_,SYS_)  values (#{id, jdbcType=VARCHAR}, 1, #{name, jdbcType=VARCHAR}, #{bytes, jdbcType=BLOB}, #{deploymentId, jdbcType=VARCHAR}, #{generated, jdbcType=BOOLEAN}, #{switchboard, jdbcType=VARCHAR},#{sys, jdbcType=BOOLEAN})  </insert>
  
  <!-- RESOURCE UPDATE -->

  <!-- RESOURCE DELETE -->

  <delete id="deleteResourcesByDeploymentId" parameterType="string">
    delete from ${prefix}ACT_GE_BYTEARRAY where DEPLOYMENT_ID_ = #{id}
  </delete>
  
  <!-- RESOURCE RESULTMAP -->

  <resultMap id="resourceResultMap" type="org.activiti.engine.impl.persistence.entity.ResourceEntity">
    <id property="id" column="ID_" jdbcType="VARCHAR" />
    <result property="name" column="NAME_" jdbcType="VARCHAR"/>
    <result property="bytes" column="BYTES_" jdbcType="BLOB"/>
    <result property="generated" column="GENERATED_" jdbcType="BOOLEAN"/>
    <result property="switchboard" column="SWITCHBOARD_" jdbcType="VARCHAR"/>
    <result property="sys" column="SYS_" jdbcType="BOOLEAN"/>
  </resultMap>
  
  <!-- RESOURCE SELECT -->

  <select id="selectResourceNamesByDeploymentId" parameterType="org.activiti.engine.impl.db.ListQueryParameterObject" resultType="string">
    select NAME_ from ${prefix}ACT_GE_BYTEARRAY where DEPLOYMENT_ID_ = #{parameter} order by NAME_ asc
  </select>
  
  <select id="selectResourceByDeploymentIdAndResourceName" parameterType="map" resultMap="resourceResultMap">
    select * from ${prefix}ACT_GE_BYTEARRAY 
    where DEPLOYMENT_ID_ = #{deploymentId}
          AND NAME_ = #{resourceName}
  </select>

  <select id="selectResourcesByDeploymentId" parameterType="org.activiti.engine.impl.db.ListQueryParameterObject" resultMap="resourceResultMap">
    select * from ${prefix}ACT_GE_BYTEARRAY where DEPLOYMENT_ID_ = #{parameter} order by NAME_ asc
  </select>  

  <!-- postgresql specific -->
  <resultMap id="resourceResultMap_postgres" type="org.activiti.engine.impl.persistence.entity.ResourceEntity">
    <id property="id" column="ID_" jdbcType="VARCHAR" />
    <result property="name" column="NAME_" jdbcType="VARCHAR"/>
    <result property="bytes" column="BYTES_" jdbcType="BINARY"/>
    <result property="generated" column="GENERATED_" jdbcType="BOOLEAN"/>
    <result property="switchboard" column="SWITCHBOARD_" jdbcType="VARCHAR"/>
    <result property="sys" column="SYS_" jdbcType="BOOLEAN"/>
  </resultMap>
    
  <!-- postgresql specific -->
  <select id="selectResourceByDeploymentIdAndResourceName_postgres" parameterType="map" resultMap="resourceResultMap_postgres">
    select * from ${prefix}ACT_GE_BYTEARRAY 
    where DEPLOYMENT_ID_ = #{deploymentId}
          AND NAME_ = #{resourceName}
  </select>
  
  <!-- postgresql specific -->
  <select id="selectResourcesByDeploymentId_postgres" parameterType="org.activiti.engine.impl.db.ListQueryParameterObject" resultMap="resourceResultMap_postgres">
    select * from ${prefix}ACT_GE_BYTEARRAY where DEPLOYMENT_ID_ = #{parameter} order by NAME_ asc
  </select>  
  
</mapper>


主要就是修改<insert><resultMap>的内容

步骤3：加载数据文件时候，设置SYS_,SWITCHBOARD_的值 

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
 RepositoryService repositoryService = processEngine.getRepositoryService();
 DeploymentBuilderImpl deploymentBuilder =(DeploymentBuilderImpl) repositoryService.createDeployment()
 .addClasspathResource("activiti/leave.bpmn");
 DeploymentEntity deploymentEntity = deploymentBuilder.getDeployment();
 ResourceEntity resourceEntity = deploymentEntity.getResource("activiti/leave.bpmn");
 resourceEntity.setSwitchboard(getSwitchboard());
 resourceEntity.setSys(true);
 deploymentEntity.addResource(resourceEntity);
 deploymentBuilder.deploy();

注：这里主要是经过ResourceEntity resourceEntity = deploymentEntity.getResource("activiti/leave.bpmn");得到数据库得到对应的实体，而后设置咱们新添加的字段的值。

测试结果：

看到上面的数据，SYS_,SWITCHBOARD_字段都有值了，activiti/leave.bpmn是正确的，可是activiti/leave.leave.png对应的值是不正确的。由于这2个添加的值因该是同样的。

下面继续修改：

步骤4：org.activiti.engine.impl.bpmn.deployer.BpmnDeployer,加载activiti/leave.bpmn中的图片 

    public void deploy(DeploymentEntity deployment) {
...
  createResource(resourceName,diagramResourceName, diagramBytes, deployment);
...
}

protected void createResource(String resourceName ,String name, byte[] bytes, DeploymentEntity deploymentEntity) {
    ResourceEntity resource = new ResourceEntity();
    resource.setName(name);
    resource.setBytes(bytes);
    resource.setDeploymentId(deploymentEntity.getId());
    
    ResourceEntity resourceEntity = deploymentEntity.getResource(resourceName);
    if(resourceEntity!=null){
    	resource.setSwitchboard(resourceEntity.getSwitchboard());
    	resource.setSys(resourceEntity.isSys());
    }
    // Mark the resource as 'generated'
    resource.setGenerated(true);
    
    Context
      .getCommandContext()
      .getDbSqlSession()
      .insert(resource);
  }

有人要问，问什么要这么修改，没办法，我是一步一步debug，一步一步看源码。

步骤5：文件org.activiti.db.mapping.entity.VariableInstance.xml，添加SYS_,SWITCHBOARD_字段： 

  <!-- BYTE ARRAY INSERT -->

  <insert id="insertByteArray" parameterType="org.activiti.engine.impl.persistence.entity.ByteArrayEntity">
    insert into ${prefix}ACT_GE_BYTEARRAY(ID_, REV_, NAME_, BYTES_, DEPLOYMENT_ID_,SWITCHBOARD_,SYS_)
    values (
      #{id, jdbcType=VARCHAR},
      1, 
      #{name, jdbcType=VARCHAR}, 
      #{bytes, jdbcType=BLOB}, 
      #{deploymentId, jdbcType=VARCHAR},
      #{switchboard, jdbcType=VARCHAR},
      #{sys, jdbcType=BOOLEAN}
    )  
  </insert>

...

而后测试结果：

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程