Как спросить JPA о накоплении транзакций?

Question

Я хочу, чтобы улучшить производительность кода здесь, у меня есть это работает:

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); });

rep является JPA хранилище собственной сборки.

И я хочу параллелировать этот поток, но когда я поместил .parallel в поток, у меня появилась ошибка, как я увидел, потому что диспетчер объектов не подготовлен к этому. Поэтому я думаю (и не выяснил, как), что я могу сделать, это аккумулировать транзакции и объединить все их вместе в одном запросе. Другие предложения приветствуются.

Спасибо за ваше время, читая это!

Answer 1

Чтобы продемонстрировать подход к выполнению нескольких инструкций базы данных в одной транзакции, я завернул ваш код в метод, а затем добавил аннотацию @Transactional к этому методу. Таким образом, ваш метод будет либо обрабатываться в существующей транзакции, либо будет создана транзакция для вас. Если это не работает в вашей среде, укажите сообщения об ошибках или трассировки стека.

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

Я думаю, что в вашем потребительной случае .parallel медленнее. Но вы можете обернуть все в один метод в свое репо для одного коммита.

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); 
    } 
}