Added index to process instance id for event subscriptions and missin…

…g execution id indexes
flowable · Sep 26, 2024 · bd2984f · bd2984f
1 parent 2526f9b
commit bd2984f
Show file tree

Hide file tree

Showing 23 changed files with 53 additions and 11 deletions.
diff --git a/...lowable-engine-common/src/main/java/org/flowable/common/engine/impl/FlowableVersions.java b/...lowable-engine-common/src/main/java/org/flowable/common/engine/impl/FlowableVersions.java
@@ -23,7 +23,7 @@
  */
 public class FlowableVersions {
 
-    public static final String CURRENT_VERSION = "7.1.0.1"; // Note the extra .x at the end. To cater for snapshot releases with different database changes
+    public static final String CURRENT_VERSION = "7.2.0.0"; // Note the extra .x at the end. To cater for snapshot releases with different database changes
 
     public static final List<FlowableVersion> FLOWABLE_VERSIONS = new ArrayList<>();
 
@@ -144,6 +144,7 @@ public class FlowableVersions {
         FLOWABLE_VERSIONS.add(new FlowableVersion("7.0.1.0"));
         FLOWABLE_VERSIONS.add(new FlowableVersion("7.0.1.1"));
         FLOWABLE_VERSIONS.add(new FlowableVersion("7.1.0.0"));
+        FLOWABLE_VERSIONS.add(new FlowableVersion("7.1.0.1"));
 
         /* Current */
         FLOWABLE_VERSIONS.add(new FlowableVersion(CURRENT_VERSION));

diff --git a/...n/src/main/resources/org/flowable/common/db/create/flowable.cockroachdb.create.common.sql b/...n/src/main/resources/org/flowable/common/db/create/flowable.cockroachdb.create.common.sql
@@ -16,7 +16,7 @@ CREATE TABLE if not exists ACT_GE_BYTEARRAY  (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);

diff --git a/...ne-common/src/main/resources/org/flowable/common/db/create/flowable.db2.create.common.sql b/...ne-common/src/main/resources/org/flowable/common/db/create/flowable.db2.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -602,4 +602,5 @@ create table ACT_RU_EVENT_SUBSCR (
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
 create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
diff --git a/...ine-common/src/main/resources/org/flowable/common/db/create/flowable.h2.create.common.sql b/...ine-common/src/main/resources/org/flowable/common/db/create/flowable.h2.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -130,6 +130,8 @@ create table ACT_RU_EVENT_SUBSCR (
 );
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
+create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
 
 create table ACT_RU_IDENTITYLINK (

diff --git a/...e-common/src/main/resources/org/flowable/common/db/create/flowable.hsql.create.common.sql b/...e-common/src/main/resources/org/flowable/common/db/create/flowable.hsql.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -130,6 +130,8 @@ create table ACT_RU_EVENT_SUBSCR (
 );
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
+create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
 
 create table ACT_RU_IDENTITYLINK (

diff --git a/...-common/src/main/resources/org/flowable/common/db/create/flowable.mssql.create.common.sql b/...-common/src/main/resources/org/flowable/common/db/create/flowable.mssql.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -600,4 +600,5 @@ create table ACT_RU_EVENT_SUBSCR (
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
 create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
diff --git a/...-common/src/main/resources/org/flowable/common/db/create/flowable.mysql.create.common.sql b/...-common/src/main/resources/org/flowable/common/db/create/flowable.mysql.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin;
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -599,4 +599,6 @@ create table ACT_RU_EVENT_SUBSCR (
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin;
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
+create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
diff --git a/...common/src/main/resources/org/flowable/common/db/create/flowable.oracle.create.common.sql b/...common/src/main/resources/org/flowable/common/db/create/flowable.oracle.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -602,4 +602,5 @@ create table ACT_RU_EVENT_SUBSCR (
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
 create index ACT_IDX_EVENT_SUBSCR on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
diff --git a/...mmon/src/main/resources/org/flowable/common/db/create/flowable.postgres.create.common.sql b/...mmon/src/main/resources/org/flowable/common/db/create/flowable.postgres.create.common.sql
@@ -16,7 +16,7 @@ create table ACT_GE_BYTEARRAY (
 );
 
 insert into ACT_GE_PROPERTY
-values ('common.schema.version', '7.1.0.1', 1);
+values ('common.schema.version', '7.2.0.0', 1);
 
 insert into ACT_GE_PROPERTY
 values ('next.dbid', '1', 1);
@@ -599,4 +599,5 @@ create table ACT_RU_EVENT_SUBSCR (
 
 create index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR(CONFIGURATION_);
 create index ACT_IDX_EVENT_SUBSCR on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
 create index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR(SCOPE_ID_, SCOPE_TYPE_);
diff --git a/...engine-common/src/main/resources/org/flowable/common/db/drop/flowable.db2.drop.common.sql b/...engine-common/src/main/resources/org/flowable/common/db/drop/flowable.db2.drop.common.sql
@@ -22,6 +22,7 @@ drop table ACT_HI_ENTITYLINK;
 
 drop index ACT_IDX_EVENT_SUBSCR_CONFIG_;
 drop index ACT_IDX_EVENT_SUBSCR_EXEC_ID;
+drop index ACT_IDX_EVENT_SUBSCR_PROC_ID;
 drop index ACT_IDX_EVENT_SUBSCR_SCOPEREF_;
 
 drop table ACT_RU_EVENT_SUBSCR;

diff --git a/...-engine-common/src/main/resources/org/flowable/common/db/drop/flowable.h2.drop.common.sql b/...-engine-common/src/main/resources/org/flowable/common/db/drop/flowable.h2.drop.common.sql
@@ -20,6 +20,8 @@ drop index if exists ACT_IDX_HI_ENT_LNK_SCOPE_DEF;
 drop table if exists ACT_RU_EVENT_SUBSCR cascade constraints;
 
 drop index if exists ACT_IDX_EVENT_SUBSCR_CONFIG_;
+drop index if exists ACT_IDX_EVENT_SUBSCR_EXEC_ID;
+drop index if exists ACT_IDX_EVENT_SUBSCR_PROC_ID;
 drop index if exists ACT_IDX_EVENT_SUBSCR_SCOPEREF_;
 
 drop table if exists ACT_RU_IDENTITYLINK cascade constraints;

diff --git a/...ngine-common/src/main/resources/org/flowable/common/db/drop/flowable.hsql.drop.common.sql b/...ngine-common/src/main/resources/org/flowable/common/db/drop/flowable.hsql.drop.common.sql
@@ -20,6 +20,8 @@ drop index if exists ACT_IDX_HI_ENT_LNK_SCOPE_DEF;
 drop table if exists ACT_RU_EVENT_SUBSCR cascade constraints;
 
 drop index if exists ACT_IDX_EVENT_SUBSCR_CONFIG_;
+drop index if exists ACT_IDX_EVENT_SUBSCR_EXEC_ID;
+drop index if exists ACT_IDX_EVENT_SUBSCR_PROC_ID;
 drop index if exists ACT_IDX_EVENT_SUBSCR_SCOPEREF_;
 
 drop table if exists ACT_RU_IDENTITYLINK cascade constraints;

diff --git a/...gine-common/src/main/resources/org/flowable/common/db/drop/flowable.mssql.drop.common.sql b/...gine-common/src/main/resources/org/flowable/common/db/drop/flowable.mssql.drop.common.sql
@@ -20,6 +20,7 @@ if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = '
 
 IF EXISTS (SELECT name FROM sysindexes WHERE name = 'ACT_IDX_EVENT_SUBSCR_CONFIG_') drop index ACT_RU_EVENT_SUBSCR.ACT_IDX_EVENT_SUBSCR_CONFIG_;
 IF EXISTS (SELECT name FROM sysindexes WHERE name = 'ACT_IDX_EVENT_SUBSCR_EXEC_ID') drop index ACT_RU_EVENT_SUBSCR.ACT_IDX_EVENT_SUBSCR_EXEC_ID;
+IF EXISTS (SELECT name FROM sysindexes WHERE name = 'ACT_IDX_EVENT_SUBSCR_PROC_ID') drop index ACT_RU_EVENT_SUBSCR.ACT_IDX_EVENT_SUBSCR_PROC_ID;
 IF EXISTS (SELECT name FROM sysindexes WHERE name = 'ACT_IDX_EVENT_SUBSCR_SCOPEREF_') drop index ACT_RU_EVENT_SUBSCR.ACT_IDX_EVENT_SUBSCR_SCOPEREF_;
 
 if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_EVENT_SUBSCR') drop table ACT_RU_EVENT_SUBSCR;

diff --git a/...gine-common/src/main/resources/org/flowable/common/db/drop/flowable.mysql.drop.common.sql b/...gine-common/src/main/resources/org/flowable/common/db/drop/flowable.mysql.drop.common.sql
@@ -21,6 +21,8 @@ drop index ACT_IDX_HI_ENT_LNK_SCOPE_DEF on ACT_HI_ENTITYLINK;
 drop table if exists ACT_HI_ENTITYLINK;
 
 drop index ACT_IDX_EVENT_SUBSCR_CONFIG_ on ACT_RU_EVENT_SUBSCR;
+drop index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR;
+drop index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR;
 drop index ACT_IDX_EVENT_SUBSCR_SCOPEREF_ on ACT_RU_EVENT_SUBSCR;
 
 drop table if exists ACT_RU_EVENT_SUBSCR;

diff --git a/...ine-common/src/main/resources/org/flowable/common/db/drop/flowable.oracle.drop.common.sql b/...ine-common/src/main/resources/org/flowable/common/db/drop/flowable.oracle.drop.common.sql
@@ -22,6 +22,7 @@ drop table ACT_HI_ENTITYLINK;
 
 drop index ACT_IDX_EVENT_SUBSCR_CONFIG_;
 drop index ACT_IDX_EVENT_SUBSCR;
+drop index ACT_IDX_EVENT_SUBSCR_PROC_ID;
 drop index ACT_IDX_EVENT_SUBSCR_SCOPEREF_;
 
 drop table ACT_RU_EVENT_SUBSCR;

diff --git a/...e-common/src/main/resources/org/flowable/common/db/drop/flowable.postgres.drop.common.sql b/...e-common/src/main/resources/org/flowable/common/db/drop/flowable.postgres.drop.common.sql
@@ -27,5 +27,3 @@ drop table if exists ACT_HI_VARINST cascade;
 
 drop table if exists ACT_GE_BYTEARRAY cascade;
 drop table if exists ACT_GE_PROPERTY cascade;
-
-
diff --git a/...resources/org/flowable/common/db/upgrade/flowable.db2.upgradestep.7101.to.7200.common.sql b/...resources/org/flowable/common/db/upgrade/flowable.db2.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,3 @@
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';
diff --git a/.../resources/org/flowable/common/db/upgrade/flowable.h2.upgradestep.7101.to.7200.common.sql b/.../resources/org/flowable/common/db/upgrade/flowable.h2.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,4 @@
+create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';
diff --git a/...esources/org/flowable/common/db/upgrade/flowable.hsql.upgradestep.7101.to.7200.common.sql b/...esources/org/flowable/common/db/upgrade/flowable.hsql.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,4 @@
+create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';
diff --git a/...sources/org/flowable/common/db/upgrade/flowable.mssql.upgradestep.7101.to.7200.common.sql b/...sources/org/flowable/common/db/upgrade/flowable.mssql.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,3 @@
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';
diff --git a/...sources/org/flowable/common/db/upgrade/flowable.mysql.upgradestep.7101.to.7200.common.sql b/...sources/org/flowable/common/db/upgrade/flowable.mysql.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,4 @@
+create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';
diff --git a/...ources/org/flowable/common/db/upgrade/flowable.oracle.upgradestep.7101.to.7200.common.sql b/...ources/org/flowable/common/db/upgrade/flowable.oracle.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,3 @@
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';
diff --git a/...rces/org/flowable/common/db/upgrade/flowable.postgres.upgradestep.7101.to.7200.common.sql b/...rces/org/flowable/common/db/upgrade/flowable.postgres.upgradestep.7101.to.7200.common.sql
@@ -0,0 +1,3 @@
+create index ACT_IDX_EVENT_SUBSCR_PROC_ID on ACT_RU_EVENT_SUBSCR(PROC_INST_ID_);
+
+update ACT_GE_PROPERTY set VALUE_ = '7.2.0.0' where NAME_ = 'common.schema.version';