官网文档：https://www.activiti.org/userguide/#queryAPI

     activiti的官方文档讲解详细很详细，也很范。按着文档写完了一个简单的demo发现，现实中的大多数问题，还是没法很好的解决。

例如：首先我需要知道的是，activiti的有那些表，及各个表的作用。这个网上有人罗列过，但总是觉得不通透。

所以，我先简单看了一下activiti数据处理的源码。

  • RepositoryServiceImpl

进行对那个操作的封装，传递Command接口的对应子类，里面封装了具体的操作

  1.   public Deployment deploy(DeploymentBuilderImpl deploymentBuilder) {
  2.     return commandExecutor.execute(new DeployCmd<Deployment>(deploymentBuilder));
  3.   }
  • CommandInvoker

commandExecutor.execute() 这个方法的执行本质，是里面的CommandInterceptor执行链式的execute,而实质执行的是传进来的CMD接口类的execute方法。具体如下所示。

  1.  public <T> T execute(final CommandConfig config, final Command<T> command) {
  2.     final CommandContext commandContext = Context.getCommandContext();
  4.     //省略一些代码
  6.     commandContext.getAgenda().planOperation(new Runnable() {
  7.       @Override
  8.       public void run() {
  9.         commandContext.setResult(command.execute(commandContext));//这里是关键
  10.       }
  11.     });
  13.      // 省略一些代码。。。。。。。。。。。。
  15.     return (T) commandContext.getResult();
  16.   }
  • DeployCmd(从这里调用DataManager的实现类进行相关数据库操作)
  1. public Deployment execute(CommandContext commandContext) {
  3.     // Backwards compatibility with Activiti v5
  4.     if (commandContext.getProcessEngineConfiguration().isActiviti5CompatibilityEnabled()
  5.         && deploymentBuilder.getDeploymentProperties() != null 
  6.         && deploymentBuilder.getDeploymentProperties().containsKey(DeploymentProperties.DEPLOY_AS_ACTIVITI5_PROCESS_DEFINITION)
  7.         && deploymentBuilder.getDeploymentProperties().get(DeploymentProperties.DEPLOY_AS_ACTIVITI5_PROCESS_DEFINITION).equals(Boolean.TRUE)) {
  8.       
  9.         return deployAsActiviti5ProcessDefinition(commandContext);
  10.     }
  12.     return executeDeploy(commandContext);
  13.   }
  • DeploymentEntityManagerImpl

实际数据库操作的是DataManager的实现类，进行数据库操作。

这个我们能看出来是有两个

  2.  @Override
  3.   public void insert(DeploymentEntity deployment) {
  4.     insert(deployment, false);
  6.     for (ResourceEntity resource : deployment.getResources().values()) {
  7.       resource.setDeploymentId(deployment.getId());
  8.       getResourceEntityManager().insert(resource);
  9.     }
  10.   }
  • 对应的xml操作

在mapping目录下可以查找到对应的操作。前面的${prefix}标识数据库，activiti已经帮我们判断好了，不需要我们再传入。

  1.   <insert id="insertDeployment" parameterType="org.activiti.engine.impl.persistence.entity.DeploymentEntityImpl">
  2.     insert into ${prefix}ACT_RE_DEPLOYMENT(ID_, NAME_, CATEGORY_, KEY_, TENANT_ID_, DEPLOY_TIME_, ENGINE_VERSION_)
  3.     values(#{id, jdbcType=VARCHAR}, #{name, jdbcType=VARCHAR}, #{category, jdbcType=VARCHAR}, #{key, jdbcType=VARCHAR}, #{tenantId, jdbcType=VARCHAR}, #{deploymentTime, jdbcType=TIMESTAMP}, #{engineVersion, jdbcType=VARCHAR})
  4.   </insert>
  6. <insert id="insertResource" parameterType="org.activiti.engine.impl.persistence.entity.ResourceEntityImpl">
  7.     insert into ${prefix}ACT_GE_BYTEARRAY(ID_, REV_, NAME_, BYTES_, DEPLOYMENT_ID_, GENERATED_)
  8.     values (#{id, jdbcType=VARCHAR}, 1, #{name, jdbcType=VARCHAR}, #{bytes, jdbcType=${blobType}}, #{deploymentId, jdbcType=VARCHAR}, #{generated, jdbcType=BOOLEAN})  
  9.   </insert>
  • DataManager

数据查询操作本质都是通过DataManger的实现类MybatisDeploymentDataManager进行操作；

  1.   @Override
  2.   public List<Deployment> executeList(CommandContext commandContext, Page page) {
  3.     checkQueryOk();
  4.     return commandContext.getDeploymentEntityManager().findDeploymentsByQueryCriteria(this, page);
  5.   }
  7.   @Override
  8.   @SuppressWarnings("unchecked")
  9.   public List<Deployment> findDeploymentsByQueryCriteria(DeploymentQueryImpl deploymentQuery, Page page) {
  10.     final String query = "selectDeploymentsByQueryCriteria";
  11.     return getDbSqlSession().selectList(query, deploymentQuery, page);
  12.   }

  • 查找xml中对应的sql
  1.   <select id="selectDeploymentsByQueryCriteria" parameterType="org.activiti.engine.impl.DeploymentQueryImpl" resultMap="deploymentResultMap">
  2.   	${limitBefore}
  3.     select distinct RES.* ${limitBetween}
  4.     <include refid="selectDeploymentsByQueryCriteriaSql"/>
  5.     ${orderBy}
  6.     ${limitAfter}
  7.   </select>

需要了解任务类型，以及网关相关知识。

  • TaskService
  1. taskService.complete(task.getId(), taskVariables);
  • AbstractCompleteTaskCmd
  1. protected void executeTaskComplete(CommandContext commandContext, TaskEntity taskEntity, Map<String, Object> variables, boolean localScope) {
  2.     // Task complete logic
  4.     if (taskEntity.getDelegationState() != null && taskEntity.getDelegationState().equals(DelegationState.PENDING)) {
  5.       throw new ActivitiException("A delegated task cannot be completed, but should be resolved instead.");
  6.     }
  7.     //执行节点监听事件  
  8.     commandContext.getProcessEngineConfiguration().getListenerNotificationHelper().executeTaskListeners(taskEntity, TaskListener.EVENTNAME_COMPLETE);
  9.     if (Authentication.getAuthenticatedUserId() != null && taskEntity.getProcessInstanceId() != null) {
  10.        //查找任务select * from ${prefix}ACT_RU_EXECUTION
  11.        // where ROOT_PROC_INST_ID_ = (select ROOT_PROC_INST_ID_ from ${prefix}ACT_RU_EXECUTION where ID_ = #{parameter})
  12.       ExecutionEntity processInstanceEntity = commandContext.getExecutionEntityManager().findById(taskEntity.getProcessInstanceId());
  13.       //任务和identity绑定
  14.       commandContext.getIdentityLinkEntityManager().involveUser(processInstanceEntity, Authentication.getAuthenticatedUserId(),IdentityLinkType.PARTICIPANT);
  15.     }
  17.     ActivitiEventDispatcher eventDispatcher = Context.getProcessEngineConfiguration().getEventDispatcher();
  18.     if (eventDispatcher.isEnabled()) {
  19.       if (variables != null) {
  20.         eventDispatcher.dispatchEvent(ActivitiEventBuilder.createEntityWithVariablesEvent(ActivitiEventType.TASK_COMPLETED, taskEntity, variables, localScope));
  21.       } else {
  22.         eventDispatcher.dispatchEvent(ActivitiEventBuilder.createEntityEvent(ActivitiEventType.TASK_COMPLETED, taskEntity));
  23.       }
  24.     }
  25.       //删除已有的任务相关数据
  26.     commandContext.getTaskEntityManager().deleteTask(taskEntity, null, false, false);
  28.     // Continue process (if not a standalone task) 激活下个步骤工作
  29.     if (taskEntity.getExecutionId() != null) {
  30.       ExecutionEntity executionEntity = commandContext.getExecutionEntityManager().findById(taskEntity.getExecutionId());
  31.       Context.getAgenda().planTriggerExecutionOperation(executionEntity);
  32.     }
  33.   }

ManagementService

  1.   managementService.getTableName()

TableDataManagerImpl

  1. static {
  2.     // runtime
  3.     entityToTableNameMap.put(TaskEntity.class, "ACT_RU_TASK");
  4.     entityToTableNameMap.put(ExecutionEntity.class, "ACT_RU_EXECUTION");
  5.     entityToTableNameMap.put(IdentityLinkEntity.class, "ACT_RU_IDENTITYLINK");
  6.     entityToTableNameMap.put(VariableInstanceEntity.class, "ACT_RU_VARIABLE");
  8.     entityToTableNameMap.put(JobEntity.class, "ACT_RU_JOB");
  9.     entityToTableNameMap.put(TimerJobEntity.class, "ACT_RU_TIMER_JOB");
  10.     entityToTableNameMap.put(SuspendedJobEntity.class, "ACT_RU_SUSPENDED_JOB");
  11.     entityToTableNameMap.put(DeadLetterJobEntity.class, "ACT_RU_DEADLETTER_JOB");
  12.     
  14.     entityToTableNameMap.put(EventSubscriptionEntity.class, "ACT_RU_EVENT_SUBSCR");
  15.     entityToTableNameMap.put(CompensateEventSubscriptionEntity.class, "ACT_RU_EVENT_SUBSCR");
  16.     entityToTableNameMap.put(MessageEventSubscriptionEntity.class, "ACT_RU_EVENT_SUBSCR");
  17.     entityToTableNameMap.put(SignalEventSubscriptionEntity.class, "ACT_RU_EVENT_SUBSCR");
  19.     // repository
  20.     entityToTableNameMap.put(DeploymentEntity.class, "ACT_RE_DEPLOYMENT");
  21.     entityToTableNameMap.put(ProcessDefinitionEntity.class, "ACT_RE_PROCDEF");
  22.     entityToTableNameMap.put(ModelEntity.class, "ACT_RE_MODEL");
  23.     entityToTableNameMap.put(ProcessDefinitionInfoEntity.class, "ACT_PROCDEF_INFO");
  25.     // history
  26.     entityToTableNameMap.put(CommentEntity.class, "ACT_HI_COMMENT");
  28.     entityToTableNameMap.put(HistoricActivityInstanceEntity.class, "ACT_HI_ACTINST");
  29.     entityToTableNameMap.put(AttachmentEntity.class, "ACT_HI_ATTACHMENT");
  30.     entityToTableNameMap.put(HistoricProcessInstanceEntity.class, "ACT_HI_PROCINST");
  31.     entityToTableNameMap.put(HistoricVariableInstanceEntity.class, "ACT_HI_VARINST");
  32.     entityToTableNameMap.put(HistoricTaskInstanceEntity.class, "ACT_HI_TASKINST");
  33.     entityToTableNameMap.put(HistoricIdentityLinkEntity.class, "ACT_HI_IDENTITYLINK");
  35.     // a couple of stuff goes to the same table
  36.     entityToTableNameMap.put(HistoricDetailAssignmentEntity.class, "ACT_HI_DETAIL");
  37.     entityToTableNameMap.put(HistoricDetailTransitionInstanceEntity.class, "ACT_HI_DETAIL");
  38.     entityToTableNameMap.put(HistoricFormPropertyEntity.class, "ACT_HI_DETAIL");
  39.     entityToTableNameMap.put(HistoricDetailVariableInstanceUpdateEntity.class, "ACT_HI_DETAIL");
  40.     entityToTableNameMap.put(HistoricDetailEntity.class, "ACT_HI_DETAIL");
  42.     // Identity module
  43.     entityToTableNameMap.put(GroupEntity.class, "ACT_ID_GROUP");
  44.     entityToTableNameMap.put(MembershipEntity.class, "ACT_ID_MEMBERSHIP");
  45.     entityToTableNameMap.put(UserEntity.class, "ACT_ID_USER");
  46.     entityToTableNameMap.put(IdentityInfoEntity.class, "ACT_ID_INFO");
  48.     // general
  49.     entityToTableNameMap.put(PropertyEntity.class, "ACT_GE_PROPERTY");
  50.     entityToTableNameMap.put(ByteArrayEntity.class, "ACT_GE_BYTEARRAY");
  51.     entityToTableNameMap.put(ResourceEntity.class, "ACT_GE_BYTEARRAY");
  52.     
  53.     entityToTableNameMap.put(EventLogEntryEntity.class, "ACT_EVT_LOG");
  55.     // and now the map for the API types (does not cover all cases)
  56.     apiTypeToTableNameMap.put(Task.class, "ACT_RU_TASK");
  57.     apiTypeToTableNameMap.put(Execution.class, "ACT_RU_EXECUTION");
  58.     apiTypeToTableNameMap.put(ProcessInstance.class, "ACT_RU_EXECUTION");
  59.     apiTypeToTableNameMap.put(ProcessDefinition.class, "ACT_RE_PROCDEF");
  60.     apiTypeToTableNameMap.put(Deployment.class, "ACT_RE_DEPLOYMENT");
  61.     apiTypeToTableNameMap.put(Job.class, "ACT_RU_JOB");
  62.     apiTypeToTableNameMap.put(Model.class, "ACT_RE_MODEL");
  64.     // history
  65.     apiTypeToTableNameMap.put(HistoricProcessInstance.class, "ACT_HI_PROCINST");
  66.     apiTypeToTableNameMap.put(HistoricActivityInstance.class, "ACT_HI_ACTINST");
  67.     apiTypeToTableNameMap.put(HistoricDetail.class, "ACT_HI_DETAIL");
  68.     apiTypeToTableNameMap.put(HistoricVariableUpdate.class, "ACT_HI_DETAIL");
  69.     apiTypeToTableNameMap.put(HistoricFormProperty.class, "ACT_HI_DETAIL");
  70.     apiTypeToTableNameMap.put(HistoricTaskInstance.class, "ACT_HI_TASKINST");
  71.     apiTypeToTableNameMap.put(HistoricVariableInstance.class, "ACT_HI_VARINST");
  73.     // identity
  74.     apiTypeToTableNameMap.put(Group.class, "ACT_ID_GROUP");
  75.     apiTypeToTableNameMap.put(User.class, "ACT_ID_USER");
  77.     // TODO: Identity skipped for the moment as no SQL injection is provided
  78.     // here
  79.   }

以Task接口为例

可以看到接口的实现类对应xml的命名空间

官方文档中的说明

  1. Activiti的数据库名称都以ACT_开头。第二部分是表用例的两个字符的标识。该用例也将与服务API大致匹配。
  3. ACT_RE_ *：RE代表repository。具有此前缀的表包含静态信息，例如流程定义和流程资源（图像，规则等）。
  5. ACT_RU_ *：RU代表runtime。这些是运行时表，其中包含流程实例，用户任务，变量，作业等的运行时数据。Activiti仅在流程实例执行期间存储运行时数据，并在流程实例结束时删除记录。这样可以使运行时表较小而又快速。
  7. ACT_ID_ *：ID代表identity。这些表包含身份信息，例如用户，组等。
  9. ACT_HI_ *：HI代表history。这些表包含历史数据，例如过去的流程实例，变量，任务等。
  11. ACT_GE_ *：general数据，用于各种用例中

初次使用中使用到的表格（后续继续补充）

类型 表格名称 存储的数据 备注
生成 ACT_GE_BYTEARRAY 存储部署的bpmn相关文件
re ACT_RE_DEPLOYMENT 发布的流程数据
re act_re_procdef 存储流程分解数据
runtime ACT_RU_TASK 正在运行的任务
runtime ACT_RU_VARIABLE 用于存储流程流转中的字段 PROC_INST_ID_ 对应ACT_RU_TASK中的EXECUTION_ID_
TASK_ID_ 对应 ACT_RU_TASK中的ID_
runtime ACT_RU_EXECUTION 运行时流程执行实例
history act_hi_taskinst 流程历史步骤数据
history act_hi_variable 历史步骤流程中转字段
history act_hi_procinst 已经发起的流程实例 已经结束的流程任务END_ACT_ID_不为空

版权声明：本文为perferect原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/perferect/p/13234784.html