Activiti连接达梦数据库

1、 5/5Activiti连接达梦数据库 目录 1 环境准备 (1) 2 创建SQL脚本 (1) 3 下载所需依赖包 (2) 3.1IDEA配置使用阿里云MAVEN仓库 (2) 3.2下载所有依赖包 (5) 4 修改配置文件 (5) 4.1修改APPLICATION.PROPERTIES文件 (5) 4.2修改POM.XML文件 (6) 5 加载DM驱动程序 (6) 5.1拷贝DM驱动程序 (6) 5.2将驱动程序打入M AVEN仓库 (7) 6 修改ACTIVITY-ENGINE-5.22.0 (8) 6.1修改P ROCESS E NGINE C ONFIGURATION I MPL文件 (

2、9) 6.2修改D B S QL S ESSION F ACTORY文件 (9) 6.3修改A BSTRACT Q UERY文件 (10) 7 ACTIVITY-ENGINE-5.22.0打包 (11) 8 验证结果 (12) 9 附录 (12) 1环境准备 项目名称：Spring boot整合activiti工作流引擎实例 Spring-Boot-Activiti5.22.0项目文件：Spring-Boot-Activiti5.22.0.zip 开发工具：IntelliJ IDEA 2020.2 (Ultimate Edition) IDEA安装路径：D:IDEA 项目路径：D:IDEAwo

3、rk 将项目文件解压至D:IDEAwork目录下，并导入IDEA： 2创建SQL脚本 将项目中activiti.sql脚本在数据库中创建。 说明：项目中activiti.sql脚本是Mysql的语法，可先在Mysql中创建，再通过DTS工具迁移至DM中。也可使用以下activiti.sql直接在DM中创建（以下activiti.sql语法已修改为DM语法）。 DM语法activiti.sql脚本：activiti.sql 3下载所需依赖包 3.1IDEA配置使用阿里云maven仓库 IDEA工具左上角：文件设置构建、执行、部署构建工具Maven 指定以下三个目录： Maven主目录(H): D

4、:/IDEA/plugins/maven/lib/maven3 用户设置文件(S): D:IDEApluginsmavenlibmaven3confsettings.xml 本地存储库(R)：C:UsersAdministrator.m2repository 在D:IDEApluginsmavenlibmaven3confsettings.xml文件中新增以下内容，使用阿里云maven仓库： central 3.2下载所有依赖包 4修改配置文件 4.1修改perties文件 将配置文件中数据源部分，改为达梦数据源： # datasource spring.datasource.url=jdbc

5、:dm:/:5236 spring.datasource.driver-class-name=dm.jdbc.driver.DmDriver http:/./doc/2e4cb966a1116c175f0e7cd184254b35effd1ad0.html ername=SYSDBA spring.datasource.password=SYSDBA 4.2修改pom.xml文件 在配置文件中新增达梦驱动部分： 1.8.0 5加载DM驱动程序 5.1拷贝DM驱动程序 达梦数据库驱动无法通过maven在线下载。所以通过将DM8的驱动程序加载到Maven仓库中实现，使用的驱动程序如下： 注意：Dm

6、JdbcDriver18.jar等名字和springboot不兼容。需要试用DmJdbcDriver.jar这个名字。 将驱动程序拷贝到Maven仓库中，并自定义创建对应的路径（红色字体需要自己创建）。本示例路径在： C:UsersAdministrator.m2repositorycomdmDmJdbcDriver1.8.0DmJdbcDriver.j ar 5.2将驱动程序打入Maven仓库 使用mvn.cmd工具将DM8驱动程序打入Maven仓库，mvn.cmd工具在：D:IDEApluginsmavenlibmaven3bin目录下，通过以下命令进行打入Maven仓库： mvn.cmd

7、 install:install-file -DgroupId=com.dm -DartifactId=DmJdbcDriver -Dversion=1.8.0 -Dpackaging=jar - Dfile=C:UsersAdministrator.m2repositorycomdmDmJdbcDriver1.8.0DmJdbcD river.jar 点击重新加载，DM驱动程序就不报错了。 6修改Activity-engine-5.22.0 将activiti-engine-5.22.0相关源码拷贝到工程src下，保持包路径不变，并做相应修改以支持达梦数据库。 6.1修改ProcessEng

8、ineConfigurationImpl文件 在org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl文件中，增加标红部分： public static final String DATABASE_TYPE_DM = dm; public static final String DATABASE_TYPE_H2 = h2; public static final String DATABASE_TYPE_HSQL = hsql; public static final String DATABASE_TYPE_MYSQL = my

9、sql; public static final String DATABASE_TYPE_ORACLE = oracle; protected static Properties getDefaultDatabaseTypeMappings() Properties databaseTypeMappings = new Properties(); databaseTypeMappings.setProperty(DM DBMS, DATABASE_TYPE_DM); databaseTypeMappings.setProperty(H2, DATABASE_TYPE_H2); 6.2修改Db

10、SqlSessionFactory文件 在org.activiti.engine.impl.db.DbSqlSessionFactory文件中，增加标红部分：if (oracle.equals(databaseType) | dm.equals(databaseType) bulkInsertableMap.put(EventLogEntryEntity.class, Boolean.FALSE); 在org.activiti.engine.impl.db.DbSqlSessionFactory文件中，增加标红部分：/ dm databaseSpecificLimitBeforeStateme

11、nts.put(dm, ); databaseSpecificLimitAfterStatements.put(dm, LIMIT #maxResults OFFSET #firstResult); databaseSpecificLimitBetweenStatements.put(dm, ); databaseOuterJoinLimitBetweenStatements.put(dm, ); databaseSpecificOrderByStatements.put(dm, defaultOrderBy); / h2 databaseSpecificLimitBeforeStatemen

12、ts.put(h2, ); databaseSpecificLimitAfterStatements.put(h2, LIMIT #maxResults OFFSET #firstResult); databaseSpecificLimitBetweenStatements.put(h2, ); databaseOuterJoinLimitBetweenStatements.put(h2, ); databaseSpecificOrderByStatements.put(h2, defaultOrderBy); 6.3修改AbstractQuery文件 在org.activiti.engine

13、.impl.AbstractQuery文件中，增加标红部分（2处）：if (nullHandlingOnOrder.equals(NullHandlingOnOrder.NULLS_FIRST) if (ProcessEngineConfigurationImpl.DATABASE_TYPE_H2.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_HSQL.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_POSTGRES.

14、equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_ORACLE.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_DM.equals(databaseType) orderBy = orderBy + defaultOrderByClause + NULLS FIRST; else if (ProcessEngineConfigurationImpl.DATABASE_TYPE_MYSQL.equals(databaseTy

15、pe) orderBy = orderBy + isnull( + column + ) desc, + defaultOrderByClause; else if (ProcessEngineConfigurationImpl.DATABASE_TYPE_DB2.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_MSSQL.equals(databaseType) orderBy = orderBy + case when + column + is null then 0 else 1 end, + de

16、faultOrderByClause; else orderBy = orderBy + defaultOrderByClause; else if (nullHandlingOnOrder.equals(NullHandlingOnOrder.NULLS_LAST) if (ProcessEngineConfigurationImpl.DATABASE_TYPE_H2.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_HSQL.equals(databaseType) | ProcessEngineConf

17、igurationImpl.DATABASE_TYPE_POSTGRES.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_ORACLE.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_DM.equals(databaseType) orderBy = orderBy + column + + sortOrder + NULLS LAST; else if (ProcessEngineConfigurationImpl.D

18、ATABASE_TYPE_MYSQL.equals(databaseType) orderBy = orderBy + isnull( + column + ) asc, + defaultOrderByClause; else if (ProcessEngineConfigurationImpl.DATABASE_TYPE_DB2.equals(databaseType) | ProcessEngineConfigurationImpl.DATABASE_TYPE_MSSQL.equals(databaseType) orderBy = orderBy + case when + column + is null then 1 else 0 end, + defaultOrderByClause; else orderBy = orderBy + defaultOrderByClau