Программное управление транзакциями в Spring

Spring реализует прекрасную поддержку декларативного управления транзакциями. В сущности всё управление сводится к корректной расстановке аннотации @Transactional, а всё остальное берёт на себя Spring. Но, в случае необходимости, можно взять контроль в свои руки и вернуть управление транзакциями в код.

Этот пример основан на статье Декларативное управление транзакциями в Spring и далее приведены только изменения в оригинальном коде.

Ручное управление транзакциями начинается с объекта TransactionTemplate, который конфигурируется PlatformTransactionManager:

@Bean
public TransactionTemplate transactionTemplate() {
  return new TransactionTemplate(transactionManager());
}

@Bean

public TransactionTemplate transactionTemplate() {

return new TransactionTemplate(transactionManager());

}

TransactionTemplate использует парадигму callback (обратных вызовов) для исполнения кода внутри транзакции. В метод execute() передаётся код для исполнения, который будет синхронно исполнен в контексте транзакции.

@Override
public final void addGreet(final Greeter g) {
  transactionTemplate.execute(new TransactionCallbackWithoutResult() {

    @Override
      protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
        em.persist(g);
    }
  });
}

@Override

public final void addGreet(final Greeter g) {

transactionTemplate.execute(new TransactionCallbackWithoutResult() {

@Override

protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {

em.persist(g);

}

});

}

В callback передаётся объект TransactionStatus, представляющий собой обёртку вокруг реальной транзакции. С его помощью можно управлять транзакцией, например программно откатывать её.

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

@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, которые настраиваются вызовами соответствующих методов:

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

@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

Рекомендованное чтение