flowable 6.8 适配达梦数据库

资源内容介绍

Flowable是一款开源的工作流引擎，它提供了业务流程管理和动态表单等功能，广泛应用于企业信息化建设。在6.8版本中，Flowable为了更好地服务于中国市场，尤其是那些使用达梦数据库（DM Database）的企业，进行了适配工作。达梦数据库是国产自主知识产权的高性能数据库管理系统，以其高安全性、高稳定性及良好的兼容性在国内得到了广泛应用。Flowable与达梦数据库的适配，意味着用户现在可以在使用Flowable进行业务流程管理时，选择达梦数据库作为后端存储系统。这种适配涉及到多个层面，包括但不限于SQL语句的优化、事务管理、数据类型映射、连接池配置等。SQL语句的优化是关键。由于不同的数据库系统在SQL语法和功能上存在差异，Flowable 6.8需要确保其生成的SQL语句能够正确执行在达梦数据库上，这可能需要对某些特定的查询或更新操作进行调整。例如，可能需要针对达梦数据库特有的函数或存储过程进行适配。事务管理是保证数据一致性的核心。Flowable作为一个分布式事务处理系统，需要与达梦数据库的事务机制进行深度融合，确保在并发环境下，流程实例的创建、更新和删除等操作能够正确回滚或提交。数据类型映射是另一个重要环节。Flowable中使用的数据类型可能与达梦数据库的不完全匹配，因此需要定义相应的映射规则，确保数据在Flowable和达梦数据库之间能准确无误地传输。此外，连接池的配置也是适配过程中的重要一环。通常，Flowable会依赖如HikariCP或Apache DBCP等连接池实现，需要为达梦数据库配置合适的连接参数，以确保高效稳定的数据连接。在提供的文件列表中，`.gitignore`用于定义版本控制系统忽略的文件类型，`flowable6.8_DM.iml`可能是IntelliJ IDEA的项目配置文件，`HELP.md`可能包含关于如何使用和配置Flowable 6.8适配达梦数据库的指南，`pom.xml`是Maven项目的配置文件，`src`目录包含了源代码，`.idea`目录存储了IDE的相关设置，`data`可能包含了示例数据或测试数据，而`target`目录则包含了编译后的输出文件。Flowable 6.8与达梦数据库的适配是一个涉及多方面技术的工程，包括数据库语法的兼容性、事务管理、数据类型映射以及连接池配置等，这使得Flowable能够在更广泛的环境中运行，进一步增强了其在中国市场的应用潜力。开发者可以通过分析源代码和配置文件，了解具体的适配实现细节，以便在实际项目中灵活运用。

//// Source code recreated from a .class file by IntelliJ IDEA// (powered by Fernflower decompiler)//package liquibase.database.core;import java.lang.reflect.Method;import java.sql.*;import java.util.ArrayList;import java.util.Arrays;import java.util.HashSet;import java.util.List;import java.util.Locale;import java.util.Map;import java.util.Properties;import java.util.ResourceBundle;import java.util.Set;import java.util.regex.Matcher;import java.util.regex.Pattern;import dm.jdbc.driver.DmdbConnection;import liquibase.CatalogAndSchema;import liquibase.GlobalConfiguration;import liquibase.Scope;import liquibase.database.AbstractJdbcDatabase;import liquibase.database.DatabaseConnection;import liquibase.database.OfflineConnection;import liquibase.database.jvm.JdbcConnection;import liquibase.exception.DatabaseException;import liquibase.exception.UnexpectedLiquibaseException;import liquibase.exception.ValidationErrors;import liquibase.executor.ExecutorService;import liquibase.statement.DatabaseFunction;import liquibase.statement.SequenceCurrentValueFunction;import liquibase.statement.SequenceNextValueFunction;import liquibase.statement.UniqueConstraint;import liquibase.statement.core.RawCallStatement;import liquibase.statement.core.RawSqlStatement;import liquibase.structure.DatabaseObject;import liquibase.structure.core.Catalog;import liquibase.structure.core.Index;import liquibase.structure.core.PrimaryKey;import liquibase.structure.core.Schema;import liquibase.util.JdbcUtil;import liquibase.util.StringUtil;public class OracleDatabase extends AbstractJdbcDatabase { public static final Pattern PROXY_USER = Pattern.compile(".*(?:thin|oci)\\:(.+)/@.*"); public static final String PRODUCT_NAME = "oracle"; private static ResourceBundle coreBundle = ResourceBundle.getBundle("liquibase/i18n/liquibase-core"); protected final int SHORT_IDENTIFIERS_LENGTH = 30; protected final int LONG_IDENTIFIERS_LEGNTH = 128; public static final int ORACLE_12C_MAJOR_VERSION = 12; private Set<String> reservedWords = new HashSet(); private Set<String> userDefinedTypes; private Map<String> savedSessionNlsSettings; private Boolean canAccessDbaRecycleBin; private Integer databaseMajorVersion; private Integer databaseMinorVersion; public OracleDatabase() { super.unquotedObjectsAreUppercased = true; super.setCurrentDateTimeFunction("SYSTIMESTAMP"); this.dateFunctions.add(new DatabaseFunction("SYSDATE")); this.dateFunctions.add(new DatabaseFunction("SYSTIMESTAMP")); this.dateFunctions.add(new DatabaseFunction("CURRENT_TIMESTAMP")); super.sequenceNextValueFunction = "%s.nextval"; super.sequenceCurrentValueFunction = "%s.currval"; } @Override public int getPriority() { return 1; } private void tryProxySession(String url, Connection con) { Matcher m = PROXY_USER.matcher(url); if (m.matches()) { Properties props = new Properties(); props.put("PROXY_USER_NAME", m.group(1)); Method method; try { method = con.getClass().getMethod("openProxySession", Integer.TYPE, Properties.class); method.setAccessible(true); method.invoke(con, 1, props); } catch (Exception var8) { Scope.getCurrentScope().getLog(this.getClass()).info("Could not open proxy session on OracleDatabase: " + var8.getCause().getMessage()); return; } try { method = con.getClass().getMethod("isProxySession"); method.setAccessible(true); boolean b = (Boolean)method.invoke(con); if (!b) { Scope.getCurrentScope().getLog(this.getClass()).info("Proxy session not established on OracleDatabase: "); } } catch (Exception var7) { Scope.getCurrentScope().getLog(this.getClass()).info("Could not open proxy session on OracleDatabase: " + var7.getCause().getMessage()); } } } @Override public void setConnection(DatabaseConnection conn) { this.reservedWords.addAll(Arrays.asList("GROUP", "USER", "SESSION", "PASSWORD", "RESOURCE", "START", "SIZE", "UID", "DESC", "ORDER")); Connection sqlConn = null; if (!(conn instanceof OfflineConnection)) { try { if (conn instanceof JdbcConnection) { sqlConn = ((JdbcConnection)conn).getWrappedConnection(); } } catch (Exception var29) { throw new UnexpectedLiquibaseException(var29); } if (sqlConn != null) { this.tryProxySession(conn.getURL(), sqlConn); try { this.reservedWords.addAll(Arrays.asList(sqlConn.getMetaData().getSQLKeywords().toUpperCase().split(",\\s*"))); } catch (SQLException var28) { Scope.getCurrentScope().getLog(this.getClass()).info("Could get sql keywords on OracleDatabase: " + var28.getMessage()); } try { Method method = sqlConn.getClass().getMethod("setRemarksReporting", Boolean.TYPE); method.setAccessible(true); method.invoke(sqlConn, true); } catch (Exception var27) { Scope.getCurrentScope().getLog(this.getClass()).info("Could not set remarks reporting on OracleDatabase: " + var27.getMessage()); } /** CallableStatement statement = null; String sql; try { statement = sqlConn.prepareCall("{call DBMS_UTILITY.DB_VERSION(?,?)}"); statement.registerOutParameter(1, 12); statement.registerOutParameter(2, 12); statement.execute(); String compatibleVersion = statement.getString(2); 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 var25) { sql = "Cannot read from DBMS_UTILITY.DB_VERSION: " + var25.getMessage(); Scope.getCurrentScope().getLog(this.getClass()).info("Could not set check compatibility mode on OracleDatabase, assuming not running in any sort of compatibility mode: " + sql); } finally { JdbcUtil.closeStatement(statement); } */ //-----------------------------------修改内容------------------------------- CallableStatement statement = null; String sql; 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.databaseMinorVer