Wie kann man JPA bitten, Transaktionen zu akkumulieren?

Question

Ich möchte hier die Leistung eines Codes zu verbessern, ich habe diese Arbeit:

List<Doctor> team = doctorService.getAll(); team.stream() .filter(doctor -> !doctor.equals(msg.getSender())) .forEach(doctor -> { ChatMessageTeam chatMsg = new ChatMessageTeam(); chatMsg.setDoctor(doctor); chatMsg.setMessage(msg); rep.save(chatMsg); });

Die rep ist ein JPA Eigenbau-Repository.

Und ich möchte diesen Strom parallel, aber wenn ich .parallel auf den Strom setzen, habe ich einen Fehler, wie ich sah, weil Entity Manager nicht darauf vorbereitet ist. Also ich denke (und nicht herausgefunden, wie), dass ich tun kann, akkumulieren die Transaktionen und bündeln sie alle zusammen in einer einzigen Abfrage dann. Andere Vorschläge sind ebenfalls willkommen.

Vielen Dank für Ihre Zeit das Lesen!

Answer 1

Um einen Ansatz zum Ausführen mehrerer Datenbankanweisungen in einer einzigen Transaktion zu demonstrieren, habe ich Ihren Code in eine Methode verpackt und dann die Annotation @Transactional zu dieser Methode hinzugefügt. Auf diese Weise wird Ihre Methode entweder in einer bestehenden Transaktion verarbeitet oder eine Transaktion wird für Sie erstellt. Wenn dies in Ihrer Umgebung nicht funktioniert, geben Sie bitte Fehlermeldungen oder Stack-Traces an.

import javax.transaction.Transactional; 

// ... 

@Transactional 
public void store() { 
    List<Doctor> team = doctorService.getAll(); 
    team.stream() 
      .filter(doctor -> !doctor.equals(msg.getSender())) 
      .forEach(doctor -> { 
       ChatMessageTeam chatMsg = new ChatMessageTeam(); 
       chatMsg.setDoctor(doctor); 
       chatMsg.setMessage(msg); 
       rep.save(chatMsg); 
      }); 
} 

Answer 2

Ich denke, bei Ihrem Anwendungsfall ist .parallel langsamer. Aber Sie können für einen Commit alle in eine Methode in Ihren Repo einbinden.

List<Doctor> team = doctorService.getAll(); 
    List<ChatMessageTeam> cmtList = team.stream() 
     .filter(doctor -> !doctor.equals(msg.getSender())) 
     .map(doctor -> new ChatMessageTeam(doctor ,msg)) 
     .collector(Collectors.toList())); 
    rep.saveList(cmtList); 


@Transactional 
public saveList(List<ChatMessageTeam> list){ 
    for(ChatMessageTeam ctm: list){ 
     save(ctm); 
    } 
}