activiti 数据库升级 upgrade

简介: 分享牛原创(尊重原创 转载对的时候第一行请注明,转载出处来自分享牛http://blog.csdn.net/qq_30739519)在项目中我们如果使用activiti 工作流引擎的时候,肯定是需要数据库支持的,如果有一天我们打算升级activi...


分享牛原创(尊重原创 转载对的时候第一行请注明,转载出处来自分享牛http://blog.csdn.net/qq_30739519)

在项目中我们如果使用activiti 工作流引擎的时候,肯定是需要数据库支持的,如果有一天我们打算升级activiti 工作流引擎的时候,那么对应的数据库表或者视图也是需要升级,因为有可能表结构有调整,举例:activiti 5.14的时候act_re_deployment表中没有tenant_id_字段,activiti 5.19有这个字段了,那我们升级的时候,肯定需要升级数据库了,下面详细的讲解如何升级数据库。

1.1.1. 第一种方式 手动sql方式

我们首先打开我们下载的activiti 工程,目录结构如下所示:

 

 

打开database目录,结构如下图所示:

 

目录说明:

create 数据库、表视图、索引的创建脚本。

drop 数据库、表视图、索引的删除脚本。(删除引擎最好这种方式删除的比较干净)

upgrade 数据库、表视图、索引的升级脚本。

目录里面的sql命名规范:

activiti.db2.create.history.sql

activiti:activiti工作流的标示。

db2 数据库厂商的名称(可以是mysqlh2oraclepostgres)比如我用的是postgres数据库,那么操作的时候选择activiti.postgres开头的即可。

create:创建数据库的意思,那对应的肯定有dropupgradestep标示符,操作的时候选择对应的即可。

最后一个标示符history,因为sql创建表的时候分为三个大的sql脚本。

1.engine核心的创建表语句、主要是ru*表等。

2.history 主要创建工作流的hi*表。

3.identity 主要创建工作流的用户表、id*以及用户信息表(扩展表的时候可以不使用这个,后面权限构建章节会详细讲解)

 

上面对目录做了一个介绍,接下来就进入upgrade目录中,如下图所示是upgrade表中的部分sql脚本:

 

升级数据库的时候比如说53to.43.xx.sqll升级的时候 53代表当前的activiti 版本,54标示需要升级到的版本。选择需要升级的数据库表的sql对应版本即可。

activiti对应的版本信息如下:

 

 

1.1.2. 第二种方式 配置方式

//主要是配置activiti 工作流引擎自定义的一些属性信息。

<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
property name="databaseSchemaUpdate" value="drop-create"></property>
</bean>
<bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
<property name="processEngineConfiguration" ref="processEngineConfiguration" />
</bean>


这里说明一下我们使用的主要的工作流对象是processEngine,从这个对象中获取各个xxxService,processEngine是需要processEngineConfiguration对象中的属性的,就好比你你去找工作,总要把自己的属性提升提升吧,换换衣服,刮刮胡子之类的。

我们接下来重点看一下ProcessEngineImpl中的源码。主要看是数据库创建、删除、更新操作底层是如何实现的。

ProcessEngineImpl继承关系如下图所示:

 

ProcessEngineImpl类的构造方法如下:

public ProcessEngineImpl(ProcessEngineConfigurationImpl processEngineConfiguration) {
...
commandExecutor.execute(processEngineConfiguration.getSchemaCommandConfig(), new SchemaOperationsProcessEngineBuild());
...
}


下面我们重点看一下commandExecutor.execute(processEngineConfiguration.getSchemaCommandConfig(), new SchemaOperationsProcessEngineBuild());方法,这个方法就是进行数据库表的创建、更新以及删除操作。看看这个方法是怎么获取配置文件然后操作数据库的,我们不仅要知道怎么配置,更重要的是知道配置在activiti中是如何解析使用的。

 

//这是一个典型的命令模式,这里我们先看一下这个SchemaOperationsProcessEngineBuild 命令是如何使用的,关于activiti Command 模式我们会在后面的文章详细的讲解

public final class SchemaOperationsProcessEngineBuild implements Command<Object> {
  public Object execute(CommandContext commandContext) {
    commandContext
      .getSession(DbSqlSession.class)
      .performSchemaOperationsProcessEngineBuild();
    return null;
  }
}


下面看一下performSchemaOperationsProcessEngineBuild方法中的操作:

打开类org.activiti.engine.impl.db.DbSqlSession中的performSchemaOperationsProcessEngineBuild方法如下所示:

 public static final String DB_SCHEMA_UPDATE_CREATE = "create";
public static final String DB_SCHEMA_UPDATE_DROP_CREATE = "drop-create";
public void performSchemaOperationsProcessEngineBuild() {
//这个方法就是获取 上面的<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
property name="databaseSchemaUpdate" value="drop-create"></property>
</bean>中的配置的信息
   默认不配置 是false
String databaseSchemaUpdate = Context.getProcessEngineConfiguration().getDatabaseSchemaUpdate();
//drop-create  删除表重新创建
    if (ProcessEngineConfigurationImpl.DB_SCHEMA_UPDATE_DROP_CREATE.equals(databaseSchemaUpdate)) {
      try {
//删除操作
        dbSchemaDrop();
      } catch (RuntimeException e) {
        // ignore
      }
}
//配置的是 create-drop drop-create create三个中的任意一个
    if ( org.activiti.engine.ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP.equals(databaseSchemaUpdate)
         || ProcessEngineConfigurationImpl.DB_SCHEMA_UPDATE_DROP_CREATE.equals(databaseSchemaUpdate)
         || ProcessEngineConfigurationImpl.DB_SCHEMA_UPDATE_CREATE.equals(databaseSchemaUpdate)
       ) {
//创建操作
      dbSchemaCreate();
      
    } else if (org.activiti.engine.ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE.equals(databaseSchemaUpdate)) {
//检查版本     
 dbSchemaCheckVersion();
      
} else if (ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE.equals(databaseSchemaUpdate)) {
//设置true就更新操作
      dbSchemaUpdate();
    }
  }


这个时候我们已经很明确参数配置的含义,以及配置参数后引擎的处理。关于activiti 工作流引擎中如何打开数据库操作表、如何更新表,因为这个地方比较负责设计mybstis内容,这个也在后面的章节讲解,然后举一反三的把这个原理也说一下。

最后,我们总结一下两种方式的优缺点:

1.第一种方式最好,sql直接运行,在数据库层面操作,速度比较快。

2.第二种方式,需要配置,是在程序级别操作,肯定还需要打开数据库连接操作,如果打开数据库连接则比较消耗性能。如果自己扩展了activti 工作流的表,可能会引起不必要的麻烦。

3.个人推荐使用第一种直接运行sql的方式进行升级。

相关文章
|
4月前
|
SQL 数据库 Python
记Flask-Migrate迁移数据库失败的两个Bug——详解循环导入问题
Flask-Migrate迁移数据库失败的两个Bug 1、找不到数据库:Unknown database ‘***’ 若还没有创建数据库,该迁移工具不会自动创建。你可以使用SQL命令手动创建一个数据库:
37 0
|
数据可视化 BI 数据库
Superset执行「superset db upgrade」命令的报错记录
Superset执行「superset db upgrade」命令的报错记录
844 0
Superset执行「superset db upgrade」命令的报错记录
|
4月前
|
关系型数据库 MySQL 数据库
MySQL【部署 03】8.0.25离线部署(下载+安装+配置)Failed dependencies 问题处理及8.0配置参数说明
MySQL【部署 03】8.0.25离线部署(下载+安装+配置)Failed dependencies 问题处理及8.0配置参数说明
121 0
|
8月前
|
SQL 数据库 开发工具
真香!flyway数据库版本控制
真香!flyway数据库版本控制
189 0
|
11月前
|
SQL 测试技术 数据库
生产环境在对Web应用进行版本回退时针对数据库表的回滚操作
生产环境在对Web应用进行版本回退时针对数据库表的回滚操作
92 0
|
12月前
|
SQL Oracle 关系型数据库
SpringBoot + Flyway,自动化实现数据库版本控制
SpringBoot + Flyway,自动化实现数据库版本控制
IEDA与activiti不兼容等等安装错误问题的解决方案
IEDA与activiti不兼容等等安装错误问题的解决方案
113 0
|
SQL Java 关系型数据库
数据库版本管理工具 Flyway 简单使用
如何快速上手使用数据版本管理工具 Flyway
397 0
数据库版本管理工具 Flyway 简单使用
|
SQL Java
JeeSite3.x版本启动不自动建表
JeeSite3.x版本启动不自动建表,防止mysql区分大小写情况下重复建表
522 0
|
关系型数据库 MySQL SQL
新功能初探 | MySQL 8.0.17重量级功能:clone plugin
MySQL8.0.17推出了一个重量级的功能:clone plugin。允许用户可以将当前实例进行本地或者远程的clone。这在某些场景尤其想快速搭建复制备份或者在group replication里加入新成员时非常有用。本文主要试玩下该功能,并试图阐述下其实现的机制是什么。
968 0