I need to commit records in a loop with following actions :
- Delete record(Parent+ child) with old status
- Create new record, insert parent + child Below deleteOldAndsaveNew() method is called in a loop and i want every time operations inside to be commited.
PFB code snippet:
Calling method: //Service layer
public int updateOldDocumentsFromList(List<DocumentChildDTO> childDocuments) {
int nbDocsUpdated = 0;
for (DocumentChildDTO docChildDTO : childDocuments) {
if (docChildDTO .getDocument() != null) {
DocumentDTO documentDTO = docChildDTO .getDocument();
Document document = documentMapper.documentDTOToDocument(documentDTO);
Document latestDoc = getLatestChildDocument(document);
DocumentStatus statusObsolete = docStatusService.findByName(DocumentStatusType.Obsolete.toString());
DocumentStatus statusValidated = docStatusService.findByName(DocumentStatusType.Validated.toString());
boolean isDBDocObsolete = isDBDocObsolete(statusObsolete, latestDoc);
boolean createDoc = false;
nbDocsUpdated = documentDAO.deleteObsoleteAndSaveValidatedDoc(docChildDTO, document, latestDoc, statusValidated, isDBDocObsolete,
nbDocsUpdated, createDoc);
}
}
LOG.info("End updating olddocouments (nb docs updated: " + nbDocsUpdated + ")");
return nbDocsUpdated;
}
//Dao layer
@Transactional(propagation = Propagation.REQUIRES_NEW)
public int deleteObsoleteAndSaveValidatedDoc(DocumentChildDTO docChildDTO, Document document, Document latestDoc,
DocumentStatus statusValidated, boolean isDBDocObsolete, int nbDocsUpdated, boolean createDoc) {
DocumentStatus statusObsolete = getOldDocStatus();
if ((latestDoc == null) || isDBDocObsolete(statusObsolete, latestDoc)) {
createDoc = true;
}
if (isDBDocObsolete(statusObsolete, latestDoc)) {
documentDAO.delete(latestDoc);
}
DocumentDTO documentDTO;
if (createDoc) {
setters for new document
// Save the new doc
documentDTO = docService.save(document);
if (documentDTO == null) {
LOG.error("Error");
} else {
nbDocsUpdated++;
}
docChildDTO.setDocument(documentDTO);
if (save(docChildDTO) == null) {
LOG.error("Error");
}
}
return nbDocsUpdated;
}
Delete document method
@PersistenceContext
private EntityManager entityManager;
public void delete(Document obsoleteDocument) {
this.entityManager.remove(obsoleteDocument);
this.entityManager.flush();
}
@Transactional
public void saveDocument(Document document) {
LOG.debug("Request to save Document : {}", document);
this.entityManager.persist(document);
this.entityManager.flush();
}
@Transactional
public void save(DocumentChild documentChild ) {
LOG.debug("Request to save documentChild : {}", documentChild );
documentChildDao.saveAndFlush(documentChild);
}
I have used both entity manager and Spring data approaches to see which one works, I can see delete statement and 2 insert statements(parent and child) getting generated and id is also incremented but it is not getting reflected/commited in db.
Does this line @Transactional(propagation = Propagation.REQUIRES_NEW) not guarantee for commiting the operations inside it for every access of method deleteOldAndsaveNew() ?
Edit: I have removed (propagation = Propagation.REQUIRES_NEW) and tried to use Transactional only on operation which needs to be committed every time .
Please suggest.
Thanks.