KOGITO-9825:Data index flyway postgresql migration scripts doesn't al…

…low multiple executions (apache#1884)
kiegroup · Dec 13, 2023 · 6e19808 · 6e19808
1 parent 46cef0a
commit 6e19808
Show file tree

Hide file tree

Showing 5 changed files with 84 additions and 23 deletions.
diff --git a/...a-index-storage-postgresql/src/main/resources/db/migration/V1.32.0__data_index_create.sql b/...a-index-storage-postgresql/src/main/resources/db/migration/V1.32.0__data_index_create.sql
@@ -1,4 +1,4 @@
-create table attachments
+create table IF NOT EXISTS attachments
 (
     id         varchar(255) not null,
     content    varchar(255),
@@ -9,7 +9,7 @@ create table attachments
     primary key (id)
 );
 
-create table comments
+create table IF NOT EXISTS comments
 (
     id         varchar(255) not null,
     content    varchar(255),
@@ -19,7 +19,7 @@ create table comments
     primary key (id)
 );
 
-create table jobs
+create table IF NOT EXISTS jobs
 (
     id                       varchar(255) not null,
     callback_endpoint        varchar(255),
@@ -41,7 +41,7 @@ create table jobs
     primary key (id)
 );
 
-create table milestones
+create table IF NOT EXISTS milestones
 (
     id                  varchar(255) not null,
     process_instance_id varchar(255) not null,
@@ -50,7 +50,7 @@ create table milestones
     primary key (id, process_instance_id)
 );
 
-create table nodes
+create table IF NOT EXISTS nodes
 (
     id                  varchar(255) not null,
     definition_id       varchar(255),
@@ -63,7 +63,7 @@ create table nodes
     primary key (id)
 );
 
-create table processes
+create table IF NOT EXISTS processes
 (
     id                         varchar(255) not null,
     business_key               varchar(255),
@@ -83,21 +83,21 @@ create table processes
     primary key (id)
 );
 
-create table processes_addons
+create table IF NOT EXISTS processes_addons
 (
     process_id varchar(255) not null,
     addon      varchar(255) not null,
     primary key (process_id, addon)
 );
 
-create table processes_roles
+create table IF NOT EXISTS processes_roles
 (
     process_id varchar(255) not null,
     role       varchar(255) not null,
     primary key (process_id, role)
 );
 
-create table tasks
+create table IF NOT EXISTS tasks
 (
     id                       varchar(255) not null,
     actual_owner             varchar(255),
@@ -119,41 +119,45 @@ create table tasks
     primary key (id)
 );
 
-create table tasks_admin_groups
+create table IF NOT EXISTS tasks_admin_groups
 (
     task_id  varchar(255) not null,
     group_id varchar(255) not null,
     primary key (task_id, group_id)
 );
 
-create table tasks_admin_users
+create table IF NOT EXISTS tasks_admin_users
 (
     task_id varchar(255) not null,
     user_id varchar(255) not null,
     primary key (task_id, user_id)
 );
 
-create table tasks_excluded_users
+create table IF NOT EXISTS tasks_excluded_users
 (
     task_id varchar(255) not null,
     user_id varchar(255) not null,
     primary key (task_id, user_id)
 );
 
-create table tasks_potential_groups
+create table IF NOT EXISTS tasks_potential_groups
 (
     task_id  varchar(255) not null,
     group_id varchar(255) not null,
     primary key (task_id, group_id)
 );
 
-create table tasks_potential_users
+create table IF NOT EXISTS tasks_potential_users
 (
     task_id varchar(255) not null,
     user_id varchar(255) not null,
     primary key (task_id, user_id)
 );
 
+alter table if exists attachments
+  drop constraint if exists fk_attachments_tasks
+cascade;
+
 alter table if exists attachments
     add constraint fk_attachments_tasks
     foreign key (task_id)
@@ -162,6 +166,10 @@ alter table if exists attachments
 delete
 cascade;
 
+alter table if exists comments
+  drop constraint if exists fk_comments_tasks
+cascade;
+
 alter table if exists comments
     add constraint fk_comments_tasks
     foreign key (task_id)
@@ -170,6 +178,10 @@ alter table if exists comments
 delete
 cascade;
 
+alter table if exists milestones
+drop constraint if exists fk_milestones_process
+cascade;
+
 alter table if exists milestones
     add constraint fk_milestones_process
     foreign key (process_instance_id)
@@ -178,6 +190,10 @@ alter table if exists milestones
 delete
 cascade;
 
+alter table if exists nodes
+drop constraint if exists fk_nodes_process
+cascade;
+
 alter table if exists nodes
     add constraint fk_nodes_process
     foreign key (process_instance_id)
@@ -186,6 +202,10 @@ alter table if exists nodes
 delete
 cascade;
 
+alter table if exists processes_addons
+drop constraint if exists fk_processes_addons_processes
+cascade;
+
 alter table if exists processes_addons
     add constraint fk_processes_addons_processes
     foreign key (process_id)
@@ -194,6 +214,10 @@ alter table if exists processes_addons
 delete
 cascade;
 
+alter table if exists processes_roles
+drop constraint if exists fk_processes_roles_processes
+cascade;
+
 alter table if exists processes_roles
     add constraint fk_processes_roles_processes
     foreign key (process_id)
@@ -202,6 +226,10 @@ alter table if exists processes_roles
 delete
 cascade;
 
+alter table if exists tasks_admin_groups
+drop constraint if exists fk_tasks_admin_groups_tasks
+cascade;
+
 alter table if exists tasks_admin_groups
     add constraint fk_tasks_admin_groups_tasks
     foreign key (task_id)
@@ -210,6 +238,10 @@ alter table if exists tasks_admin_groups
 delete
 cascade;
 
+alter table if exists tasks_admin_users
+drop constraint if exists fk_tasks_admin_users_tasks
+cascade;
+
 alter table if exists tasks_admin_users
     add constraint fk_tasks_admin_users_tasks
     foreign key (task_id)
@@ -218,6 +250,10 @@ alter table if exists tasks_admin_users
 delete
 cascade;
 
+alter table if exists tasks_excluded_users
+drop constraint if exists fk_tasks_excluded_users_tasks
+cascade;
+
 alter table if exists tasks_excluded_users
     add constraint fk_tasks_excluded_users_tasks
     foreign key (task_id)
@@ -226,6 +262,10 @@ alter table if exists tasks_excluded_users
 delete
 cascade;
 
+alter table if exists tasks_potential_groups
+drop constraint if exists fk_tasks_potential_groups_tasks
+cascade;
+
 alter table if exists tasks_potential_groups
     add constraint fk_tasks_potential_groups_tasks
     foreign key (task_id)
@@ -234,6 +274,10 @@ alter table if exists tasks_potential_groups
 delete
 cascade;
 
+alter table if exists tasks_potential_users
+drop constraint if exists fk_tasks_potential_users_tasks
+cascade;
+
 alter table if exists tasks_potential_users
     add constraint fk_tasks_potential_users_tasks
     foreign key (task_id)

diff --git a/...ex-storage-postgresql/src/main/resources/db/migration/V1.44.0__data_index_definitions.sql b/...ex-storage-postgresql/src/main/resources/db/migration/V1.44.0__data_index_definitions.sql
@@ -1,4 +1,4 @@
-create table definitions
+create table IF NOT EXISTS definitions
 (
     id       varchar(255) not null,
     version  varchar(255) not null,
@@ -9,22 +9,26 @@ create table definitions
     primary key (id, version)
 );
 
-create table definitions_addons
+create table IF NOT EXISTS definitions_addons
 (
     process_id      varchar(255) not null,
     process_version varchar(255) not null,
     addon           varchar(255) not null,
     primary key (process_id, process_version, addon)
 );
 
-create table definitions_roles
+create table IF NOT EXISTS definitions_roles
 (
     process_id      varchar(255) not null,
     process_version varchar(255) not null,
     role            varchar(255) not null,
     primary key (process_id, process_version, role)
 );
 
+alter table if exists definitions_addons
+drop constraint if exists fk_definitions_addons_definitions
+cascade;
+
 alter table if exists definitions_addons
     add constraint fk_definitions_addons_definitions
     foreign key (process_id, process_version)
@@ -33,6 +37,10 @@ alter table if exists definitions_addons
 delete
 cascade;
 
+alter table if exists definitions_roles
+drop constraint if exists fk_definitions_roles_definitions
+cascade;
+
 alter table if exists definitions_roles
     add constraint fk_definitions_roles_definitions
     foreign key (process_id, process_version)
@@ -42,4 +50,4 @@ delete
 cascade;
 
 alter table if exists processes
-    add column version varchar (255);
+    add column IF NOT EXISTS version varchar (255);
diff --git a/...age-postgresql/src/main/resources/db/migration/V1.45.0.0__data_index_node_definitions.sql b/...age-postgresql/src/main/resources/db/migration/V1.45.0.0__data_index_node_definitions.sql
@@ -1,4 +1,4 @@
-create table definitions_nodes
+create table IF NOT EXISTS definitions_nodes
 (
     id              varchar(255) not null,
     name            varchar(255),
@@ -9,7 +9,7 @@ create table definitions_nodes
     primary key (id, process_id, process_version)
 );
 
-create table definitions_nodes_metadata
+create table IF NOT EXISTS definitions_nodes_metadata
 (
     node_id         varchar(255) not null,
     process_id      varchar(255) not null,
@@ -18,6 +18,9 @@ create table definitions_nodes_metadata
     key             varchar(255) not null,
     primary key (node_id, process_id, process_version, key)
 );
+alter table if exists definitions_nodes
+drop constraint if exists fk_definitions_nodes_definitions
+cascade;
 
 alter table if exists definitions_nodes
     add constraint fk_definitions_nodes_definitions
@@ -27,6 +30,10 @@ alter table if exists definitions_nodes
 delete
 cascade;
 
+alter table if exists definitions_nodes_metadata
+drop constraint if exists fk_definitions_nodes_metadata_definitions_nodes
+cascade;
+
 alter table if exists definitions_nodes_metadata
     add constraint fk_definitions_nodes_metadata_definitions_nodes
     foreign key (node_id, process_id, process_version)

diff --git a/...ostgresql/src/main/resources/db/migration/V1.45.0.1__add_identity_to_process_instance.sql b/...ostgresql/src/main/resources/db/migration/V1.45.0.1__add_identity_to_process_instance.sql
@@ -1,3 +1,3 @@
-ALTER TABLE processes
-    ADD COLUMN created_by character varying,
-    ADD COLUMN updated_by character varying;
+ALTER TABLE IF exists processes
+    ADD COLUMN IF NOT EXISTS created_by character varying,
+    ADD COLUMN IF NOT EXISTS updated_by character varying;
diff --git a/...ta-index-storage/data-index-storage-postgresql/src/main/resources/db/migration/readme.txt b/...ta-index-storage/data-index-storage-postgresql/src/main/resources/db/migration/readme.txt
@@ -0,0 +1,2 @@
+Ensure migration scripts are developed to support several executions over the same database without any error.
+This feature will make sure this migration execution would be compatible with other needed flyway migrations without broking the chain.
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		Ensure migration scripts are developed to support several executions over the same database without any error.
		This feature will make sure this migration execution would be compatible with other needed flyway migrations without broking the chain.