From 373167e5686e36708d547bb28c1cf82faf3d1623 Mon Sep 17 00:00:00 2001 From: maverickstuder Date: Thu, 9 Jan 2025 13:42:43 +0100 Subject: [PATCH] RED-10660: Re-Add deduplication Migration --- .../V32RankDeduplicationMigration.java | 35 +++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/V32RankDeduplicationMigration.java diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/V32RankDeduplicationMigration.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/V32RankDeduplicationMigration.java new file mode 100644 index 000000000..911f0bae4 --- /dev/null +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/migration/migrations/V32RankDeduplicationMigration.java @@ -0,0 +1,35 @@ +package com.iqser.red.service.persistence.management.v1.processor.migration.migrations; + +import org.springframework.stereotype.Service; + +import com.iqser.red.service.persistence.management.v1.processor.migration.Migration; +import com.iqser.red.service.persistence.management.v1.processor.migration.RankDeDuplicationService; + +import lombok.extern.slf4j.Slf4j; + +@Slf4j +@Service +public class V32RankDeduplicationMigration extends Migration { + + private static final String NAME = "Adding to the migration the rank de-duplication"; + private static final long VERSION = 32; + + private final RankDeDuplicationService rankDeDuplicationService; + + + public V32RankDeduplicationMigration(RankDeDuplicationService rankDeDuplicationService) { + + super(NAME, VERSION); + this.rankDeDuplicationService = rankDeDuplicationService; + } + + + @Override + protected void migrate() { + + log.info("Migration: Checking for duplicate ranks"); + rankDeDuplicationService.deduplicate(); + + } + +}