Транзакция только для чтения не работает в моей конфигурации AOP
Я пытаюсь научиться использовать AOP, и я пытаюсь установить транзакцию только для чтения в контексте приложения Spring, но она не работает, она все еще передает данные в БД.
Я действительно не знаю, что я делаю неправильно, если вы можете мне помочь, я буду очень рад.
applicationContext.xml
<?xml version="1.0" encoding="windows-1252"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx= "http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/tx`enter code here`
http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
<aop:aspectj-autoproxy proxy-target-class="true" />
<!--advice-->
<tx:advice id="txAdvice" transaction-manager="txManager">
<tx:attributes>
<tx:method name="eliminar*" read-only="true" />
</tx:attributes>
</tx:advice>
<!-- Aspect -->
<bean id="Aop" class="com.all.mymavenii.dao.TiposSolicitudDAO" />
<aop:config>
<aop:pointcut id="point"
expression="execution(* com.all.mymavenii.dao.TiposSolicitudDAO.eliminar(..))"/>
<aop:advisor advice-ref="txAdvice" pointcut-ref="point"/>
</aop:config>
<!-- Data Base configuration -->
<bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="/WEB-INF/config/basedatos/jdbc.properties" />
</bean>
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
<property name="driverClass" value="${sifa.jdbc.driverClassName}" />
<property name="jdbcUrl" value="${sifa.jdbc.url}" />
<property name="user" value="${sifa.jdbc.username}" />
<property name="password" value="${sifa.jdbc.password}" />
<property name="acquireIncrement" value="${sifa.c3p0.acquireIncrement}" />
<property name="minPoolSize" value="${sifa.c3p0.minPoolSize}" />
<property name="maxPoolSize" value="${sifa.c3p0.maxPoolSize}" />
<property name="maxIdleTime" value="${sifa.c3p0.maxIdleTime}" />
</bean>
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<context:component-scan base-package="com.all.mymavenii.servicio">
<context:include-filter expression="org.springframework.stereotype.Service" type="annotation" />
</context:component-scan>
<context:component-scan base-package="com.all.mymavenii.dao">
<context:include-filter expression="org.springframework.stereotype.Repository" type="annotation" />
</context:component-scan>
</beans>
IndexController
Код запроса, который выполняет метод:
@Controller
@RequestMapping("/")
public class IndexControlador {
@Autowired
private Servicio service;
/*
. . .
*/
@RequestMapping(value = "/vista2", method = RequestMethod.POST)
public String tipoSolicitudEliminar(@RequestParam("clv") String claveTipo) {
service.eliminar(claveTipo);
return "redirect:/vista2";
}
}
обслуживание
@Service
public class Servicio {
@Autowired
private TiposSolicitudDAO tiposSolicitudDAO;
public void eliminar(String clave)
{
tiposSolicitudDAO.eliminar(clave);
}
}
DAO
@Repository("tiposSolicitudDAO")
public class TiposSolicitudDAO {
private JdbcTemplate jdbcTemplate;
private final String DELETE_SQL;
@Autowired
public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}
public TiposSolicitudDAO() {
this.DELETE_SQL = "DELETE FROM sifa_tipos_solicitud WHERE tiso_clave =? ";
}
public void eliminar(String claveTiposSolicitud) {
jdbcTemplate.update(DELETE_SQL, new Object[]{claveTiposSolicitud});
}
}
Зависимости
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>4.0.5.RELEASE</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjrt</artifactId>
<version>1.8.1</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.1</version>
</dependency>
1 ответ
Как можно увидеть здесь ( https://jira.spring.io/browse/SPR-8959), свойство только для чтения не приводит к автоматическому откату в конце транзакции с JPATransactionManager и MySQL, как этого ожидают многие (включая меня). Похоже, что разработчики Spring не думают, что это ошибка, и нет планов ее исправлять.
Если вы хотите всегда откатывать транзакцию (таким образом, делать ее доступной только для чтения) в конце некоторых методов, мой способ сделать это - расширить Spring TransactionInterceptor
,
Метод commitTransactionAfterReturning
берет на себя ответственность за транзакцию.
protected void commitTransactionAfterReturning(TransactionInfo txInfo) {
if (txInfo != null && txInfo.hasTransaction()) {
if (logger.isTraceEnabled()) {
logger.trace("Completing transaction for [" + txInfo.getJoinpointIdentification() + "]");
}
txInfo.getTransactionManager().commit(txInfo.getTransactionStatus());
}
}
Из последней строки видно, что по умолчанию он просто фиксирует транзакцию. Поэтому нам нужно заменить его на выражение if.
if (txInfo.getTransactionAttribute().isReadOnly()) {
txInfo.getTransactionManager().rollback(txInfo.getTransactionStatus());
} else {
txInfo.getTransactionManager().commit(txInfo.getTransactionStatus());
}
Таким образом, конечно, вы не можете использовать <tx:advice>
больше. Нам также нужно настроить бин самостоятельно. Ниже приведен пример:
<bean id="txAdvice" class="yourTransactionInterceptor">
<property name="transactionManager" ref="transactionManager" />
<property name="transactionAttributes">
<props>
<prop key="read*">PROPAGATION_REQUIRED,ISOLATION_DEFAULT,readOnly
</prop>
<prop key="*">PROPAGATION_REQUIRED,ISOLATION_DEFAULT</prop>
</props>
</property>
</bean>