Propagation REQUIRES_NEW
08 October 2017
현재 spring에서 선언할 수 있는 transaction의 격리 수준을 테스트 해보도록 하겠습니다.
가장 먼저 아래와 같이 person이라는 table에 접근하는 서비스 [PersonService]를 선언하도록 합니다.
해당 서비스에서는 PersonNewService 라는 서비스를 접근하게 되고, 해당 서비스는 transaction이 격리 수준을 변화시켜
어떻게 commit, rollback 등이 진행되는지 알아보도록 하겠습니다.
@Service
@Transactional
@Slf4j
public class PersonServiceImpl implements PersonService {
@Autowired
private PersonRepository personRepository;
@Autowired
private PersonNewService personNewService;
@Override
@Transactional
public void addPerson(String name) throws Exception {
Person person = new Person();
person.setName(name);
personRepository.save(person);
personNewService.addNewPerson("newName");
}
}
@Service
@Slf4j
public class PersonNewServiceImpl implements PersonNewService {
@Autowired
private PersonRepository personRepository;
@Autowired
private PersonService personService;
@Override
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void addNewPerson(String newName) {
Person newPerson = new Person();
newPerson.setName(newName);
}
}
해당 API를 호출하였을 때, 정상적으로 아래와 같이 값이 입력되는 것을 확인할 수 있습니다.
mysql> select * from person;
+----+---------+
| id | name |
+----+---------+
| 18 | dfefe |
| 19 | newName |
+----+---------+
2 rows in set (0.00 sec)
현재 transaction의 name을 가져왔을 때 두 메소드 내에서 다른 이름의 transaction이 실행되고 있는 것을 확인할 수 있습니다.
2017-10-08 18:06:41.383 INFO 15092 --- [nio-8080-exec-1] o.b.t.p.service.impl.PersonServiceImpl : addPerson : org.blog.test.person.service.impl.PersonServiceImpl.addPerson
2017-10-08 18:06:41.388 INFO 15092 --- [nio-8080-exec-1] o.b.t.p.s.impl.PersonNewServiceImpl : addNewPerson : org.blog.test.person.service.impl.PersonNewServiceImpl.addNewPerson
Exception은 "throw new RuntimeException();"을 통해 발생시키도록 합니다.
1. addNewPerson이 호출된 이후, addPerson에서 Exception 발생한 경우
기존의 transaction A가 실행되고, 새로운 transaction B가 실행되고 commit된 이후,
transaction A로 다시 돌아와서 해당 transaction A가 끝나기 전 Exception이 발생한 경우입니다.
전체 API에서는 exception이 발생하게 되고, 새로운 transaction B는 이미 commit 된 이후이기 때문에
exception 여부와 상관없이 transaction B에서 실행된 내역은 그대로 DB에 입력되게 됩니다.
하지만, 기존 transaction A는 rollback되기 때문에 addPerson에서 입력한 값은 commit되지 않는 것을 확인할 수 있습니다.
mysql> select * from person;
+----+---------+
| id | name |
+----+---------+
| 23 | newName |
+----+---------+
1 row in set (0.00 sec)
2. addNewPerson이 호출된 이전, addPerson에서 Exception 발생한 경우
transaction B가 시작하기 전, transaction A가 rollback되기 때문에
transaction A,B 모두 commit 되지 않습니다.
mysql> select * from person;
Empty set (0.00 sec)
3. addNewPerson이 호출된 이후, addNewPerson에서 exception이 발생한 경우
transaction B에서 exception이 발생 후, transaction B가 rollback되고 transaction A도 반영되지 않습니다.
mysql> select * from person;
Empty set (0.00 sec)
4. addNewPerson이 호출된 이후, addNewPerson에서 호출한 외부 메서드에서 Exception이 발생한 경우
외부 호출 메서드 역시 transaction B에서 진행되며 해당 transaction에서 exception이 발생 후,
transaction B가 rollback되고 transaction A도 반영되지 않습니다.
mysql> select * from person;
Empty set (0.00 sec)