Acitiviti数据库表设计（学习笔记）

ACT_ID_*：与权限，用户与用户组，以及用户与用户组关系相关的表

ACT_RU_*：代表了流程引擎运行时的库表，RU表示Runtime

ACT_HI_*：HI表示History当流程完成了节点以后，就将其迁移到历史数据库表

---

ACT_GE_*（通用数据库 ）涉及到两个表：

act_ge_property:属性表，保存一些流程引擎的kv键值属性

对应数据库实体：PropertyEntityImpl

---

act_ge_bytearray:资源表，存储的是一些流程定义的资源信息（包括流程定义文件xml、流程定义的流程图，都被序列化成字节流存储在资源表里）

对应数据库实体：ByteArrayEntityImpl

定义有两种方式，可以用他的自动部署，也可以手动。

public class DbConfigTest {
    private static final Logger LOGGER =  LoggerFactory.getLogger(configDBTest.class);

    @Rule
    public ActivitiRule activitiRule = new ActivitiRule("activiti_druid.cfg.xml");//传入自定义的mdc配置文件

    @Test
    public void testDbConfig(){
            //自动
            activitiRule.getRepositoryService()
                    .createDeployment()
                    .name("指定部署名称")
                    .addClasspathResource("my-process.bpmn20.xml");
    }

    //手工添加act_ge_bytearray资源库信息
    @Test
    public void testbytearrayinsert(){
        //获取managementService，通过managementService去执行命令
        ManagementService managementService = activitiRule.getManagementService();
        Object o = managementService.executeCommand(new Command<Object>() {

            @Override
            public Object execute(CommandContext commandContext) {
                ByteArrayEntity entity = new ByteArrayEntityImpl();
                entity.setName("test");
                entity.setBytes("test message".getBytes());
                //根据上下文获取对象
                commandContext.getByteArrayEntityManager().insert(entity);

                return null;
            }
        });

    }
}

看数据库表效果：

---

---

ACT_RE_*(流程定义存储表)设计到四张表：

存储的都是些流程信息的名字等信息。

---

ACT_ID_*(身份数据表)涉及到四个表：

ACT_ID_USER对应实体UserEntityImpl

ID_：对应登录的用户名

REV_：版本信息

FIRST_:firstname

LAST_：lastname

EMAIL_：email

PWD_：password

PICTURE_ID_：对应用户头像信息，即头像的url

ACT_ID_INFO对应实体IdentityInfoEntityImpl

TYPE_:类型，针对user的

KEY_:属性名

VALUE_;属性值

如果要用key与value扩展，例如：key可以放age，value可以放18；

PASSWORD_:密码（并没有使用到）

PARENT_ID_:上级关联（这个字段表明了可以用ACT_ID_INFO做一些树状的关联）

ACT_ID_GROUP对应实体GroupEntityImpl

ID_:跟用户组关联的唯一键

REV_:版本信息

NAME_:对group的一个描述

TYPE_:是自定义的类型，可以扩展一下业务信息

ACT_ID_MEMBERSHIP对应实体MembershipEntityImpl

USER_ID_:

GROUP_ID_:

这里主要是体现了一个简单的多对多关系。

记录一下对这几个身份数据表插入数据的操作：

public class DbIdentityTest {
    private static final Logger LOGGER =  LoggerFactory.getLogger(configDBTest.class);

    @Rule
    public ActivitiRule activitiRule = new ActivitiRule("activiti_druid.cfg.xml");//传入自定义的mdc配置文件

    @Test
    public void testIdentity(){
        //对用户和用户组的操作要先获取对应的service
        IdentityService identityService = activitiRule.getIdentityService();
        //identityService或者identity数据可以去可选的设置，在这里面默认是设置关闭掉的，
        // 所以需要去流程定义文件里打开
        //          <!-- 打开用户相关的信息设置 -->
        //        <property name="dbIdentityUsed" value="true"/>
        //这样数据库就会自动生成有关用户信息的表

        //1.创建一个用户User，例：创建一个用户id为lll
        User lll = identityService.newUser("lll");
        //接着可以选择性的给用户设置一些属性信息
        lll.setFirstName("firstName");
        lll.setLastName("lastName");
        lll.setEmail("[e-mail]");
        lll.setPassword("pssword");
        //设置完这些用户信息，就可以对这个用户进行保存了
        identityService.saveUser(lll);

        //2.创建一个用户组Group,例：创建一个用户组id为BossGroup
        Group bossGroup1 = identityService.newGroup("BossGroup1");
        //同样可以选择性的给用户组设置一些属性信息
        bossGroup1.setName("Boss");
        //保存这个用户组
        identityService.saveGroup(bossGroup1);

        //3.接着就可以创建用户与组的关系了
        identityService.createMembership(lll.getId(),bossGroup1.getId());//createMembership这里面有两个参数，一个指定userId,一个是指定groupId

        //为了体现用户与用户组多对多的关系，可以再创建一个用户
        User lll2 = identityService.newUser("lll2");
        identityService.saveUser(lll2);
        //同样再把这个新增的用户添加进组
        identityService.createMembership(lll2.getId(),bossGroup1.getId());
        //至此操作的使用，一共涉及到三张表：act_id_user、act_id_group、act_id_membership

        //用户扩展信息表act_procdef_info的使用：(这里针对之前创建的lxk用户来使用扩展信息表，增加年龄与地址的信息)
        identityService.setUserInfo(lll.getId(),"age","18");//分别对应了表中USER_ID_:并联用户ID、KEY_:属性名、VALUE_;属性值  这三个字段
        identityService.setUserInfo(lll.getId(),"address","成都");
    }
}

执行完数据库效果如下：

act_id_user :(这里id为主键)

act_id_group :(这里id为主键)

act_id_membership :

act_id_info :(这里id自动给的)

---

ACT_RU_*(运行时流程数据表)涉及到九个表：

Task：当userTask执行到此处时，会在Task表里插入数据

Variable：当启动流程、或者在流程过程中设置的一些变量信息，会存储在这张表

Identitylink：跟参与者信息相关的表，当我们设置一个用户的owner或用户的代办人、候选人的时候，都会在该表写入信息

event_subscr：流程中许多地方需要等待一个message或者singno，一个消息或者一个事件的情况下，这种监听的记录，都会存储在这张表里

job在6.0版本以后重构了一下，以前只有一个jbo表，现在有四个。

Job:一般作业表

timer_job：定时器作业表

suspended_job：当挂起的时候，暂停的作业会存放在这张表：

deadletter_job：当一个作业重复了三四次都没有成功执行下去，就会将它挪入这张表，所以说这张表的里数据是需要管理人员去关注的，需要查明原因，为什么job没有执行成功

ACT_ID_EXECUTUION对应实体ExecutionEntityImpl：

PROC_INST_ID_：流程实例ID，对应流程实例的ID的外键

BUSINESS_KEY_：业务标志

PARENT_ID_:标识这个流程实例是由哪一个流程实例启动的（如果是直接的流程实例的启动，那么这列为null）

PROC_DEF_ID_：流程定义ID  有时候会和流程执行ID是相同的

SUPERT_EXEC_：父流程实例对应的执行

ACT_ID_：流程定义节点ID  指流程定义里面执行到这个节点对应到流程定义这个节点的ID

ACT_RU_EXECUTUION对应实体ExecutionEntityImpl：

IS_ACTIVE_：是否活动的执行  0非活动，1活动

IS_CONCURRENT_：是否并行分支   0非  1是

IS_SCOPE_：是否全局流程执行 0非 1是

IS_ECENT_SCOPE_：是否激活状态

SUSPENSION_STATE：挂起状态 1正常 、2挂起

LOCK_TIME_：锁定时间

ACT_RU_TASK用户任务表对应的实体类TaskEntityImpl

EXECUTION_ID_：执行流ID

PROC_INST_ID_：流程实例ID

PROC_DEF_ID_：流程定义ID

PARENT_TASK_ID_：父任务

TASK_DEF_KEY_：任务定义ID

NAME_：任务定义名称

OWNER_：拥有人

ASSIGNEE_：代理人

DELEGATION_：委托状态  PENDING委托中，RESOLVED已处理

PRIORITY_：优先级

DUE_DATE_：过期时间

FORM_KEY_：表单标志

变量信息表

ACT_RU_VARIABLE对应实体类VariableInstanceEntityImpl:

TYPE_：变量类型（integer/string/double/json...）

NAME_：变量名 对应扩展的属性的名称   如果变量非常大的话，就会将其存进二进制的资源表并在BYTEARRAY_ID_存入这张表的ID

BYTEARRAY_ID_：资源表ID

DOUBLE_：浮点值  如果变量是浮点型就存在这

LONG_：长整型数值  如果变量是纯数字的，不管是integer还是long它都会存在这个字段下

TEXT_：文本值   如果是一个普通的文本，且它的长度没有超过一点的限制，它就会作为文本字符串存在这个字段下面

参与者信息表：当一个用户与一个流程建立关系的时候，就会在这张表里插入一条记录

比如在使用RuntimeService设置一个流程实例的owner或者signal时，都会在这张表里插入一条记录。

ACT_RU_IDENTITYLINK对应实体类IdentityLinkEntityImpl

ID_：主键

GROUP_ID_：用户组ID

TYPE_：类型assignee,candidate,owner,starter

USER_ID_：用户ID

TASK_ID_：任务ID

PROC_INST_ID_：流程实例

事件订阅信息表

ACT_RU_EVENT_SUBSCR对应实体类EventSubscriptionEntityImpl

EVENT_TYPE_：事件类型message，signal  消息、信号

EVENT_NAME_：事件名称   （事件一般都跟流程执行有一定关系）

EXECUTION_ID_：流程执行ID

PROC_INST_ID_：流程实例ID

ACTIVITY_ID_：流程定义节点ID（标识事件触发对应的流程定义节点）

CONFIGURATION_：配置（可以对流程事件做一些对应的特殊配置信息存储起来）

作业信息表：

ACT_RU_JOB对应实体类 JobEntityImpl

TYPE_：类型

LOCK_EXP_TIME_：锁定过期时间

LOCK_OWNER_：锁定节点

EXCLUSIVE_：是否唯一

RETRIES_：重试次数3

REPEAT_：重复表达式R5/PT10S

EXCEPTION_STACK_ID_：异常堆栈（资源表ID）

EXCEPTION_MSG_：异常信息

DUEDATE_：过期时间

HANDLER_TYPE_：处理器类型

HANDLER_CFG_：处理器配置

EXECUTION_ID_：流程执行表ID

记录一下对这几个表的操作：

启动一个流程会操作的表

public class DbRuntimeTest {
    private static final Logger LOGGER =  LoggerFactory.getLogger(configDBTest.class);

    @Rule
    public ActivitiRule activitiRule = new ActivitiRule("activiti_druid.cfg.xml");//传入自定义的mdc配置文件

    @Test
    public void testRuntime(){
            activitiRule.getRepositoryService()
                    .createDeployment()
                    .name("指定部署名称2")
                    .addClasspathResource("second_approve.bpmn20.xml")
                    .deploy();

        Map<String, Object> variables = Maps.newHashMap();
        variables.put("key1","value1");

        //启动流程,且在启动时，传入一些变量 值variables
        activitiRule.getRuntimeService()
                    .startProcessInstanceByKey("erjishenpiliucheng",variables);
    }
}

会操作到的表有：

1.

以及表

2.

执行到这里遇到了userTask，需要指定它去提交一个表单，所以到这里就暂停了，并且userTask里面会有一条记录。

因为前面在启动时插入了一些变量，所以变量表里面也存在一条记录

3.

上面启动一个流程的java代码里面的操作，会影响到数据表有这几个

接着记录一下给其他几个表插入数据需要如何操作：

接着上面流程暂停的步骤继续操作，指定一个owner，来让流程继续下去

 @Test //给参与者赋值
    public void testSetOwner(){
        TaskService taskService =  activitiRule.getTaskService();
        //指定流程定义key,这里因为流程遇到了userTask会暂停，
        // 在task表里会记录是停在了哪个步骤的任务，所以
        // 需要查出task来给他指定一个owner来将流程继续下去
        Task task = taskService.createTaskQuery().processDefinitionKey("erjishenpiliucheng").singleResult();
        //使用taskService设置owner
        taskService.setOwner(task.getId(),"lxk");
    }

受影响的数据库表：

1.

这里可以看到这张表记录到，lxk以参与者的类型参与到了流程id  52505 的这个流程中，具体这个参与者在流程中参与了什么，有什么职责，要刷新一下task表

会发现OWNER_中同时指定了lxk这个用户。

如何让事件订阅信息表有数据呢？那就必须要让流程定义支持事件订阅，也就是说它必须支持message或者signal事件，接下来修改流程定义文件

使用my-process-message.bpmn20.xml ，代码如下

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">

  <message id="messageStart" name="my-message"></message>
  <process id="my-process">

    <startEvent id="start">
      <messageEventDefinition messageRef="messageStart"/>
    </startEvent>

    <sequenceFlow id="flow1" sourceRef="start" targetRef="someTask"/>
    <userTask id="someTask" name="Activiti is awesome!"/>
    <sequenceFlow id="flow2" sourceRef="someTask" targetRef="end"/>

    <endEvent id="end"/>

  </process>

</definitions>

然后部署一下流程定义文件：

public void testMyssage(){
        activitiRule.getRepositoryService()
                .createDeployment()
                .addClasspathResource("my-process-message.bpmn20.xml")
                .deploy();
    }

执行一下，会发现表：

中就有数据了：

这里EXECUTION_ID_ 与 PROC_INST_ID_为null，涉及到两种流程定义文件的区别：

一种是前者，刚才修改的那个定义文件，它的消息时间实在开始节点的位置，它可以接收一个消息 驱动流程的启动

而另一种是只有在流程开始以后，在流程的一个节点上去监听messageStart的消息，定义文件具体内容如下：

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">

  <message id="messageStart" name="my-message"></message>
  <process id="my-process">

    <startEvent id="start"/>

    <sequenceFlow id="flow1" sourceRef="start" targetRef="message-received"/>
    <intermediateCatchEvent id="message-received">
    <messageEventDefinition messageRef="messageStart"/>
    </intermediateCatchEvent>
    <sequenceFlow id="flow2" sourceRef="message-received" targetRef="end"/>

    <endEvent id="end"/>

  </process>

</definitions>

部署以后，需要再启动流程才可以看见EXECUTION_ID_ 与 PROC_INST_ID_插入数据。

接着是job表：

需要在流程定义文件中定一个 定时任务：

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

<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn"
    xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
    xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema"
    expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">

    <process id="my-process">

        <!--这种是自行启动流程的方式<startEvent id="start" />-->
        <!--定时任务来启动流程-->
        <startEvent id="start">
            <timerEventDefinition>
                <!-- 共执行5次，间隔为10S -->
                <timeCycle>R5/PT10S</timeCycle>
            </timerEventDefinition>
        </startEvent>
        <sequenceFlow id="flow1" sourceRef="start" targetRef="someTask" />

        <userTask id="someTask" name="Activiti is awesome!" />
        <sequenceFlow id="flow2" sourceRef="someTask" targetRef="end" />

        <endEvent id="end" />

    </process>

</definitions>

启动流程：

    public void testJob() throws InterruptedException {
        activitiRule.getRepositoryService()
                .createDeployment()
                .addClasspathResource("my-process_job.bpmn20.xml")
                .deploy();

        Thread.sleep(1000*30L);
    }

观察数据库 

插入了数据：

---

---

ACT_HI_*(历史流程数据表)涉及到九个表：

事件日志表比较特殊，只能插入与删除，无法修改

这里面有几个单表：

主要是跟TASK相关的

附件表与评论表：

ACT_HI_ATTACHMENT：在用户任务的处理过程中，可以提交一些附件

ACT_HI_COMMENT：或者添加一些评论

一般都是有需求时，对它们单独进行编辑，这两个表没有对应的运行时表，因为在运行的操作的过程中，提交的内容直接就把它作为历史记录存储起来

ACT_HI_PROCINST对应的实体类HistoricProcessInstanceEntityImpl

PROC_INST_ID_：流程实例ID

BUSINESS_KEY_：业务ID

PROC_DEF_ID_：流程定义ID

START_TIME_：开始时间

END_TIME_：结束时间

DURATION_：执行时长

START_USER_ID_：流程发起人

START_ACT_ID_：开始节点ID

END_ACT_ID_：结束节点ID

SUPER_PROCESS_INSTANCE_ID_：父流程实例

DELETE_REASON_：删除原因

TENANT_ID_：多租户

记录一下操作实例：

public class DbHistoryTest {
    private static final Logger LOGGER =  LoggerFactory.getLogger(configDBTest.class);

    @Rule
    public ActivitiRule activitiRule = new ActivitiRule("activiti_druid.cfg.xml");//传入自定义的mdc配置文件

    @Test
    public void testHistory(){
            //自动
            activitiRule.getRepositoryService()
                    .createDeployment()
                    .name("指定部署名称")
                    .addClasspathResource("my-process.bpmn20.xml");

        RuntimeService runtimeService = activitiRule.getRuntimeService();

        Map<String, Object> variables = Maps.newHashMap();
        variables.put("key0","value0");
        variables.put("key1","value1");
        variables.put("key2","value2");

        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("my-process", variables);
        //启动完以后获取流程实例ID，修改变量
        runtimeService.setVariable(processInstance.getId(),"key1","value1");

        //获取TaskService，然后获取到当前唯一需要执行的task
        TaskService taskService = activitiRule.getTaskService();

        //获取task是要演示一下参与者里面是否有添加一条记录
        Task task = taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult();

        //给当前task指定一个owner
        taskService.setOwner(task.getId(),"lxk");
        //同时上传一些附件
        taskService.createAttachment("url",task.getId(),processInstance.getId(),"附件","附件描述","/url/test.png");
        //同时再添加一些评论
        taskService.addComment(task.getId(),task.getProcessInstanceId(),"评论1");
        taskService.addComment(task.getId(),task.getProcessInstanceId(),"评论2");

        //完成这些操作以后，可以通过formService来将表单提交上去，也可以用taskservice来提交
        Map<String, String> properties = Maps.newHashMap();
        properties.put("key2","value2_1覆盖");
        properties.put("key3","value3_1");
        activitiRule.getFormService().submitTaskFormData(task.getId(),properties);
    }
}

执行效果：

表：

表：

表：

表：

附件表：

评论表：