From 78fcb0a394bbdfda24dc3d8d30a98bf64246cc90 Mon Sep 17 00:00:00 2001 From: Viktor Seifert Date: Tue, 11 Apr 2023 14:34:02 +0200 Subject: [PATCH] RED-6467: Added some debugging information --- .../persistence/EntryPersistenceService.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/EntryPersistenceService.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/EntryPersistenceService.java index 0209004b0..16fa643c1 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/EntryPersistenceService.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/EntryPersistenceService.java @@ -97,12 +97,17 @@ public class EntryPersistenceService { } } + @Transactional public void addEntries(String typeId, Set entries, long version, DictionaryEntryType dictionaryEntryType) { var type = typeRepository.getById(typeId); + + log.info("Adding {} entries to type {}\n", entries, dictionaryEntryType); + log.info("Following entries will be added\n" + String.join("\n", entries)); + switch (dictionaryEntryType) { - case ENTRY: { + case ENTRY -> { var undeletedEntries = entryRepository.undeleteEntries(typeId, entries, version); undeletedEntries.forEach(entries::remove); @@ -116,9 +121,8 @@ public class EntryPersistenceService { }).collect(Collectors.toList()); jdbcWriteUtils.saveBatch(entryEntities); - break; } - case FALSE_POSITIVE: { + case FALSE_POSITIVE -> { var undeletedEntries = falsePositiveEntryRepository.undeleteEntries(typeId, entries, version); undeletedEntries.forEach(entries::remove); @@ -131,9 +135,8 @@ public class EntryPersistenceService { }).collect(Collectors.toList()); jdbcWriteUtils.saveBatch(entryEntities); - break; } - case FALSE_RECOMMENDATION: { + case FALSE_RECOMMENDATION -> { var undeletedEntries = falseRecommendationEntryRepository.undeleteEntries(typeId, entries, version); undeletedEntries.forEach(entries::remove); @@ -146,7 +149,6 @@ public class EntryPersistenceService { }).collect(Collectors.toList()); jdbcWriteUtils.saveBatch(entryEntities); - break; } } }