context.xml
:
<context:component-scan base-package="BP"/>
<tx:annotation-driven transaction-manager="txManager"/><!-- a PlatformTransactionManager is still required -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!-- (this dependency is defined somewhere else) -->
<property name="dataSource" ref="dataSource"/>
</bean>
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/springjdbc?serverTimezone=UTC"/>
<property name="username" value="root"/>
<property name="password" value="1234"/>
</bean>
Класс, в котором происходит действие(Находится в пакете BP
):
@Configuration
public class SomeNumbersMySQLDao{
public JdbcTemplate jdbcTemplate;
@Autowired
public SomeNumbersMySQLDao(DataSource dataSource){
jdbcTemplate = new JdbcTemplate(dataSource);
}
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("context.xml");
SomeNumbersMySQLDao dao = context.getBean("someNumbersMySQLDao", SomeNumbersMySQLDao.class);
// код здесь будет изменяться. Назовем ее точкой "main"
}
// здесь методы, которые покажу далее.
public void cleanTable() {
jdbcTemplate.execute("DELETE FROM someNumbers");
}
public void printTable() {
List<Integer> numbersGot = jdbcTemplate.queryForList("SELECT * FROM someNumbers", Integer.class);
System.out.println("Numbers got from table: ");
numbersGot.forEach(System.out::println);
}
}
Транзакции на одиночных(не вложенных) методах работают.
Приведу пример.
Есть метод:
@Transactional(propagation=Propagation.REQUIRED)
public void outer(int number) {
System.out.println(TransactionSynchronizationManager.isActualTransactionActive());
jdbcTemplate.update("INSERT INTO someNumbers (number) VALUES (?)", new Object[] {number});
throw new RuntimeException();
}
В точке "main" пишем следующий код:
dao.cleanTable();
dao.outer(123);
Выполняем, убираем этот код, пишем следующий код и вновь выполняем:
dao.printTable();
Получим сначала вывод:
true
а затем:
Numbers got from table:
Что понятно, так как транзакция откатилась. Если мы напишем вместо Propagation.REQUIRED
Propagation.NEVER
, то получим сначала вывод:
false
а затем:
Numbers got from table:
123
Что логично - транзакции нет, она и не откатилась.
Более того, если мы напишем вместо Propagation.REQUIRED
Propagation.MANDATORY
, то получим однозначный(что одиночные транзакции работают) вывод:
Exception in thread "main" org.springframework.transaction.IllegalTransactionStateException
Хорошо, теперь попробуем одним методом с Propagation.REQUIRED
вызвать метод с Propagation.NEVER
. По идее должны получить ошибку, но этого не происходит.
@Transactional(propagation=Propagation.REQUIRED)
public void outer(int number) {
System.out.println(TransactionSynchronizationManager.isActualTransactionActive());
jdbcTemplate.update("INSERT INTO someNumbers (number) VALUES (?)", new Object[] {number});
withNever(number);
}
@Transactional(propagation=Propagation.NEVER)
public void withNever(int numberToInsertInInnerMethod) {
System.out.println(TransactionSynchronizationManager.isActualTransactionActive());
jdbcTemplate.update("INSERT INTO someNumbers (number) VALUES (?)", new Object[] {numberToInsertInInnerMethod});
throw new RuntimeException();
}
Вывод:
true
true
Exception in thread "main" java.lang.RuntimeException
а затем:
Numbers got from table:
Должно было лечь уже на вызове метода Propagation.NEVER
. И изменения откатились.
Та же картина и с Propagation.REQUIRES_NEW
, и с Propagation.REQUIRED
, и тем более с Propagation.MANDATORY
.
Однако несколько другие результаты, если поставить на метод outer
Propagation.NEVER
. Тогда(пробовал пока только на Propagation.REQUIRED
, но уверен, что то же будет и с остальными) будет следующий вывод:
false
false
Exception in thread "main" java.lang.RuntimeException
И потом:
Numbers got from table:
123
123
То есть мои внутренние транзакции по-сути работают как транзакции Propagation.SUPPORTS
.