RED-5624: migration

working on migration
This commit is contained in:
yhampe 2024-08-09 10:10:06 +02:00
parent 79fec2e9c9
commit 96eef1a7a2
3 changed files with 9 additions and 13 deletions

View File

@ -54,13 +54,6 @@ public class LegalBasisMappingPersistenceService {
}
@Transactional
public List<LegalBasisMappingEntity> getAllLegalBasisMappingEntities() {
return this.legalBasisMappingRepository.findAll();
}
private LegalBasisMappingEntity getLegalBasisMappingOrCreate(String dossierTemplateId) {
return legalBasisMappingRepository.findById(dossierTemplateId)

View File

@ -11,6 +11,7 @@ import com.google.common.hash.HashFunction;
import com.google.common.hash.Hashing;
import com.iqser.red.service.persistence.management.v1.processor.service.persistence.repository.FileRepository;
import com.iqser.red.service.persistence.management.v1.processor.service.persistence.repository.LegalBasisMappingRepository;
import com.iqser.red.service.persistence.management.v1.processor.service.persistence.repository.annotationentity.LegalBasisChangeRepository;
import com.iqser.red.service.persistence.service.v1.api.shared.mongo.repository.EntityLogDocumentRepository;
import jakarta.transaction.Transactional;
@ -50,6 +51,7 @@ public class LegalBasisMigrationService {
private final LegalBasisMappingRepository legalBasisMappingRepository;
private final EntityLogDocumentRepository entityLogDocumentRepository;
private final FileRepository fileRepository;
private final LegalBasisChangeRepository legalBasisChangeRepository;
public void migrate() {
@ -83,6 +85,13 @@ public class LegalBasisMigrationService {
lb.setTechnicalName(getOrDefault(lb.getName()));
}))
.forEach(entityLogDocumentRepository::save);
this.legalBasisChangeRepository.findAll()
.stream()
.peek(entry -> {
entry.setLegalBasis(technicalNameMapping.getOrDefault(entry.getLegalBasis(), entry.getLegalBasis()));
})
.forEach(legalBasisChangeRepository::save);
log.info("Finishing migration: Adding technical names to legal basis");
}

View File

@ -197,12 +197,6 @@ public class EntityLogMongoService {
}
public List<EntityLogDocument> findAllEntityLogDocuments() {
return this.entityLogDocumentRepository.findAll();
}
public boolean entityLogDocumentExists(String dossierId, String fileId) {
return entityLogDocumentRepository.existsById(mapper.getLogId(dossierId, fileId));