Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

RED-5624: migration

Browse Source 
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
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/LegalBasisMappingPersistenceService.java
View File

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

9
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/LegalBasisMigrationService.java
View File

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

6
persistence-service-v1/persistence-service-shared-mongo-v1/src/main/java/com/iqser/red/service/persistence/service/v1/api/shared/mongo/service/EntityLogMongoService.java
View File

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