Skip to content

Commit 12bee79

Browse files
committed
Testing transactionals to fix delete student courses error
1 parent 77fc478 commit 12bee79

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/StudentCourseUpdateService.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@
1414
import lombok.val;
1515
import org.apache.commons.lang3.StringUtils;
1616
import org.springframework.stereotype.Service;
17+
import org.springframework.transaction.annotation.Propagation;
18+
import org.springframework.transaction.annotation.Transactional;
1719

1820
import java.util.ArrayList;
1921
import java.util.List;
@@ -45,6 +47,7 @@ public StudentCourseUpdateService(final EntityManagerFactory emf, final EventRep
4547
* @param event the event
4648
*/
4749
@Override
50+
@Transactional(propagation = Propagation.REQUIRES_NEW)
4851
public void processEvent(final StudentCourseUpdate studentCourseUpdate, final Event event) {
4952
var studentPEN = restUtils.getStudentPen(studentCourseUpdate.getStudentID());
5053
val existingTraxStudentRecord = this.traxStudentService.findTraxStudentByPen(StringUtils.rightPad(studentPEN, 10));

api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/TraxStudentCourseService.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,13 @@
11
package ca.bc.gov.educ.api.pen.replication.service;
22

33
import ca.bc.gov.educ.api.pen.replication.model.TraxStudentCourseEntity;
4-
import ca.bc.gov.educ.api.pen.replication.model.TraxStudentEntity;
54
import ca.bc.gov.educ.api.pen.replication.repository.TraxStudentCourseRepository;
65
import lombok.extern.slf4j.Slf4j;
76
import org.springframework.stereotype.Service;
87
import org.springframework.transaction.annotation.Propagation;
98
import org.springframework.transaction.annotation.Transactional;
109

1110
import java.util.List;
12-
import java.util.Optional;
1311

1412
@Service
1513
@Slf4j
@@ -26,7 +24,7 @@ public List<TraxStudentCourseEntity> findTraxStudentCoursesByPen(final String pe
2624
}
2725

2826
// it is saved in a new transaction to make sure commit happens in DB.
29-
@Transactional(propagation = Propagation.REQUIRES_NEW)
27+
@Transactional(propagation = Propagation.REQUIRED)
3028
public void deletePriorAndSaveTraxStudentCourses(final List<TraxStudentCourseEntity> existingCourseList, final List<TraxStudentCourseEntity> studentCourseEntityList) {
3129
try {
3230
if(!existingCourseList.isEmpty()) {

0 commit comments

Comments
 (0)