如何配置工作流引擎Activiti集成JPA持久化保存流程数据-成都创新互联网站建设

成都创新互联网站制作

028-86922220

关于创新互联

多方位宣传企业产品与服务 突出企业形象

公司简介 公司的服务 荣誉资质 新闻动态 联系我们

如何配置工作流引擎Activiti集成JPA持久化保存流程数据

这篇文章主要讲解了“如何配置工作流引擎Activiti集成JPA持久化保存流程数据”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“如何配置工作流引擎Activiti集成JPA持久化保存流程数据”吧！

创新互联是一家集网站建设,宣威企业网站建设,宣威品牌网站建设,网站定制,宣威网站建设报价,网络营销,网络优化,宣威网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。

Activiti中JPA简介

  • 可以使用JPA实体作为流程变量,并进行操作:

    • 基于流程变量更新已有的JPA实体,可以在用户任务的表单中填写或者由服务任务生成

    • 重用已有的领域模型,不需要编写显示的服务获取实体或者更新实体的值

    • 根据已有实体的属性做出判断(网关即分支聚合)

JPA实体要求

  • Activiti中JPA只支持符合以下要求的实体:

    • Id字段或者属性能够使用JPA规范支持的任意类型:

    • 原生态数据类型和他们的包装类型(Boolean除外)

    • String

    • BigInteger

    • BigDecimal

    • java.util.Date

    • java.sql.Date

    • 实体应该使用JPA注解进行配置,支持字段和属性访问两种方式.@MappedSuperclass也要能够被使用

    • 实体中应该有一个使用@Id注解的主键,不支持复合主键@EmbeddedId 和 @IdClass:

JPA配置

  • 引擎必须有一个对EntityManagerFactory的引用才能够使用JPA的实体,这样可以通过配置引用或者提供一个持久化单元名称

  • 作为变量的JPA实体将会被自动检测并进行相应的处理

  • 使用jpaPersistenceUnitName配置:



    
    
    

    
    
    

    
    

    
    

  • 配置一个自定义的EntityManagerFactory,

    • 这里使用了OpenJPA实体管理器

    • 该代码片段仅仅包含与例子相关的beans,去掉了其他beans.

    • OpenJPA实体管理的完整并可以使用的例子可以在activiti-spring-examples(/activiti-spring/src/test/java/org/activiti/spring/test/jpa/JPASpringTest.java)中找到


  
  
    
      
    
  



  
  
  
  
  
  
  

  • 也可以在编程式创建一个引擎时完成配置:

ProcessEngine processEngine = ProcessEngineConfiguration
  .createProcessEngineConfigurationFromResourceDefault()
  .setJpaPersistenceUnitName("activiti-pu")
  .buildProcessEngine();

配置的属性有:

  • jpaPersistenceUnitName:使用持久化单元的名称:

    • 要确保该持久化单元在类路径下是可用的,默认的路径是 /META-INF/persistence.xml

    • 要么使用jpaEntityManagerFactory要么或者是jpaPersistenceUnitName

  • jpaEntityManagerFactory:一个实现了javax.persistence.EntityManagerFactory的bean的引用:

    • 将被用来加载实体并且刷新更新

    • 要么使用jpaEntityManagerFactory要么或者是jpaPersistenceUnitName

  • jpaHandleTransaction:在被使用的EntityManager实例上,该标记表示流程引擎是否需要开始和提交或者回滚事务:

    • 当使用Java事务API(JTA)时,设置为false

  • jpaCloseEntityManager:该标记表示流程引擎是否应该关闭从 EntityManagerFactory获取的EntityManager的实例:

    • 当EntityManager是由容器管理的时候需要设置为false:当使用并不是单一事务作用域的扩展持久化上下文的时候

JPA用法

简单示例

  • 首先,需要创建一个基于META-INF/persistence.xml的EntityManagerFactory作为持久化单元:包含持久化单元中所有的类和一些供应商特定的配置

  • 使用一个简单的实体作为测试,其中包含有一个id和String类型的value属性,也将会被持久化

  • 在测试之前,创建一个实体并且保存:

@Entity(name = "JPA_ENTITY_FIELD")
public class FieldAccessJPAEntity {

  @Id
  @Column(name = "ID_")
  private Long id;

  private String value;

  public FieldAccessJPAEntity() {
    // Empty constructor needed for JPA
  }

  public Long getId() {
    return id;
  }

  public void setId(Long id) {
    this.id = id;
  }

  public String getValue() {
    return value;
  }

  public void setValue(String value) {
    this.value = value;
  }
}

  • 启动一个新的流程实例,添加一个实体作为变量.其他的变量,将会被存储在流程引擎的持久化数据库中.下一次获取该变量的时候,将会根据该类和存储Id从EntityManager中加载:

Map variables = new HashMap();
variables.put("entityToUpdate", entityToUpdate);

ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("UpdateJPAValuesProcess", variables);

  • 流程定义中的第一个节点是一个服务任务,将会调用entityToUpdate上的setValue方法,其实就是之前在启动流程实例时候设置的JPA变量并且将会从当前流程引擎的上下文关联的EntityManager中加载:

  • 当完成服务任务时,流程实例将会停留在流程定义中定义的用户任务环节上:

    • 可以查看该流程实例

    • EntityManager已经被刷新了并且改变的实体已经被保存进数据库中

    • 获取entityToUpdate的变量value时,该实体将会被再次加载并且获取该实体属性的值将会是updatedValue

// Servicetask in process 'UpdateJPAValuesProcess' should have set value on entityToUpdate.
Object updatedEntity = runtimeService.getVariable(processInstance.getId(), "entityToUpdate");
assertTrue(updatedEntity instanceof FieldAccessJPAEntity);
assertEquals("updatedValue", ((FieldAccessJPAEntity)updatedEntity).getValue())

查询JPA流程变量

  • 以查询某一JPA实体作为变量的ProcessInstances和Executions

  • 在ProcessInstanceQuery和ExecutionQuery查询中仅仅variableValueEquals(name, entity)支持JPA实体变量:

    • [variableValueNotEquals],[variableValueGreaterThan],[variableValueGreaterThanOrEqual],[variableValueLessThan],[variableValueLessThanOrEqual]不被支持并且传递JPA实体值的时候会抛出一个ActivitiException

ProcessInstance result = runtimeService.createProcessInstanceQuery().variableValueEquals("entityToQuery", entityToQuery).singleResult();

使用Spring beans和JPA结合的高级例子

  • JPASpringTest,在activiti-spring-examples中:

    • 已经存在了一个使用JPA实体的Spring-bean,用来存储贷款申请

    • 使用Activiti,可以通过已经存在的bean获取已经使用的实体,并使用它作为变量用于流程中

  • 流程定义步骤:

    • 当申请批准,流程结束

    • 否则,一个额外的任务将会使用(发送拒绝信),这样就可以发送拒绝信手动通知客户 如何配置工作流引擎Activiti集成JPA持久化保存流程数据

    • 更新贷款申请实体,因此该实体与流程保持同步

    • 允许经理查看贷款申请,并填入审批意见(同意/不同意)

    • 审批意见将作为一个boolean变量approvedByManager进行存储

    • 创建一个新的贷款申请,使用已经存在的LoanRequestBean接受启动流程时候的变量(来自流程启动时候的表单)

    • 使用activiti:resultVariable(作为一个变量对表达式返回的结果进行存储)将创建出来的实体作为变量进行存储

    • 服务任务:

    • 用户任务:

    • 服务任务:

    • 根据贷款申请实体变量approved的值,将利用唯一网关自动决定下一步该选择那一条路径:




  
    
    

    
    

    
    

    
    

    
    
      ${loanRequest.approved}
    
    
      ${!loanRequest.approved}
    

    
    

    
    
  

感谢各位的阅读，以上就是“如何配置工作流引擎Activiti集成JPA持久化保存流程数据”的内容了，经过本文的学习后，相信大家对如何配置工作流引擎Activiti集成JPA持久化保存流程数据这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！


标题名称：如何配置工作流引擎Activiti集成JPA持久化保存流程数据
文章地址：http://kswsj.cn/article/jseied.html

其他资讯