gCubeSystem
/
accounting-aggregator-se-plugin
15
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fixed bulk delete

This commit is contained in:
Luca Frosini 2024-02-28 17:12:01 +01:00
parent 2c927dda9d
commit e7759dd97f
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/org/gcube/accounting/aggregator/persist/DeleteDocument.java
View File

@ -29,7 +29,6 @@ public class DeleteDocument extends DocumentElaboration {
JsonNode jsonNode = DSMapper.asJsonNode(line); JsonNode jsonNode = DSMapper.asJsonNode(line);
if(aggregatorPersistenceSrc.isBulkDeleteAllowed()) { if(aggregatorPersistenceSrc.isBulkDeleteAllowed()) {
arrayNode.add(jsonNode); arrayNode.add(jsonNode);
aggregatorPersistenceSrc.deleteRecord(jsonNode);
if(arrayNode.size()>=effectiveMaxRowPerStep) { if(arrayNode.size()>=effectiveMaxRowPerStep) {
aggregatorPersistenceSrc.deleteRecords(arrayNode); aggregatorPersistenceSrc.deleteRecords(arrayNode);
arrayNode = DSMapper.getObjectMapper().createArrayNode(); arrayNode = DSMapper.getObjectMapper().createArrayNode();