fix(migration): add an if condition for the tenant in migration #1486

Author: Miguel7373

backend/src/main/java/ch/puzzle/okr/multitenancy/FlywayMultitenantMigrationInitializer.java

@@ -5,6 +5,8 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 @Component
 public class FlywayMultitenantMigrationInitializer {
     private final TenantConfigProviderInterface tenantConfigProvider;
@@ -28,6 +30,7 @@ public void migrateFlyway() {
                     .configure() //
                     .dataSource(dataSourceConfig.url(), dataSourceConfig.name(), dataSourceConfig.password()) //
                     .locations(scriptLocations) //
+                    .placeholders(Map.of("tenant", tenantConfig.tenantId()))
                     .baselineOnMigrate(Boolean.TRUE) //
                     .schemas(dataSourceConfig.schema()) //
                     .load();

backend/src/main/resources/db/data-migration-demo/afterMigrate__0_0_clear_data.sql

@@ -1,23 +1,30 @@
-truncate table okr_acme.alignment cascade;
-truncate table okr_acme.action cascade;
-truncate table okr_acme.check_in cascade;
-truncate table okr_acme.key_result cascade;
-truncate table okr_acme.completed cascade;
-truncate table okr_acme.objective cascade;
-truncate table okr_acme.person cascade;
-truncate table okr_acme.quarter cascade;
-truncate table okr_acme.team cascade;
-truncate table okr_acme.person_team cascade;
-truncate table okr_acme.unit cascade;
+DO $$
+BEGIN
+    IF '${tenant}' = 'pitc' THEN
+        truncate table okr_pitc.alignment cascade;
+        truncate table okr_pitc.action cascade;
+        truncate table okr_pitc.check_in cascade;
+        truncate table okr_pitc.key_result cascade;
+        truncate table okr_pitc.completed cascade;
+        truncate table okr_pitc.objective cascade;
+        truncate table okr_pitc.person cascade;
+        truncate table okr_pitc.quarter cascade;
+        truncate table okr_pitc.team cascade;
+        truncate table okr_pitc.person_team cascade;
+        truncate table okr_pitc.unit cascade;
+    ELSIF '${tenant}' = 'acme' THEN
+        truncate table okr_acme.alignment cascade;
+        truncate table okr_acme.action cascade;
+        truncate table okr_acme.check_in cascade;
+        truncate table okr_acme.key_result cascade;
+        truncate table okr_acme.completed cascade;
+        truncate table okr_acme.objective cascade;
+        truncate table okr_acme.person cascade;
+        truncate table okr_acme.quarter cascade;
+        truncate table okr_acme.team cascade;
+        truncate table okr_acme.person_team cascade;
+        truncate table okr_acme.unit cascade;
+    END IF;
+END $$;
+
 
-truncate table okr_pitc.alignment cascade;
-truncate table okr_pitc.action cascade;
-truncate table okr_pitc.check_in cascade;
-truncate table okr_pitc.key_result cascade;
-truncate table okr_pitc.completed cascade;
-truncate table okr_pitc.objective cascade;
-truncate table okr_pitc.person cascade;
-truncate table okr_pitc.quarter cascade;
-truncate table okr_pitc.team cascade;
-truncate table okr_pitc.person_team cascade;
-truncate table okr_pitc.unit cascade;