Spring реализует прекрасную поддержку декларативного управления транзакциями. В сущности всё управление сводится к корректной расстановке аннотации @Transactional, а всё остальное берёт на себя Spring. Но, в случае необходимости, можно взять контроль в свои руки и вернуть управление транзакциями в код.
Этот пример основан на статье Декларативное управление транзакциями в Spring и далее приведены только изменения в оригинальном коде.
Ручное управление транзакциями начинается с объекта TransactionTemplate, который конфигурируется PlatformTransactionManager:
|
1
2
3
4
|
@Bean
public TransactionTemplate transactionTemplate() {
return new TransactionTemplate(transactionManager());
}
|
TransactionTemplate использует парадигму callback (обратных вызовов) для исполнения кода внутри транзакции. В метод execute() передаётся код для исполнения, который будет синхронно исполнен в контексте транзакции.
|
1
2
3
4
5
6
7
8
9
10
|
@Override
public final void addGreet(final Greeter g) {
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
@Override
protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
em.persist(g);
}
});
}
|
В callback передаётся объект TransactionStatus, представляющий собой обёртку вокруг реальной транзакции. С его помощью можно управлять транзакцией, например программно откатывать её.
|
1
2
3
4
5
6
7
8
9
10
11
12
|
@Override
public final void updateGreet(final Greeter g, final String newTarget) {
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
@Override
protected void doInTransactionWithoutResult(TransactionStatus status) {
Greeter greet = em.merge(g);
greet.setTarget(newTarget);
status.setRollbackOnly();
}
});
}
|
TransactionTemplate поддерживает все те же возможности, что и аннотация @Transactional, которые настраиваются вызовами соответствующих методов:
|
1
2
3
4
5
6
7
|
@Override
public final List<Greeter> getGreetings() {
TransactionTemplate tx = new TransactionTemplate(transactionManager);
tx.setReadOnly(true);
return tx.execute(status -> em.createQuery("from Greeter", Greeter.class)
.getResultList());
}
|
Код примера доступен на github