diff --git a/modules/flowable-cmmn-engine/src/test/java/org/flowable/cmmn/test/task/CmmnTaskQueryTest.java b/modules/flowable-cmmn-engine/src/test/java/org/flowable/cmmn/test/task/CmmnTaskQueryTest.java index 1e1c6553e54eb330f36bf64e895e57006017c90b..b6c685ef9544eb4781957464223dd8130ddc5718 100644 --- a/modules/flowable-cmmn-engine/src/test/java/org/flowable/cmmn/test/task/CmmnTaskQueryTest.java +++ b/modules/flowable-cmmn-engine/src/test/java/org/flowable/cmmn/test/task/CmmnTaskQueryTest.java @@ -75,7 +75,7 @@ public class CmmnTaskQueryTest extends FlowableCmmnTestCase { } @Test - public void testQuertByCaseDefinitionId() { + public void testQueryByCaseDefinitionId() { CaseDefinition caseDefinition = cmmnRepositoryService.createCaseDefinitionQuery().singleResult(); assertNotNull(caseDefinition); assertEquals(NR_CASE_INSTANCES, cmmnTaskService.createTaskQuery().caseDefinitionId(caseDefinition.getId()).list().size()); diff --git a/modules/flowable-engine/src/main/java/org/flowable/engine/impl/cfg/ProcessEngineConfigurationImpl.java b/modules/flowable-engine/src/main/java/org/flowable/engine/impl/cfg/ProcessEngineConfigurationImpl.java index 5ab423ac61b42d2eca3a18299a045b1c4fa15ba1..9fb4779f7c620ae1b638dd86f36ef42e4d6e43fd 100755 --- a/modules/flowable-engine/src/main/java/org/flowable/engine/impl/cfg/ProcessEngineConfigurationImpl.java +++ b/modules/flowable-engine/src/main/java/org/flowable/engine/impl/cfg/ProcessEngineConfigurationImpl.java @@ -286,6 +286,7 @@ import org.flowable.job.service.impl.asyncexecutor.DefaultAsyncJobExecutor; import org.flowable.job.service.impl.asyncexecutor.ExecuteAsyncRunnableFactory; import org.flowable.job.service.impl.asyncexecutor.FailedJobCommandFactory; import org.flowable.job.service.impl.asyncexecutor.JobManager; +import org.flowable.job.service.impl.db.JobDbSchemaManager; import org.flowable.task.service.InternalTaskLocalizationManager; import org.flowable.task.service.InternalTaskVariableScopeResolver; import org.flowable.task.service.TaskServiceConfiguration; @@ -743,6 +744,7 @@ public abstract class ProcessEngineConfigurationImpl extends ProcessEngineConfig protected DbSchemaManager identityLinkDbSchemaManager; protected DbSchemaManager variableDbSchemaManager; protected DbSchemaManager taskDbSchemaManager; + protected DbSchemaManager jobDbSchemaManager; // Backwards compatibility ////////////////////////////////////////////////////////////// @@ -923,6 +925,7 @@ public abstract class ProcessEngineConfigurationImpl extends ProcessEngineConfig initIdentityLinkDbSchemaManager(); initVariableDbSchemaManager(); initTaskDbSchemaManager(); + initJobDbSchemaManager(); } protected void initProcessDbSchemaManager() { @@ -948,6 +951,12 @@ public abstract class ProcessEngineConfigurationImpl extends ProcessEngineConfig this.identityLinkDbSchemaManager = new IdentityLinkDbSchemaManager(); } } + + protected void initJobDbSchemaManager() { + if (this.jobDbSchemaManager == null) { + this.jobDbSchemaManager = new JobDbSchemaManager(); + } + } public void initMybatisTypeHandlers(Configuration configuration) { configuration.getTypeHandlerRegistry().register(VariableType.class, JdbcType.VARCHAR, new IbatisVariableTypeHandler(variableTypes)); @@ -3438,6 +3447,15 @@ public abstract class ProcessEngineConfigurationImpl extends ProcessEngineConfig this.identityLinkDbSchemaManager = identityLinkDbSchemaManager; return this; } + + public DbSchemaManager getJobDbSchemaManager() { + return jobDbSchemaManager; + } + + public ProcessEngineConfigurationImpl setJobDbSchemaManager(DbSchemaManager jobDbSchemaManager) { + this.jobDbSchemaManager = jobDbSchemaManager; + return this; + } // Flowable 5 diff --git a/modules/flowable-engine/src/main/java/org/flowable/engine/impl/db/ProcessDbSchemaManager.java b/modules/flowable-engine/src/main/java/org/flowable/engine/impl/db/ProcessDbSchemaManager.java index b94e5bed6a11b24ee081f5376754abed89baa6a3..15a4a9bf3500e193b8db2debcad504e71e035820 100644 --- a/modules/flowable-engine/src/main/java/org/flowable/engine/impl/db/ProcessDbSchemaManager.java +++ b/modules/flowable-engine/src/main/java/org/flowable/engine/impl/db/ProcessDbSchemaManager.java @@ -92,6 +92,7 @@ public class ProcessDbSchemaManager extends AbstractSqlScriptBasedDbSchemaManage getIdentityLinkDbSchemaManager().dbSchemaCreate(); getTaskDbSchemaManager().dbSchemaCreate(); getVariableDbSchemaManager().dbSchemaCreate(); + getJobDbSchemaManager().dbSchemaCreate(); if (isEngineTablePresent()) { String dbVersion = getDbVersion(); @@ -127,6 +128,12 @@ public class ProcessDbSchemaManager extends AbstractSqlScriptBasedDbSchemaManage } catch (Exception e) { LOGGER.info("Error dropping engine tables", e); } + + try { + getJobDbSchemaManager().dbSchemaDrop(); + } catch (Exception e) { + LOGGER.info("Error dropping job tables", e); + } try { getVariableDbSchemaManager().dbSchemaDrop(); @@ -166,6 +173,7 @@ public class ProcessDbSchemaManager extends AbstractSqlScriptBasedDbSchemaManage getIdentityLinkDbSchemaManager().dbSchemaUpdate(); getTaskDbSchemaManager().dbSchemaUpdate(); getVariableDbSchemaManager().dbSchemaUpdate(); + getJobDbSchemaManager().dbSchemaUpdate(); String feedback = null; boolean isUpgradeNeeded = false; @@ -331,6 +339,10 @@ public class ProcessDbSchemaManager extends AbstractSqlScriptBasedDbSchemaManage return CommandContextUtil.getProcessEngineConfiguration().getTaskDbSchemaManager(); } + protected DbSchemaManager getJobDbSchemaManager() { + return CommandContextUtil.getProcessEngineConfiguration().getJobDbSchemaManager(); + } + @Override protected String getResourcesRootDirectory() { return "org/flowable/db/"; diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.db2.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.db2.create.engine.sql index f6aef117eeeb6f03475b38920c362e1454174824..d50e869c5914c29615b94dbf7944116aad828ed4 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.db2.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.db2.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ); -create table ACT_RU_JOB ( - ID_ varchar(64) not null, - REV_ integer, - TYPE_ varchar(255) not null, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_TIMER_JOB ( - ID_ varchar(64) not null, - REV_ integer, - TYPE_ varchar(255) not null, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_SUSPENDED_JOB ( - ID_ varchar(64) not null, - REV_ integer, - TYPE_ varchar(255) not null, - EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_DEADLETTER_JOB ( - ID_ varchar(64) not null, - REV_ integer, - TYPE_ varchar(255) not null, - EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_HISTORY_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - ADV_HANDLER_CFG_ID_ varchar(64), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - create table ACT_RE_PROCDEF ( ID_ varchar(64) not null, REV_ integer, @@ -241,19 +142,15 @@ create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_); create index ACT_IDX_JOB_EXECUTION_ID on ACT_RU_JOB(EXECUTION_ID_); create index ACT_IDX_JOB_PROCESS_INSTANCE_ID on ACT_RU_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_JOB_PROC_DEF_ID on ACT_RU_JOB(PROC_DEF_ID_); -create index ACT_IDX_JOB_EXCEPTION_STACK_ID on ACT_RU_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_TIMER_JOB_EXECUTION_ID on ACT_RU_TIMER_JOB(EXECUTION_ID_); create index ACT_IDX_TIMER_JOB_PROCESS_INSTANCE_ID on ACT_RU_TIMER_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_TIMER_JOB_PROC_DEF_ID on ACT_RU_TIMER_JOB(PROC_DEF_ID_); -create index ACT_IDX_TIMER_JOB_EXCEPTION_STACK_ID on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_SUSPENDED_JOB_EXECUTION_ID on ACT_RU_SUSPENDED_JOB(EXECUTION_ID_); create index ACT_IDX_SUSPENDED_JOB_PROCESS_INSTANCE_ID on ACT_RU_SUSPENDED_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_SUSPENDED_JOB_PROC_DEF_ID on ACT_RU_SUSPENDED_JOB(PROC_DEF_ID_); -create index ACT_IDX_SUSPENDED_JOB_EXCEPTION_STACK_ID on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_DEADLETTER_JOB_EXECUTION_ID on ACT_RU_DEADLETTER_JOB(EXECUTION_ID_); create index ACT_IDX_DEADLETTER_JOB_PROCESS_INSTANCE_ID on ACT_RU_DEADLETTER_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_DEADLETTER_JOB_PROC_DEF_ID on ACT_RU_DEADLETTER_JOB(PROC_DEF_ID_); -create index ACT_IDX_DEADLETTER_JOB_EXCEPTION_STACK_ID on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_INFO_PROCDEF on ACT_PROCDEF_INFO(PROC_DEF_ID_); alter table ACT_GE_BYTEARRAY @@ -340,11 +237,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -360,11 +252,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -380,11 +267,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -400,11 +282,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC foreign key (EXECUTION_ID_) diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.h2.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.h2.create.engine.sql index 7bbe984f14b4f93e1852b70ea25f866e9b33fd73..f1b5c22ae95d062c7be9f651ac1859332dd407fe 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.h2.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.h2.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ); -create table ACT_RU_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_TIMER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_SUSPENDED_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_DEADLETTER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_HISTORY_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - ADV_HANDLER_CFG_ID_ varchar(64), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - create table ACT_RE_PROCDEF ( ID_ varchar(64) NOT NULL, REV_ integer, @@ -310,11 +211,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -330,11 +226,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -350,11 +241,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -370,11 +256,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC foreign key (EXECUTION_ID_) diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.hsql.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.hsql.create.engine.sql index 5ca854fbcc2686a35c946259cf9df0ee66b6b8a1..8b7868426237184c117e5a96a6501db9db2b8904 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.hsql.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.hsql.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ); -create table ACT_RU_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_TIMER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_SUSPENDED_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_DEADLETTER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_HISTORY_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - ADV_HANDLER_CFG_ID_ varchar(64), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - create table ACT_RE_PROCDEF ( ID_ varchar(64) NOT NULL, REV_ integer, @@ -310,11 +211,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -330,11 +226,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -350,11 +241,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -370,11 +256,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF; -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY; - alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC foreign key (EXECUTION_ID_) diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mssql.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mssql.create.engine.sql index 87d46311e70e64dacedb6b3a4f8f35c990023f09..c50e5991246d3a13d2efcde4f4b98463793ce388 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mssql.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mssql.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ); -create table ACT_RU_JOB ( - ID_ nvarchar(64) NOT NULL, - REV_ int, - TYPE_ nvarchar(255) NOT NULL, - LOCK_EXP_TIME_ datetime, - LOCK_OWNER_ nvarchar(255), - EXCLUSIVE_ bit, - EXECUTION_ID_ nvarchar(64), - PROCESS_INSTANCE_ID_ nvarchar(64), - PROC_DEF_ID_ nvarchar(64), - RETRIES_ int, - EXCEPTION_STACK_ID_ nvarchar(64), - EXCEPTION_MSG_ nvarchar(4000), - DUEDATE_ datetime NULL, - REPEAT_ nvarchar(255), - HANDLER_TYPE_ nvarchar(255), - HANDLER_CFG_ nvarchar(4000), - CREATE_TIME_ datetime2 NULL, - TENANT_ID_ nvarchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_TIMER_JOB ( - ID_ nvarchar(64) NOT NULL, - REV_ int, - TYPE_ nvarchar(255) NOT NULL, - LOCK_EXP_TIME_ datetime, - LOCK_OWNER_ nvarchar(255), - EXCLUSIVE_ bit, - EXECUTION_ID_ nvarchar(64), - PROCESS_INSTANCE_ID_ nvarchar(64), - PROC_DEF_ID_ nvarchar(64), - RETRIES_ int, - EXCEPTION_STACK_ID_ nvarchar(64), - EXCEPTION_MSG_ nvarchar(4000), - DUEDATE_ datetime NULL, - REPEAT_ nvarchar(255), - HANDLER_TYPE_ nvarchar(255), - HANDLER_CFG_ nvarchar(4000), - CREATE_TIME_ datetime2 NULL, - TENANT_ID_ nvarchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_SUSPENDED_JOB ( - ID_ nvarchar(64) NOT NULL, - REV_ int, - TYPE_ nvarchar(255) NOT NULL, - EXCLUSIVE_ bit, - EXECUTION_ID_ nvarchar(64), - PROCESS_INSTANCE_ID_ nvarchar(64), - PROC_DEF_ID_ nvarchar(64), - RETRIES_ int, - EXCEPTION_STACK_ID_ nvarchar(64), - EXCEPTION_MSG_ nvarchar(4000), - DUEDATE_ datetime NULL, - REPEAT_ nvarchar(255), - HANDLER_TYPE_ nvarchar(255), - HANDLER_CFG_ nvarchar(4000), - CREATE_TIME_ datetime2 NULL, - TENANT_ID_ nvarchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_DEADLETTER_JOB ( - ID_ nvarchar(64) NOT NULL, - REV_ int, - TYPE_ nvarchar(255) NOT NULL, - EXCLUSIVE_ bit, - EXECUTION_ID_ nvarchar(64), - PROCESS_INSTANCE_ID_ nvarchar(64), - PROC_DEF_ID_ nvarchar(64), - EXCEPTION_STACK_ID_ nvarchar(64), - EXCEPTION_MSG_ nvarchar(4000), - DUEDATE_ datetime NULL, - REPEAT_ nvarchar(255), - HANDLER_TYPE_ nvarchar(255), - HANDLER_CFG_ nvarchar(4000), - CREATE_TIME_ datetime2 NULL, - TENANT_ID_ nvarchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_HISTORY_JOB ( - ID_ nvarchar(64) NOT NULL, - REV_ int, - LOCK_EXP_TIME_ datetime NULL, - LOCK_OWNER_ nvarchar(255), - RETRIES_ int, - EXCEPTION_STACK_ID_ nvarchar(64), - EXCEPTION_MSG_ nvarchar(4000), - HANDLER_TYPE_ nvarchar(255), - HANDLER_CFG_ nvarchar(4000), - ADV_HANDLER_CFG_ID_ nvarchar(64), - CREATE_TIME_ datetime2 NULL, - TENANT_ID_ nvarchar(255) default '', - primary key (ID_) -); - create table ACT_RE_PROCDEF ( ID_ nvarchar(64) not null, REV_ int, @@ -241,19 +142,15 @@ create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_); create index ACT_IDX_JOB_EXECUTION_ID on ACT_RU_JOB(EXECUTION_ID_); create index ACT_IDX_JOB_PROCESS_INSTANCE_ID on ACT_RU_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_JOB_PROC_DEF_ID on ACT_RU_JOB(PROC_DEF_ID_); -create index ACT_IDX_JOB_EXCEPTION_STACK_ID on ACT_RU_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_TIMER_JOB_EXECUTION_ID on ACT_RU_TIMER_JOB(EXECUTION_ID_); create index ACT_IDX_TIMER_JOB_PROCESS_INSTANCE_ID on ACT_RU_TIMER_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_TIMER_JOB_PROC_DEF_ID on ACT_RU_TIMER_JOB(PROC_DEF_ID_); -create index ACT_IDX_TIMER_JOB_EXCEPTION_STACK_ID on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_SUSPENDED_JOB_EXECUTION_ID on ACT_RU_SUSPENDED_JOB(EXECUTION_ID_); create index ACT_IDX_SUSPENDED_JOB_PROCESS_INSTANCE_ID on ACT_RU_SUSPENDED_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_SUSPENDED_JOB_PROC_DEF_ID on ACT_RU_SUSPENDED_JOB(PROC_DEF_ID_); -create index ACT_IDX_SUSPENDED_JOB_EXCEPTION_STACK_ID on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_DEADLETTER_JOB_EXECUTION_ID on ACT_RU_DEADLETTER_JOB(EXECUTION_ID_); create index ACT_IDX_DEADLETTER_JOB_PROCESS_INSTANCE_ID on ACT_RU_DEADLETTER_JOB(PROCESS_INSTANCE_ID_); create index ACT_IDX_DEADLETTER_JOB_PROC_DEF_ID on ACT_RU_DEADLETTER_JOB(PROC_DEF_ID_); -create index ACT_IDX_DEADLETTER_JOB_EXCEPTION_STACK_ID on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); create index ACT_IDX_INFO_PROCDEF on ACT_PROCDEF_INFO(PROC_DEF_ID_); alter table ACT_GE_BYTEARRAY @@ -335,11 +232,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -355,11 +247,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -375,11 +262,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -395,11 +277,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC foreign key (EXECUTION_ID_) diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql.create.engine.sql index b2b3c063382ddea8e7bb79a07a7fd192e430f4b4..12569c22bbf09cf543633214d8725c61636ddcc8 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; -create table ACT_RU_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp(3) NULL, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp(3) NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp(3) NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_TIMER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp(3) NULL, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp(3) NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp(3) NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_SUSPENDED_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp(3) NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp(3) NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_DEADLETTER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp(3) NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp(3) NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_HISTORY_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - LOCK_EXP_TIME_ timestamp(3) NULL, - LOCK_OWNER_ varchar(255), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - ADV_HANDLER_CFG_ID_ varchar(64), - CREATE_TIME_ timestamp(3) NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - create table ACT_RE_PROCDEF ( ID_ varchar(64) not null, REV_ integer, @@ -311,11 +212,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -331,11 +227,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -351,11 +242,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -371,11 +257,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC foreign key (EXECUTION_ID_) diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql55.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql55.create.engine.sql index 03b3cc959e5b42b02a8312e78da1e084a7426a41..2391a26f0f40722378c7f9d7e4a86c7f904a4ac3 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql55.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.mysql55.create.engine.sql @@ -62,105 +62,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; -create table ACT_RU_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp NULL, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_TIMER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp NULL, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_SUSPENDED_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_DEADLETTER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp NULL, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp NULL, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - -create table ACT_RU_HISTORY_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - LOCK_EXP_TIME_ timestamp NULL, - LOCK_OWNER_ varchar(255), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - ADV_HANDLER_CFG_ID_ varchar(64), - TENANT_ID_ varchar(255) default '', - CREATE_TIME_ timestamp NULL, - primary key (ID_) -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; - create table ACT_RE_PROCDEF ( ID_ varchar(64) not null, REV_ integer, @@ -310,11 +211,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -330,11 +226,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -350,11 +241,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION foreign key (EXECUTION_ID_) @@ -370,11 +256,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC foreign key (EXECUTION_ID_) diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.oracle.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.oracle.create.engine.sql index 347b1e63bc77207c35f06ae0540f4ff85dba3958..722d67e4c3bc18f1b958eb9a053c229b2b4b991d 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.oracle.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.oracle.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ); -create table ACT_RU_JOB ( - ID_ NVARCHAR2(64) NOT NULL, - REV_ INTEGER, - TYPE_ NVARCHAR2(255) NOT NULL, - LOCK_EXP_TIME_ TIMESTAMP(6), - LOCK_OWNER_ NVARCHAR2(255), - EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), - EXECUTION_ID_ NVARCHAR2(64), - PROCESS_INSTANCE_ID_ NVARCHAR2(64), - PROC_DEF_ID_ NVARCHAR2(64), - RETRIES_ INTEGER, - EXCEPTION_STACK_ID_ NVARCHAR2(64), - EXCEPTION_MSG_ NVARCHAR2(2000), - DUEDATE_ TIMESTAMP(6), - REPEAT_ NVARCHAR2(255), - HANDLER_TYPE_ NVARCHAR2(255), - HANDLER_CFG_ NVARCHAR2(2000), - CREATE_TIME_ TIMESTAMP(6), - TENANT_ID_ NVARCHAR2(255) DEFAULT '', - primary key (ID_) -); - -create table ACT_RU_TIMER_JOB ( - ID_ NVARCHAR2(64) NOT NULL, - REV_ INTEGER, - TYPE_ NVARCHAR2(255) NOT NULL, - LOCK_EXP_TIME_ TIMESTAMP(6), - LOCK_OWNER_ NVARCHAR2(255), - EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), - EXECUTION_ID_ NVARCHAR2(64), - PROCESS_INSTANCE_ID_ NVARCHAR2(64), - PROC_DEF_ID_ NVARCHAR2(64), - RETRIES_ INTEGER, - EXCEPTION_STACK_ID_ NVARCHAR2(64), - EXCEPTION_MSG_ NVARCHAR2(2000), - DUEDATE_ TIMESTAMP(6), - REPEAT_ NVARCHAR2(255), - HANDLER_TYPE_ NVARCHAR2(255), - HANDLER_CFG_ NVARCHAR2(2000), - CREATE_TIME_ TIMESTAMP(6), - TENANT_ID_ NVARCHAR2(255) DEFAULT '', - primary key (ID_) -); - -create table ACT_RU_SUSPENDED_JOB ( - ID_ NVARCHAR2(64) NOT NULL, - REV_ INTEGER, - TYPE_ NVARCHAR2(255) NOT NULL, - EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), - EXECUTION_ID_ NVARCHAR2(64), - PROCESS_INSTANCE_ID_ NVARCHAR2(64), - PROC_DEF_ID_ NVARCHAR2(64), - RETRIES_ INTEGER, - EXCEPTION_STACK_ID_ NVARCHAR2(64), - EXCEPTION_MSG_ NVARCHAR2(2000), - DUEDATE_ TIMESTAMP(6), - REPEAT_ NVARCHAR2(255), - HANDLER_TYPE_ NVARCHAR2(255), - HANDLER_CFG_ NVARCHAR2(2000), - CREATE_TIME_ TIMESTAMP(6), - TENANT_ID_ NVARCHAR2(255) DEFAULT '', - primary key (ID_) -); - -create table ACT_RU_DEADLETTER_JOB ( - ID_ NVARCHAR2(64) NOT NULL, - REV_ INTEGER, - TYPE_ NVARCHAR2(255) NOT NULL, - EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), - EXECUTION_ID_ NVARCHAR2(64), - PROCESS_INSTANCE_ID_ NVARCHAR2(64), - PROC_DEF_ID_ NVARCHAR2(64), - EXCEPTION_STACK_ID_ NVARCHAR2(64), - EXCEPTION_MSG_ NVARCHAR2(2000), - DUEDATE_ TIMESTAMP(6), - REPEAT_ NVARCHAR2(255), - HANDLER_TYPE_ NVARCHAR2(255), - HANDLER_CFG_ NVARCHAR2(2000), - CREATE_TIME_ TIMESTAMP(6), - TENANT_ID_ NVARCHAR2(255) DEFAULT '', - primary key (ID_) -); - -create table ACT_RU_HISTORY_JOB ( - ID_ NVARCHAR2(64) NOT NULL, - REV_ INTEGER, - LOCK_EXP_TIME_ TIMESTAMP(6), - LOCK_OWNER_ NVARCHAR2(255), - RETRIES_ INTEGER, - EXCEPTION_STACK_ID_ NVARCHAR2(64), - EXCEPTION_MSG_ NVARCHAR2(2000), - HANDLER_TYPE_ NVARCHAR2(255), - HANDLER_CFG_ NVARCHAR2(2000), - ADV_HANDLER_CFG_ID_ NVARCHAR2(64), - CREATE_TIME_ TIMESTAMP(6), - TENANT_ID_ NVARCHAR2(255) DEFAULT '', - primary key (ID_) -); - create table ACT_RE_PROCDEF ( ID_ NVARCHAR2(64) NOT NULL, REV_ INTEGER, @@ -327,12 +228,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_JOB_EXCEPTION on ACT_RU_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_TJOB_EXECUTION_ID on ACT_RU_TIMER_JOB(EXECUTION_ID_); alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TJOB_EXECUTION @@ -351,12 +246,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_TJOB_EXCEPTION on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TJOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_SJOB_EXECUTION_ID on ACT_RU_SUSPENDED_JOB(EXECUTION_ID_); alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SJOB_EXECUTION @@ -375,12 +264,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_SJOB_EXCEPTION on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SJOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_DJOB_EXECUTION_ID on ACT_RU_DEADLETTER_JOB(EXECUTION_ID_); alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DJOB_EXECUTION @@ -399,12 +282,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_DJOB_EXCEPTION on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DJOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_EVENT_SUBSCR on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_); alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.postgres.create.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.postgres.create.engine.sql index 156b3f359cbb03c04a9c3cbd08bef9169f370f93..8be5b9acb452a7d1a744393e98faf5cbf4a25bf2 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.postgres.create.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/create/flowable.postgres.create.engine.sql @@ -63,105 +63,6 @@ create table ACT_RU_EXECUTION ( primary key (ID_) ); -create table ACT_RU_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_TIMER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_SUSPENDED_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_DEADLETTER_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - TYPE_ varchar(255) NOT NULL, - EXCLUSIVE_ boolean, - EXECUTION_ID_ varchar(64), - PROCESS_INSTANCE_ID_ varchar(64), - PROC_DEF_ID_ varchar(64), - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - DUEDATE_ timestamp, - REPEAT_ varchar(255), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - -create table ACT_RU_HISTORY_JOB ( - ID_ varchar(64) NOT NULL, - REV_ integer, - LOCK_EXP_TIME_ timestamp, - LOCK_OWNER_ varchar(255), - RETRIES_ integer, - EXCEPTION_STACK_ID_ varchar(64), - EXCEPTION_MSG_ varchar(4000), - HANDLER_TYPE_ varchar(255), - HANDLER_CFG_ varchar(4000), - ADV_HANDLER_CFG_ID_ varchar(64), - CREATE_TIME_ timestamp, - TENANT_ID_ varchar(255) default '', - primary key (ID_) -); - create table ACT_RE_PROCDEF ( ID_ varchar(64) NOT NULL, REV_ integer, @@ -326,12 +227,6 @@ alter table ACT_RU_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_JOB_EXCEPTION on ACT_RU_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_JOB - add constraint ACT_FK_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_TIMER_JOB_EXECUTION_ID on ACT_RU_TIMER_JOB(EXECUTION_ID_); alter table ACT_RU_TIMER_JOB add constraint ACT_FK_TIMER_JOB_EXECUTION @@ -350,12 +245,6 @@ alter table ACT_RU_TIMER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_TIMER_JOB_EXCEPTION on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_TIMER_JOB - add constraint ACT_FK_TIMER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_SUSPENDED_JOB_EXECUTION_ID on ACT_RU_SUSPENDED_JOB(EXECUTION_ID_); alter table ACT_RU_SUSPENDED_JOB add constraint ACT_FK_SUSPENDED_JOB_EXECUTION @@ -374,12 +263,6 @@ alter table ACT_RU_SUSPENDED_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_SUSPENDED_JOB_EXCEPTION on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_SUSPENDED_JOB - add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_DEADLETTER_JOB_EXECUTION_ID on ACT_RU_DEADLETTER_JOB(EXECUTION_ID_); alter table ACT_RU_DEADLETTER_JOB add constraint ACT_FK_DEADLETTER_JOB_EXECUTION @@ -398,12 +281,6 @@ alter table ACT_RU_DEADLETTER_JOB foreign key (PROC_DEF_ID_) references ACT_RE_PROCDEF (ID_); -create index ACT_IDX_DEADLETTER_JOB_EXCEPTION on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); -alter table ACT_RU_DEADLETTER_JOB - add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION - foreign key (EXCEPTION_STACK_ID_) - references ACT_GE_BYTEARRAY (ID_); - create index ACT_IDX_EVENT_SUBSCR on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_); alter table ACT_RU_EVENT_SUBSCR add constraint ACT_FK_EVENT_EXEC diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.db2.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.db2.drop.engine.sql index df1bc83487f4888d9df996f2cee4e7ba1a810176..9465dcc80b90457dfec166fc4ad260c2431ba863 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.db2.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.db2.drop.engine.sql @@ -49,9 +49,6 @@ alter table ACT_RU_JOB alter table ACT_RU_JOB drop foreign key ACT_FK_JOB_PROC_DEF; -alter table ACT_RU_JOB - drop foreign key ACT_FK_JOB_EXCEPTION; - alter table ACT_RU_TIMER_JOB drop foreign key ACT_FK_TIMER_JOB_EXECUTION; @@ -61,9 +58,6 @@ alter table ACT_RU_TIMER_JOB alter table ACT_RU_TIMER_JOB drop foreign key ACT_FK_TIMER_JOB_PROC_DEF; -alter table ACT_RU_TIMER_JOB - drop foreign key ACT_FK_TIMER_JOB_EXCEPTION; - alter table ACT_RU_SUSPENDED_JOB drop foreign key ACT_FK_SUSPENDED_JOB_EXECUTION; @@ -73,9 +67,6 @@ alter table ACT_RU_SUSPENDED_JOB alter table ACT_RU_SUSPENDED_JOB drop foreign key ACT_FK_SUSPENDED_JOB_PROC_DEF; -alter table ACT_RU_SUSPENDED_JOB - drop foreign key ACT_FK_SUSPENDED_JOB_EXCEPTION; - alter table ACT_RU_DEADLETTER_JOB drop foreign key ACT_FK_DEADLETTER_JOB_EXECUTION; @@ -85,9 +76,6 @@ alter table ACT_RU_DEADLETTER_JOB alter table ACT_RU_DEADLETTER_JOB drop foreign key ACT_FK_DEADLETTER_JOB_PROC_DEF; -alter table ACT_RU_DEADLETTER_JOB - drop foreign key ACT_FK_DEADLETTER_JOB_EXCEPTION; - alter table ACT_RU_EVENT_SUBSCR drop foreign key ACT_FK_EVENT_EXEC; @@ -113,11 +101,6 @@ drop table ACT_RE_DEPLOYMENT; drop table ACT_RE_MODEL; drop table ACT_RE_PROCDEF; drop table ACT_RU_EXECUTION; -drop table ACT_RU_JOB; -drop table ACT_RU_TIMER_JOB; -drop table ACT_RU_SUSPENDED_JOB; -drop table ACT_RU_DEADLETTER_JOB; -drop table ACT_RU_HISTORY_JOB; drop table ACT_RU_EVENT_SUBSCR; drop table ACT_EVT_LOG; drop table ACT_PROCDEF_INFO; diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.h2.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.h2.drop.engine.sql index 56bfe62ddb24f01320355efb21dd257752639931..a7e829be26b633b7b053f77b75f6cc97ca3435c9 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.h2.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.h2.drop.engine.sql @@ -1,11 +1,6 @@ drop table if exists ACT_RE_DEPLOYMENT cascade constraints; drop table if exists ACT_RE_MODEL cascade constraints; drop table if exists ACT_RU_EXECUTION cascade constraints; -drop table if exists ACT_RU_JOB cascade constraints; -drop table if exists ACT_RU_TIMER_JOB cascade constraints; -drop table if exists ACT_RU_SUSPENDED_JOB cascade constraints; -drop table if exists ACT_RU_DEADLETTER_JOB cascade constraints; -drop table if exists ACT_RU_HISTORY_JOB cascade constraints; drop table if exists ACT_RE_PROCDEF cascade constraints; drop table if exists ACT_RU_EVENT_SUBSCR cascade constraints; drop table if exists ACT_EVT_LOG cascade constraints; diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.hsql.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.hsql.drop.engine.sql index e1e4f14302806d3983ab6d45c479e54e07a3d6a4..86e3c13de612996b313e72b791433fb4ff9c27d6 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.hsql.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.hsql.drop.engine.sql @@ -1,11 +1,6 @@ drop table if exists ACT_RE_DEPLOYMENT cascade; drop table if exists ACT_RE_MODEL cascade; drop table if exists ACT_RU_EXECUTION cascade; -drop table if exists ACT_RU_JOB cascade; -drop table if exists ACT_RU_TIMER_JOB cascade; -drop table if exists ACT_RU_SUSPENDED_JOB cascade; -drop table if exists ACT_RU_DEADLETTER_JOB cascade; -drop table if exists ACT_RU_HISTORY_JOB cascade; drop table if exists ACT_RE_PROCDEF cascade; drop table if exists ACT_RU_EVENT_SUBSCR cascade; drop table if exists ACT_EVT_LOG cascade; diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mssql.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mssql.drop.engine.sql index 980a83ba56d1124b7a093357c589b7d94baca4e5..caf3695e7aa53bad92677feb251686578fcfe6de 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mssql.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mssql.drop.engine.sql @@ -19,19 +19,15 @@ if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = ' if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') alter table ACT_RU_JOB drop constraint ACT_FK_JOB_EXECUTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') alter table ACT_RU_JOB drop constraint ACT_FK_JOB_PROCESS_INSTANCE; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') alter table ACT_RU_JOB drop constraint ACT_FK_JOB_PROC_DEF; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') alter table ACT_RU_JOB drop constraint ACT_FK_JOB_EXCEPTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') alter table ACT_RU_TIMER_JOB drop constraint ACT_FK_TIMER_JOB_EXECUTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') alter table ACT_RU_TIMER_JOB drop constraint ACT_FK_TIMER_JOB_PROCESS_INSTANCE; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') alter table ACT_RU_TIMER_JOB drop constraint ACT_FK_TIMER_JOB_PROC_DEF; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') alter table ACT_RU_TIMER_JOB drop constraint ACT_FK_TIMER_JOB_EXCEPTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') alter table ACT_RU_SUSPENDED_JOB drop constraint ACT_FK_SUSPENDED_JOB_EXECUTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') alter table ACT_RU_SUSPENDED_JOB drop constraint ACT_FK_SUSPENDED_JOB_PROCESS_INSTANCE; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') alter table ACT_RU_SUSPENDED_JOB drop constraint ACT_FK_SUSPENDED_JOB_PROC_DEF; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') alter table ACT_RU_SUSPENDED_JOB drop constraint ACT_FK_SUSPENDED_JOB_EXCEPTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') alter table ACT_RU_DEADLETTER_JOB drop constraint ACT_FK_DEADLETTER_JOB_EXECUTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') alter table ACT_RU_DEADLETTER_JOB drop constraint ACT_FK_DEADLETTER_JOB_PROCESS_INSTANCE; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') alter table ACT_RU_DEADLETTER_JOB drop constraint ACT_FK_DEADLETTER_JOB_PROC_DEF; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') alter table ACT_RU_DEADLETTER_JOB drop constraint ACT_FK_DEADLETTER_JOB_EXCEPTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_EVENT_SUBSCR') alter table ACT_RU_EVENT_SUBSCR drop constraint ACT_FK_EVENT_EXEC; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RE_MODEL') alter table ACT_RE_MODEL drop constraint ACT_FK_MODEL_SOURCE; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RE_MODEL') alter table ACT_RE_MODEL drop constraint ACT_FK_MODEL_SOURCE_EXTRA; @@ -46,10 +42,5 @@ if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = ' if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RE_MODEL') drop table ACT_RE_MODEL; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_EXECUTION') drop table ACT_RU_EXECUTION; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_EVENT_SUBSCR') drop table ACT_RU_EVENT_SUBSCR; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') drop table ACT_RU_JOB; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') drop table ACT_RU_TIMER_JOB; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') drop table ACT_RU_SUSPENDED_JOB; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') drop table ACT_RU_DEADLETTER_JOB; -if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_HISTORY_JOB') drop table ACT_RU_HISTORY_JOB; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_EVT_LOG') drop table ACT_EVT_LOG; if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_PROCDEF_INFO') drop table ACT_PROCDEF_INFO; \ No newline at end of file diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mysql.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mysql.drop.engine.sql index 6eeec7c291a107bcb358545398aff914284aa3da..1facdb02b228fd0904abadb587ac518e226ab180 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mysql.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.mysql.drop.engine.sql @@ -50,9 +50,6 @@ alter table ACT_RU_JOB alter table ACT_RU_JOB drop foreign key ACT_FK_JOB_PROC_DEF; -alter table ACT_RU_JOB - drop foreign key ACT_FK_JOB_EXCEPTION; - alter table ACT_RU_TIMER_JOB drop foreign key ACT_FK_TIMER_JOB_EXECUTION; @@ -62,9 +59,6 @@ alter table ACT_RU_TIMER_JOB alter table ACT_RU_TIMER_JOB drop foreign key ACT_FK_TIMER_JOB_PROC_DEF; -alter table ACT_RU_TIMER_JOB - drop foreign key ACT_FK_TIMER_JOB_EXCEPTION; - alter table ACT_RU_SUSPENDED_JOB drop foreign key ACT_FK_SUSPENDED_JOB_EXECUTION; @@ -74,9 +68,6 @@ alter table ACT_RU_SUSPENDED_JOB alter table ACT_RU_SUSPENDED_JOB drop foreign key ACT_FK_SUSPENDED_JOB_PROC_DEF; -alter table ACT_RU_SUSPENDED_JOB - drop foreign key ACT_FK_SUSPENDED_JOB_EXCEPTION; - alter table ACT_RU_DEADLETTER_JOB drop foreign key ACT_FK_DEADLETTER_JOB_EXECUTION; @@ -86,9 +77,6 @@ alter table ACT_RU_DEADLETTER_JOB alter table ACT_RU_DEADLETTER_JOB drop foreign key ACT_FK_DEADLETTER_JOB_PROC_DEF; -alter table ACT_RU_DEADLETTER_JOB - drop foreign key ACT_FK_DEADLETTER_JOB_EXCEPTION; - alter table ACT_RU_EVENT_SUBSCR drop FOREIGN KEY ACT_FK_EVENT_EXEC; @@ -114,11 +102,6 @@ drop table if exists ACT_RE_DEPLOYMENT; drop table if exists ACT_RE_MODEL; drop table if exists ACT_RE_PROCDEF; drop table if exists ACT_RU_EXECUTION; -drop table if exists ACT_RU_JOB; -drop table if exists ACT_RU_TIMER_JOB; -drop table if exists ACT_RU_SUSPENDED_JOB; -drop table if exists ACT_RU_DEADLETTER_JOB; -drop table if exists ACT_RU_HISTORY_JOB; drop table if exists ACT_RU_EVENT_SUBSCR; drop table if exists ACT_EVT_LOG; drop table if exists ACT_PROCDEF_INFO; \ No newline at end of file diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.oracle.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.oracle.drop.engine.sql index 661f9e68a5eeba0e18067cce1746fc7b2352a197..d71d5921b4dc01b152d7b3c3dbd735f788543e3d 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.oracle.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.oracle.drop.engine.sql @@ -11,19 +11,15 @@ drop index ACT_IDX_VAR_PROCINST; drop index ACT_IDX_JOB_EXECUTION_ID; drop index ACT_IDX_JOB_PROC_INST_ID; drop index ACT_IDX_JOB_PROC_DEF_ID; -drop index ACT_IDX_JOB_EXCEPTION; drop index ACT_IDX_TJOB_EXECUTION_ID; drop index ACT_IDX_TJOB_PROC_INST_ID; drop index ACT_IDX_TJOB_PROC_DEF_ID; -drop index ACT_IDX_TJOB_EXCEPTION; drop index ACT_IDX_SJOB_EXECUTION_ID; drop index ACT_IDX_SJOB_PROC_INST_ID; drop index ACT_IDX_SJOB_PROC_DEF_ID; -drop index ACT_IDX_SJOB_EXCEPTION; drop index ACT_IDX_DJOB_EXECUTION_ID; drop index ACT_IDX_DJOB_PROC_INST_ID; drop index ACT_IDX_DJOB_PROC_DEF_ID; -drop index ACT_IDX_DJOB_EXCEPTION; drop index ACT_IDX_MODEL_SOURCE; drop index ACT_IDX_MODEL_SOURCE_EXTRA; drop index ACT_IDX_MODEL_DEPLOYMENT; @@ -80,9 +76,6 @@ alter table ACT_RU_JOB alter table ACT_RU_JOB drop CONSTRAINT ACT_FK_JOB_PROC_DEF; -alter table ACT_RU_JOB - drop CONSTRAINT ACT_FK_JOB_EXCEPTION; - alter table ACT_RU_TIMER_JOB drop CONSTRAINT ACT_FK_TJOB_EXECUTION; @@ -92,9 +85,6 @@ alter table ACT_RU_TIMER_JOB alter table ACT_RU_TIMER_JOB drop CONSTRAINT ACT_FK_TJOB_PROC_DEF; -alter table ACT_RU_TIMER_JOB - drop CONSTRAINT ACT_FK_TJOB_EXCEPTION; - alter table ACT_RU_SUSPENDED_JOB drop CONSTRAINT ACT_FK_SJOB_EXECUTION; @@ -104,9 +94,6 @@ alter table ACT_RU_SUSPENDED_JOB alter table ACT_RU_SUSPENDED_JOB drop CONSTRAINT ACT_FK_SJOB_PROC_DEF; -alter table ACT_RU_SUSPENDED_JOB - drop CONSTRAINT ACT_FK_SJOB_EXCEPTION; - alter table ACT_RU_DEADLETTER_JOB drop CONSTRAINT ACT_FK_DJOB_EXECUTION; @@ -116,9 +103,6 @@ alter table ACT_RU_DEADLETTER_JOB alter table ACT_RU_DEADLETTER_JOB drop CONSTRAINT ACT_FK_DJOB_PROC_DEF; -alter table ACT_RU_DEADLETTER_JOB - drop CONSTRAINT ACT_FK_DJOB_EXCEPTION; - alter table ACT_RU_EVENT_SUBSCR drop CONSTRAINT ACT_FK_EVENT_EXEC; @@ -152,11 +136,6 @@ drop table ACT_RE_DEPLOYMENT; drop table ACT_RE_MODEL; drop table ACT_RE_PROCDEF; drop table ACT_RU_EXECUTION; -drop table ACT_RU_JOB; -drop table ACT_RU_TIMER_JOB; -drop table ACT_RU_SUSPENDED_JOB; -drop table ACT_RU_DEADLETTER_JOB; -drop table ACT_RU_HISTORY_JOB; drop table ACT_RU_EVENT_SUBSCR; drop sequence act_evt_log_seq; diff --git a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.postgres.drop.engine.sql b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.postgres.drop.engine.sql index 3f23b73d107d88efd2f4ec315dc5bfdd7dc63d85..78b04b7920c2acbb1641b891304f2c0e067f4d94 100644 --- a/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.postgres.drop.engine.sql +++ b/modules/flowable-engine/src/main/resources/org/flowable/db/drop/flowable.postgres.drop.engine.sql @@ -2,11 +2,6 @@ drop table if exists ACT_RE_DEPLOYMENT cascade; drop table if exists ACT_RE_MODEL cascade; drop table if exists ACT_RE_PROCDEF cascade; drop table if exists ACT_RU_EXECUTION cascade; -drop table if exists ACT_RU_JOB cascade; -drop table if exists ACT_RU_TIMER_JOB cascade; -drop table if exists ACT_RU_SUSPENDED_JOB cascade; -drop table if exists ACT_RU_DEADLETTER_JOB cascade; -drop table if exists ACT_RU_HISTORY_JOB cascade; drop table if exists ACT_RU_EVENT_SUBSCR cascade; drop table if exists ACT_EVT_LOG cascade; drop table if exists ACT_PROCDEF_INFO cascade; \ No newline at end of file diff --git a/modules/flowable-engine/src/test/java/org/flowable/examples/mgmt/ManagementServiceTest.java b/modules/flowable-engine/src/test/java/org/flowable/examples/mgmt/ManagementServiceTest.java index c0d1edd9731712ae49444b0795fba38073dbf23a..8429d9cecad53ac19d0ff40e8695bb2b5ff06afe 100644 --- a/modules/flowable-engine/src/test/java/org/flowable/examples/mgmt/ManagementServiceTest.java +++ b/modules/flowable-engine/src/test/java/org/flowable/examples/mgmt/ManagementServiceTest.java @@ -50,7 +50,7 @@ public class ManagementServiceTest extends PluggableFlowableTestCase { }); - assertEquals(new Long(9), tableCount.get(tablePrefix + "ACT_GE_PROPERTY")); + assertEquals(new Long(10), tableCount.get(tablePrefix + "ACT_GE_PROPERTY")); assertEquals(new Long(0), tableCount.get(tablePrefix + "ACT_GE_BYTEARRAY")); assertEquals(new Long(0), tableCount.get(tablePrefix + "ACT_RE_DEPLOYMENT")); assertEquals(new Long(0), tableCount.get(tablePrefix + "ACT_RU_EXECUTION")); diff --git a/modules/flowable-job-service/src/main/java/org/flowable/job/service/impl/db/JobDbSchemaManager.java b/modules/flowable-job-service/src/main/java/org/flowable/job/service/impl/db/JobDbSchemaManager.java new file mode 100644 index 0000000000000000000000000000000000000000..173e00224f7b8ea0ebe5f97e90717e6b97615154 --- /dev/null +++ b/modules/flowable-job-service/src/main/java/org/flowable/job/service/impl/db/JobDbSchemaManager.java @@ -0,0 +1,35 @@ +/* Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.flowable.job.service.impl.db; + +import org.flowable.engine.common.impl.db.ServiceSqlScriptBasedDbSchemaManager; + +/** + * @author Joram Barrez + */ +public class JobDbSchemaManager extends ServiceSqlScriptBasedDbSchemaManager { + + private static final String JOB_TABLE = "ACT_RU_JOB"; + private static final String JOB_VERSION_PROPERTY = "job.schema.version"; + private static final String SCHEMA_COMPONENT = "job"; + + public JobDbSchemaManager() { + super(JOB_TABLE, SCHEMA_COMPONENT, null, JOB_VERSION_PROPERTY); + } + + @Override + protected String getResourcesRootDirectory() { + return "org/flowable/job/db/"; + } + +} diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.db2.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.db2.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..ba6f210ff26de8530c932899fe3726c69dd16559 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.db2.create.job.sql @@ -0,0 +1,125 @@ +create table ACT_RU_JOB ( + ID_ varchar(64) not null, + REV_ integer, + TYPE_ varchar(255) not null, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_TIMER_JOB ( + ID_ varchar(64) not null, + REV_ integer, + TYPE_ varchar(255) not null, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_SUSPENDED_JOB ( + ID_ varchar(64) not null, + REV_ integer, + TYPE_ varchar(255) not null, + EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_DEADLETTER_JOB ( + ID_ varchar(64) not null, + REV_ integer, + TYPE_ varchar(255) not null, + EXCLUSIVE_ smallint check(EXCLUSIVE_ in (1,0)), + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_HISTORY_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + ADV_HANDLER_CFG_ID_ varchar(64), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create index ACT_IDX_JOB_EXCEPTION_STACK_ID on ACT_RU_JOB(EXCEPTION_STACK_ID_); +create index ACT_IDX_TIMER_JOB_EXCEPTION_STACK_ID on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); +create index ACT_IDX_SUSPENDED_JOB_EXCEPTION_STACK_ID on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); +create index ACT_IDX_DEADLETTER_JOB_EXCEPTION_STACK_ID on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); + +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.h2.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.h2.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..9d4e619d10e479b2b94f2b11542cf2973da8c8f2 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.h2.create.job.sql @@ -0,0 +1,120 @@ +create table ACT_RU_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_TIMER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_SUSPENDED_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_DEADLETTER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_HISTORY_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + ADV_HANDLER_CFG_ID_ varchar(64), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.hsql.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.hsql.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..9d4e619d10e479b2b94f2b11542cf2973da8c8f2 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.hsql.create.job.sql @@ -0,0 +1,120 @@ +create table ACT_RU_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_TIMER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_SUSPENDED_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_DEADLETTER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_HISTORY_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + ADV_HANDLER_CFG_ID_ varchar(64), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY; + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mssql.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mssql.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..fd3fcca76e844387c8bdc6d95290de4907198bc4 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mssql.create.job.sql @@ -0,0 +1,125 @@ +create table ACT_RU_JOB ( + ID_ nvarchar(64) NOT NULL, + REV_ int, + TYPE_ nvarchar(255) NOT NULL, + LOCK_EXP_TIME_ datetime, + LOCK_OWNER_ nvarchar(255), + EXCLUSIVE_ bit, + EXECUTION_ID_ nvarchar(64), + PROCESS_INSTANCE_ID_ nvarchar(64), + PROC_DEF_ID_ nvarchar(64), + RETRIES_ int, + EXCEPTION_STACK_ID_ nvarchar(64), + EXCEPTION_MSG_ nvarchar(4000), + DUEDATE_ datetime NULL, + REPEAT_ nvarchar(255), + HANDLER_TYPE_ nvarchar(255), + HANDLER_CFG_ nvarchar(4000), + CREATE_TIME_ datetime2 NULL, + TENANT_ID_ nvarchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_TIMER_JOB ( + ID_ nvarchar(64) NOT NULL, + REV_ int, + TYPE_ nvarchar(255) NOT NULL, + LOCK_EXP_TIME_ datetime, + LOCK_OWNER_ nvarchar(255), + EXCLUSIVE_ bit, + EXECUTION_ID_ nvarchar(64), + PROCESS_INSTANCE_ID_ nvarchar(64), + PROC_DEF_ID_ nvarchar(64), + RETRIES_ int, + EXCEPTION_STACK_ID_ nvarchar(64), + EXCEPTION_MSG_ nvarchar(4000), + DUEDATE_ datetime NULL, + REPEAT_ nvarchar(255), + HANDLER_TYPE_ nvarchar(255), + HANDLER_CFG_ nvarchar(4000), + CREATE_TIME_ datetime2 NULL, + TENANT_ID_ nvarchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_SUSPENDED_JOB ( + ID_ nvarchar(64) NOT NULL, + REV_ int, + TYPE_ nvarchar(255) NOT NULL, + EXCLUSIVE_ bit, + EXECUTION_ID_ nvarchar(64), + PROCESS_INSTANCE_ID_ nvarchar(64), + PROC_DEF_ID_ nvarchar(64), + RETRIES_ int, + EXCEPTION_STACK_ID_ nvarchar(64), + EXCEPTION_MSG_ nvarchar(4000), + DUEDATE_ datetime NULL, + REPEAT_ nvarchar(255), + HANDLER_TYPE_ nvarchar(255), + HANDLER_CFG_ nvarchar(4000), + CREATE_TIME_ datetime2 NULL, + TENANT_ID_ nvarchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_DEADLETTER_JOB ( + ID_ nvarchar(64) NOT NULL, + REV_ int, + TYPE_ nvarchar(255) NOT NULL, + EXCLUSIVE_ bit, + EXECUTION_ID_ nvarchar(64), + PROCESS_INSTANCE_ID_ nvarchar(64), + PROC_DEF_ID_ nvarchar(64), + EXCEPTION_STACK_ID_ nvarchar(64), + EXCEPTION_MSG_ nvarchar(4000), + DUEDATE_ datetime NULL, + REPEAT_ nvarchar(255), + HANDLER_TYPE_ nvarchar(255), + HANDLER_CFG_ nvarchar(4000), + CREATE_TIME_ datetime2 NULL, + TENANT_ID_ nvarchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_HISTORY_JOB ( + ID_ nvarchar(64) NOT NULL, + REV_ int, + LOCK_EXP_TIME_ datetime NULL, + LOCK_OWNER_ nvarchar(255), + RETRIES_ int, + EXCEPTION_STACK_ID_ nvarchar(64), + EXCEPTION_MSG_ nvarchar(4000), + HANDLER_TYPE_ nvarchar(255), + HANDLER_CFG_ nvarchar(4000), + ADV_HANDLER_CFG_ID_ nvarchar(64), + CREATE_TIME_ datetime2 NULL, + TENANT_ID_ nvarchar(255) default '', + primary key (ID_) +); + +create index ACT_IDX_JOB_EXCEPTION_STACK_ID on ACT_RU_JOB(EXCEPTION_STACK_ID_); +create index ACT_IDX_TIMER_JOB_EXCEPTION_STACK_ID on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); +create index ACT_IDX_SUSPENDED_JOB_EXCEPTION_STACK_ID on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); +create index ACT_IDX_DEADLETTER_JOB_EXCEPTION_STACK_ID on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); + +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mysql.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mysql.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..9dc857e42ad316ddb28ecc45a60933f27ea1ec07 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mysql.create.job.sql @@ -0,0 +1,120 @@ +create table ACT_RU_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp(3) NULL, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp(3) NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp(3) NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_TIMER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp(3) NULL, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp(3) NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp(3) NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_SUSPENDED_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp(3) NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp(3) NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_DEADLETTER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp(3) NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp(3) NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_HISTORY_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + LOCK_EXP_TIME_ timestamp(3) NULL, + LOCK_OWNER_ varchar(255), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + ADV_HANDLER_CFG_ID_ varchar(64), + CREATE_TIME_ timestamp(3) NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mysql55.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mysql55.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..eb4dcd8f953e98504ee5916d359ec51469445c48 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.mysql55.create.job.sql @@ -0,0 +1,120 @@ +create table ACT_RU_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp NULL, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_TIMER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp NULL, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_SUSPENDED_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_DEADLETTER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp NULL, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp NULL, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +create table ACT_RU_HISTORY_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + LOCK_EXP_TIME_ timestamp NULL, + LOCK_OWNER_ varchar(255), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + ADV_HANDLER_CFG_ID_ varchar(64), + TENANT_ID_ varchar(255) default '', + CREATE_TIME_ timestamp NULL, + primary key (ID_) +) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE utf8_bin; + +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.oracle.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.oracle.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..92ec1d3772f45dceb5013399a84d2aab388bb1e4 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.oracle.create.job.sql @@ -0,0 +1,124 @@ +create table ACT_RU_JOB ( + ID_ NVARCHAR2(64) NOT NULL, + REV_ INTEGER, + TYPE_ NVARCHAR2(255) NOT NULL, + LOCK_EXP_TIME_ TIMESTAMP(6), + LOCK_OWNER_ NVARCHAR2(255), + EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), + EXECUTION_ID_ NVARCHAR2(64), + PROCESS_INSTANCE_ID_ NVARCHAR2(64), + PROC_DEF_ID_ NVARCHAR2(64), + RETRIES_ INTEGER, + EXCEPTION_STACK_ID_ NVARCHAR2(64), + EXCEPTION_MSG_ NVARCHAR2(2000), + DUEDATE_ TIMESTAMP(6), + REPEAT_ NVARCHAR2(255), + HANDLER_TYPE_ NVARCHAR2(255), + HANDLER_CFG_ NVARCHAR2(2000), + CREATE_TIME_ TIMESTAMP(6), + TENANT_ID_ NVARCHAR2(255) DEFAULT '', + primary key (ID_) +); + +create table ACT_RU_TIMER_JOB ( + ID_ NVARCHAR2(64) NOT NULL, + REV_ INTEGER, + TYPE_ NVARCHAR2(255) NOT NULL, + LOCK_EXP_TIME_ TIMESTAMP(6), + LOCK_OWNER_ NVARCHAR2(255), + EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), + EXECUTION_ID_ NVARCHAR2(64), + PROCESS_INSTANCE_ID_ NVARCHAR2(64), + PROC_DEF_ID_ NVARCHAR2(64), + RETRIES_ INTEGER, + EXCEPTION_STACK_ID_ NVARCHAR2(64), + EXCEPTION_MSG_ NVARCHAR2(2000), + DUEDATE_ TIMESTAMP(6), + REPEAT_ NVARCHAR2(255), + HANDLER_TYPE_ NVARCHAR2(255), + HANDLER_CFG_ NVARCHAR2(2000), + CREATE_TIME_ TIMESTAMP(6), + TENANT_ID_ NVARCHAR2(255) DEFAULT '', + primary key (ID_) +); + +create table ACT_RU_SUSPENDED_JOB ( + ID_ NVARCHAR2(64) NOT NULL, + REV_ INTEGER, + TYPE_ NVARCHAR2(255) NOT NULL, + EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), + EXECUTION_ID_ NVARCHAR2(64), + PROCESS_INSTANCE_ID_ NVARCHAR2(64), + PROC_DEF_ID_ NVARCHAR2(64), + RETRIES_ INTEGER, + EXCEPTION_STACK_ID_ NVARCHAR2(64), + EXCEPTION_MSG_ NVARCHAR2(2000), + DUEDATE_ TIMESTAMP(6), + REPEAT_ NVARCHAR2(255), + HANDLER_TYPE_ NVARCHAR2(255), + HANDLER_CFG_ NVARCHAR2(2000), + CREATE_TIME_ TIMESTAMP(6), + TENANT_ID_ NVARCHAR2(255) DEFAULT '', + primary key (ID_) +); + +create table ACT_RU_DEADLETTER_JOB ( + ID_ NVARCHAR2(64) NOT NULL, + REV_ INTEGER, + TYPE_ NVARCHAR2(255) NOT NULL, + EXCLUSIVE_ NUMBER(1,0) CHECK (EXCLUSIVE_ IN (1,0)), + EXECUTION_ID_ NVARCHAR2(64), + PROCESS_INSTANCE_ID_ NVARCHAR2(64), + PROC_DEF_ID_ NVARCHAR2(64), + EXCEPTION_STACK_ID_ NVARCHAR2(64), + EXCEPTION_MSG_ NVARCHAR2(2000), + DUEDATE_ TIMESTAMP(6), + REPEAT_ NVARCHAR2(255), + HANDLER_TYPE_ NVARCHAR2(255), + HANDLER_CFG_ NVARCHAR2(2000), + CREATE_TIME_ TIMESTAMP(6), + TENANT_ID_ NVARCHAR2(255) DEFAULT '', + primary key (ID_) +); + +create table ACT_RU_HISTORY_JOB ( + ID_ NVARCHAR2(64) NOT NULL, + REV_ INTEGER, + LOCK_EXP_TIME_ TIMESTAMP(6), + LOCK_OWNER_ NVARCHAR2(255), + RETRIES_ INTEGER, + EXCEPTION_STACK_ID_ NVARCHAR2(64), + EXCEPTION_MSG_ NVARCHAR2(2000), + HANDLER_TYPE_ NVARCHAR2(255), + HANDLER_CFG_ NVARCHAR2(2000), + ADV_HANDLER_CFG_ID_ NVARCHAR2(64), + CREATE_TIME_ TIMESTAMP(6), + TENANT_ID_ NVARCHAR2(255) DEFAULT '', + primary key (ID_) +); + +create index ACT_IDX_JOB_EXCEPTION on ACT_RU_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +create index ACT_IDX_TJOB_EXCEPTION on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TJOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +create index ACT_IDX_SJOB_EXCEPTION on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SJOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +create index ACT_IDX_DJOB_EXCEPTION on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DJOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.postgres.create.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.postgres.create.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..5b0fd747631db09a92ead004147b98f2d60dc49f --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/create/flowable.postgres.create.job.sql @@ -0,0 +1,124 @@ +create table ACT_RU_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_TIMER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_SUSPENDED_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_DEADLETTER_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + TYPE_ varchar(255) NOT NULL, + EXCLUSIVE_ boolean, + EXECUTION_ID_ varchar(64), + PROCESS_INSTANCE_ID_ varchar(64), + PROC_DEF_ID_ varchar(64), + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + DUEDATE_ timestamp, + REPEAT_ varchar(255), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create table ACT_RU_HISTORY_JOB ( + ID_ varchar(64) NOT NULL, + REV_ integer, + LOCK_EXP_TIME_ timestamp, + LOCK_OWNER_ varchar(255), + RETRIES_ integer, + EXCEPTION_STACK_ID_ varchar(64), + EXCEPTION_MSG_ varchar(4000), + HANDLER_TYPE_ varchar(255), + HANDLER_CFG_ varchar(4000), + ADV_HANDLER_CFG_ID_ varchar(64), + CREATE_TIME_ timestamp, + TENANT_ID_ varchar(255) default '', + primary key (ID_) +); + +create index ACT_IDX_JOB_EXCEPTION on ACT_RU_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_JOB + add constraint ACT_FK_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +create index ACT_IDX_TIMER_JOB_EXCEPTION on ACT_RU_TIMER_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_TIMER_JOB + add constraint ACT_FK_TIMER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +create index ACT_IDX_SUSPENDED_JOB_EXCEPTION on ACT_RU_SUSPENDED_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_SUSPENDED_JOB + add constraint ACT_FK_SUSPENDED_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +create index ACT_IDX_DEADLETTER_JOB_EXCEPTION on ACT_RU_DEADLETTER_JOB(EXCEPTION_STACK_ID_); +alter table ACT_RU_DEADLETTER_JOB + add constraint ACT_FK_DEADLETTER_JOB_EXCEPTION + foreign key (EXCEPTION_STACK_ID_) + references ACT_GE_BYTEARRAY (ID_); + +insert into ACT_GE_PROPERTY values ('job.schema.version', '6.2.0.0', 1); \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.db2.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.db2.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..26a8f88aec565a57aaeae06fc21a2e8a81cd9299 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.db2.drop.job.sql @@ -0,0 +1,17 @@ +alter table ACT_RU_JOB + drop foreign key ACT_FK_JOB_EXCEPTION; + +alter table ACT_RU_TIMER_JOB + drop foreign key ACT_FK_TIMER_JOB_EXCEPTION; + +alter table ACT_RU_SUSPENDED_JOB + drop foreign key ACT_FK_SUSPENDED_JOB_EXCEPTION; + +alter table ACT_RU_DEADLETTER_JOB + drop foreign key ACT_FK_DEADLETTER_JOB_EXCEPTION; + +drop table ACT_RU_JOB; +drop table ACT_RU_TIMER_JOB; +drop table ACT_RU_SUSPENDED_JOB; +drop table ACT_RU_DEADLETTER_JOB; +drop table ACT_RU_HISTORY_JOB; \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.h2.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.h2.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..53716346eeeac3de93a93ec61b909c65d5ce1295 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.h2.drop.job.sql @@ -0,0 +1,5 @@ +drop table if exists ACT_RU_JOB cascade constraints; +drop table if exists ACT_RU_TIMER_JOB cascade constraints; +drop table if exists ACT_RU_SUSPENDED_JOB cascade constraints; +drop table if exists ACT_RU_DEADLETTER_JOB cascade constraints; +drop table if exists ACT_RU_HISTORY_JOB cascade constraints; \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.hsql.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.hsql.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..f0ad18df4469dc7a63c775d5518edfce2cd47fd5 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.hsql.drop.job.sql @@ -0,0 +1,5 @@ +drop table if exists ACT_RU_JOB cascade; +drop table if exists ACT_RU_TIMER_JOB cascade; +drop table if exists ACT_RU_SUSPENDED_JOB cascade; +drop table if exists ACT_RU_DEADLETTER_JOB cascade; +drop table if exists ACT_RU_HISTORY_JOB cascade; \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.mssql.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.mssql.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..71fac818c58ebd1a2491af8c8e7d6b9766b85978 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.mssql.drop.job.sql @@ -0,0 +1,10 @@ +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') alter table ACT_RU_JOB drop constraint ACT_FK_JOB_EXCEPTION; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') alter table ACT_RU_TIMER_JOB drop constraint ACT_FK_TIMER_JOB_EXCEPTION; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') alter table ACT_RU_SUSPENDED_JOB drop constraint ACT_FK_SUSPENDED_JOB_EXCEPTION; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') alter table ACT_RU_DEADLETTER_JOB drop constraint ACT_FK_DEADLETTER_JOB_EXCEPTION; + +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_JOB') drop table ACT_RU_JOB; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_TIMER_JOB') drop table ACT_RU_TIMER_JOB; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_SUSPENDED_JOB') drop table ACT_RU_SUSPENDED_JOB; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_DEADLETTER_JOB') drop table ACT_RU_DEADLETTER_JOB; +if exists (select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_NAME = 'ACT_RU_HISTORY_JOB') drop table ACT_RU_HISTORY_JOB; \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.mysql.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.mysql.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..506560b92c632061110323c55b5f586ab4e954c3 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.mysql.drop.job.sql @@ -0,0 +1,17 @@ +alter table ACT_RU_JOB + drop foreign key ACT_FK_JOB_EXCEPTION; + +alter table ACT_RU_TIMER_JOB + drop foreign key ACT_FK_TIMER_JOB_EXCEPTION; + +alter table ACT_RU_SUSPENDED_JOB + drop foreign key ACT_FK_SUSPENDED_JOB_EXCEPTION; + +alter table ACT_RU_DEADLETTER_JOB + drop foreign key ACT_FK_DEADLETTER_JOB_EXCEPTION; + +drop table if exists ACT_RU_JOB; +drop table if exists ACT_RU_TIMER_JOB; +drop table if exists ACT_RU_SUSPENDED_JOB; +drop table if exists ACT_RU_DEADLETTER_JOB; +drop table if exists ACT_RU_HISTORY_JOB; \ No newline at end of file diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.oracle.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.oracle.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..30ff57eb67a9d2fa7141a166853ff95b997985ef --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.oracle.drop.job.sql @@ -0,0 +1,22 @@ +drop index ACT_IDX_JOB_EXCEPTION; +drop index ACT_IDX_TJOB_EXCEPTION; +drop index ACT_IDX_SJOB_EXCEPTION; +drop index ACT_IDX_DJOB_EXCEPTION; + +alter table ACT_RU_JOB + drop CONSTRAINT ACT_FK_JOB_EXCEPTION; + +alter table ACT_RU_TIMER_JOB + drop CONSTRAINT ACT_FK_TJOB_EXCEPTION; + +alter table ACT_RU_SUSPENDED_JOB + drop CONSTRAINT ACT_FK_SJOB_EXCEPTION; + +alter table ACT_RU_DEADLETTER_JOB + drop CONSTRAINT ACT_FK_DJOB_EXCEPTION; + +drop table ACT_RU_JOB; +drop table ACT_RU_TIMER_JOB; +drop table ACT_RU_SUSPENDED_JOB; +drop table ACT_RU_DEADLETTER_JOB; +drop table ACT_RU_HISTORY_JOB; diff --git a/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.postgres.drop.job.sql b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.postgres.drop.job.sql new file mode 100644 index 0000000000000000000000000000000000000000..f0ad18df4469dc7a63c775d5518edfce2cd47fd5 --- /dev/null +++ b/modules/flowable-job-service/src/main/resources/org/flowable/job/db/drop/flowable.postgres.drop.job.sql @@ -0,0 +1,5 @@ +drop table if exists ACT_RU_JOB cascade; +drop table if exists ACT_RU_TIMER_JOB cascade; +drop table if exists ACT_RU_SUSPENDED_JOB cascade; +drop table if exists ACT_RU_DEADLETTER_JOB cascade; +drop table if exists ACT_RU_HISTORY_JOB cascade; \ No newline at end of file diff --git a/modules/flowable5-test/src/test/java/org/activiti/examples/mgmt/ManagementServiceTest.java b/modules/flowable5-test/src/test/java/org/activiti/examples/mgmt/ManagementServiceTest.java index cc9651f7958f1d2b1241e3ef0d18e08d953b548e..995336d7d5d2e9d687a1c685c523dc403a1d6a06 100644 --- a/modules/flowable5-test/src/test/java/org/activiti/examples/mgmt/ManagementServiceTest.java +++ b/modules/flowable5-test/src/test/java/org/activiti/examples/mgmt/ManagementServiceTest.java @@ -32,7 +32,7 @@ public class ManagementServiceTest extends PluggableFlowableTestCase { String tablePrefix = processEngineConfiguration.getDatabaseTablePrefix(); - assertEquals(new Long(9), tableCount.get(tablePrefix + "ACT_GE_PROPERTY")); + assertEquals(new Long(10), tableCount.get(tablePrefix + "ACT_GE_PROPERTY")); assertEquals(new Long(0), tableCount.get(tablePrefix + "ACT_GE_BYTEARRAY")); assertEquals(new Long(0), tableCount.get(tablePrefix + "ACT_RE_DEPLOYMENT")); assertEquals(new Long(0), tableCount.get(tablePrefix + "ACT_RU_EXECUTION"));