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

RED-6467: Added some debugging information

Browse Source
This commit is contained in:
Viktor Seifert 2023-04-11 14:34:02 +02:00
parent 796cc3c8cc
commit 78fcb0a394
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -97,12 +97,17 @@ public class EntryPersistenceService {
} }
} }
@Transactional @Transactional
public void addEntries(String typeId, Set<String> entries, long version, DictionaryEntryType dictionaryEntryType) { public void addEntries(String typeId, Set<String> entries, long version, DictionaryEntryType dictionaryEntryType) {
var type = typeRepository.getById(typeId); 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) { switch (dictionaryEntryType) {
case ENTRY: { case ENTRY -> {
var undeletedEntries = entryRepository.undeleteEntries(typeId, entries, version); var undeletedEntries = entryRepository.undeleteEntries(typeId, entries, version);
undeletedEntries.forEach(entries::remove); undeletedEntries.forEach(entries::remove);
@ -116,9 +121,8 @@ public class EntryPersistenceService {
}).collect(Collectors.toList()); }).collect(Collectors.toList());
jdbcWriteUtils.saveBatch(entryEntities); jdbcWriteUtils.saveBatch(entryEntities);
break;
} }
case FALSE_POSITIVE: { case FALSE_POSITIVE -> {
var undeletedEntries = falsePositiveEntryRepository.undeleteEntries(typeId, entries, version); var undeletedEntries = falsePositiveEntryRepository.undeleteEntries(typeId, entries, version);
undeletedEntries.forEach(entries::remove); undeletedEntries.forEach(entries::remove);
@ -131,9 +135,8 @@ public class EntryPersistenceService {
}).collect(Collectors.toList()); }).collect(Collectors.toList());
jdbcWriteUtils.saveBatch(entryEntities); jdbcWriteUtils.saveBatch(entryEntities);
break;
} }
case FALSE_RECOMMENDATION: { case FALSE_RECOMMENDATION -> {
var undeletedEntries = falseRecommendationEntryRepository.undeleteEntries(typeId, entries, version); var undeletedEntries = falseRecommendationEntryRepository.undeleteEntries(typeId, entries, version);
undeletedEntries.forEach(entries::remove); undeletedEntries.forEach(entries::remove);
@ -146,7 +149,6 @@ public class EntryPersistenceService {
}).collect(Collectors.toList()); }).collect(Collectors.toList());
jdbcWriteUtils.saveBatch(entryEntities); jdbcWriteUtils.saveBatch(entryEntities);
break;
} }
} }
} }