三、达梦适配步骤整理

步骤一：报错处理_couldn’t deduct database type from database product name ‘DM DBMS’

原因分析

1. flowable启动后会从已有的databaseTypeMappings集合中看到数据库类型。
2. databaseTypeMappings集合调用的是getDefaultDatabaseTypeMappings方法
3. 在getDefaultDatabaseTypeMappings函数中并没有DM DBMS类型，所以会报错。

解决方案

在jdbc连接串后添加compatibleMode=oracle的兼容参数

注意:不采用网上的解决方案也就是将DM DBMS识别添加到getDefaultDatabaseTypeMappings函数中

spring:
  datasource:
    url: jdbc:dm://127.0.0.1:5236?compatibleMode=oracle
    username: SYSDBA
    password: SYSDBA
    driver-class-name: dm.jdbc.driver.DmDriver
    type: com.alibaba.druid.pool.DruidDataSource

步骤二：确认liquibase的版本

接下来需要查看下flowable的框架中内置的liquibase的版本，经测试发现3.x版本与4.x版本的代码有所差异，适配步骤不同

liquibase4.x的适配步骤

Cannot read from DBMS_UTILITY.DB_VERSION: -2193 第1 行附近出现错误:无效的方法名[DB_VERSION]

原因分析

1. 在liquibase.database.core.OracleDatabase#setConnection中代码会通过调用存储过程{call DBMS_UTILITY.DB_VERSION(?,?)}获取版本号通过解析后封装到databaseMajorVersion与databaseMinorVersion中。
2. 在达梦中并没有该存储过程，执行后控制台会报改错，因为取不到值

解决方案

在项目中新建liquibase.database.core目录并重写该部分源码，代码如下
调整的逻辑就是 判断connection类型 如果是DmdbConnection类 就直接把值写死即可。

                    CallableStatement statement = null;
                    try {
                        DatabaseMetaData metaData = sqlConn.getMetaData();
                        Connection connection = metaData.getConnection();
                        if (connection instanceof DmdbConnection) {
                            String compatibleVersion = "11.2.0.4.0";
                            Matcher majorVersionMatcher = Pattern.compile("(\\d+)\\.(\\d+)\\..*").matcher(compatibleVersion);
                            if (majorVersionMatcher.matches()) {
                                this.databaseMajorVersion = Integer.valueOf(majorVersionMatcher.group(1));
                                this.databaseMinorVersion = Integer.valueOf(majorVersionMatcher.group(2));
                            }
                        }else{
                            //noinspection HardCodedStringLiteral
                            statement = sqlConn.prepareCall("{call DBMS_UTILITY.DB_VERSION(?,?)}");
                            statement.registerOutParameter(1, Types.VARCHAR);
                            statement.registerOutParameter(2, Types.VARCHAR);
                            statement.execute();

                            String compatibleVersion = statement.getString(2); //"11.2.0.4.0";

                            if (compatibleVersion != null) {
                                Matcher majorVersionMatcher = Pattern.compile("(\\d+)\\.(\\d+)\\..*").matcher(compatibleVersion);
                                if (majorVersionMatcher.matches()) {
                                    this.databaseMajorVersion = Integer.valueOf(majorVersionMatcher.group(1));
                                    this.databaseMinorVersion = Integer.valueOf(majorVersionMatcher.group(2));
                                }
                            }
                        }




                    } catch (SQLException e) {
                        @SuppressWarnings("HardCodedStringLiteral") String message = "Cannot read from DBMS_UTILITY.DB_VERSION: " + e.getMessage();

                        //noinspection HardCodedStringLiteral
                        Scope.getCurrentScope().getLog(getClass()).info("Could not set check compatibility mode on OracleDatabase, assuming not running in any sort of compatibility mode: " + message);
                    } finally {
                        JdbcUtil.closeStatement(statement);
                    }

liquibase3.x的适配步骤_现场环境

注：使用2023以后的达梦jdbc驱动版本，理论来说可规避该问题。

Error creating dmn liquibase instance

现场适配的版本是3.6.3版本，报错堆栈如下：

原因分析

根据堆栈可以看到liquibase.changelog.ChangeLogParameters类初始化取getDatabaseMinorVersion时报错。
修改思路就是，找到源码直接强制修改结果集

解决方案

在项目中新建liquibase.changelog目录并重写liquibase.changelog.ChangeLogParameters#ChangeLogParameters(liquibase.database.Database) 该部分源码，代码如下
调整的逻辑就是 把getDatabaseMinorVersion函数的返回值写死，根据jdbc的查询oracle的结果，直接写死该值

            try {
              //  this.set("database.databaseMinorVersion", database.getDatabaseMinorVersion());
                this.set("database.databaseMinorVersion", "2");
            } catch (Exception ignore) {
            }