Почему моя транзакция не откатывается весенними аннотациями?

Я в своем уме, пытаясь отладить эту проблему. В основном, у меня есть приложение mvc, где у меня есть BusinessManagerImplкласс, который имеет 2 DAOs ( UserDaoиProductDao), и я использую JDBC с пулом соединений вместо ORM. База данных mySQL с InnoDB engine. RestUserControllerявляется вызывающим классом BusinessManagerImpl.

BusinessManagerImpl.addUser() аннотирован @Transactionalаннотацией. Я также пытался аннотировать @Transactionalна уровне класса, но, похоже, это не имеет значения. Оба DAO также аннотируются как таковые.

BusinessManagerImpl.addUser() используется UserDaoдля вставки пользователя, но последующий вызов ProductDao.getAllProducts()вызывает RuntimeExceptionспециально, чтобы вызвать откат транзакции. Я ожидаю, что пользователь не должен был быть вставлен как RuntimeExceptionпроизошло, и транзакция была бы откатана, но я проверил свою базу данных, и новый пользователь вставлен.

Я пытался создать проверенное исключение и использовать параметр» rollback for » @Transactionalаннотации, но он не работает. Я также пробовал различные значения распространения, такие какPropagation.Required, но, похоже, не оказывают влияния на откат транзакции. Я пытался искать на stackoverflow и google, но не придумал ничего, что могло бы помочь. Может ли кто — то пролить свет на то, что я делаю неправильно или что-то упускаю? Спасибо!. Ниже приведена моя настройка:

контекст приложения.XML

<beans 




xsi_schemaLocation="
    http://www.springframework.org/schema/beans     
    http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
    http://www.springframework.org/schema/mvc 
    http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx-3.2.xsd        
    http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context-3.2.xsd">

<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>
<context:component-scan base-package="someproject" />
<!-- <context:annotation-config /> -->


<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/somedb" />
    <property name="username" value="xxx" />
    <property name="password" value="yyy" />
</bean>

<bean id="transactionManager"
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"></property>
</bean> 

Класс BusinessManagerImpl

@Service 
public class BusinessManagerImpl implements BusinessManager{

@Autowired
private UserDao userDao;

@Autowired
private ProductDao productDao;
....
@Override   
@Transactional(propagation=Propagation.REQUIRED)
public User addUser(User user) throws Exception {
    // TODO Auto-generated method stub
    User tempUser = userDao.addUser(user);
    productDao.getAllProducts();

    return tempUser;
}

Класс UserDaoImpl

@Service
public class UserDaoImpl implements UserDao {

private DataSource dataSource;

@Autowired
public UserDaoImpl(DataSource dataSource) {
    super();
    setDataSource(dataSource);
}   

public void setDataSource(DataSource dataSource) {
    this.dataSource = dataSource;
}       

private JdbcTemplate getJdbcTemplate(){
    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

    return jdbcTemplate;
}       
...
    @Override   
@Transactional(propagation=Propagation.MANDATORY)
public User addUser(final User user) {
    KeyHolder holder = new GeneratedKeyHolder();

    final String sql = "insert into user (username, password) "
            + " VALUES (?, ?)";

    getJdbcTemplate().update(new PreparedStatementCreator() {

        @Override
        public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
            PreparedStatement ps = connection.prepareStatement(sql.toString(), Statement.RETURN_GENERATED_KEYS);

            int index = 1;              

            ps.setString(index++, user.getUsername());
            ps.setString(index++, user.getPassword());


            return ps;
        }
    }, holder);

    int seq = holder.getKey().intValue();
    user.setSeq(seq);
    return user;
}

Класс ProductDaoImpl

@Service
public class ProductDaoImpl implements ProductDao {

private DataSource dataSource;

@Autowired
public ProductDaoImpl(DataSource dataSource) {
    super();
    setDataSource(dataSource);
}   

public void setDataSource(DataSource dataSource) {
    this.dataSource = dataSource;
}   

@Override
@Transactional(propagation=Propagation.MANDATORY)
public List<Product> getAllProducts() throws Exception {

    if(true)
        throw new RuntimeException("on purpose");

    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    List<Product> products = jdbcTemplate.query(
            "select * from product",
            new ProductRowMapper());

    return products;
}

Класс RestUserController

@RestController
public class RestUserController {
private static Logger logger = LoggerFactory.getLogger(RestUserController.class);

@Autowired
private BusinessManager businessManager;

@RequestMapping(value = "/adduser", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<String> createEmployee(@RequestBody User user) 
{
    logger.debug("adding user:"+user);
    User addedUser=null;
    try {
        addedUser = businessManager.addUser(user);
        return new ResponseEntity(addedUser, HttpStatus.CREATED);
    } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    return new ResponseEntity(HttpStatus.INTERNAL_SERVER_ERROR);

}

сеть.XML

   <?xml version="1.0" encoding="UTF-8"?>
    <web-app   xsi_schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">
    <display-name>Spring3 MVC Application</display-name>
    <context-param>
        <param-name>contextConfigLocation</param-name>
            <param-value>/WEB-INF/application-context.xml  
        </param-value>
        </context-param>
          <listener>
            <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
          </listener>
          <servlet>
            <servlet-name>spring-web</servlet-name>
            <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
            <load-on-startup>1</load-on-startup>
          </servlet>
          <servlet-mapping>
            <servlet-name>spring-web</servlet-name>
            <url-pattern>/</url-pattern>
          </servlet-mapping>
        </web-app>

spring-web-сервлет.XML

<beans 
    
    
    
    xsi_schemaLocation="
        http://www.springframework.org/schema/beans     
        http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-3.2.xsd">

    <context:component-scan base-package="someproject" />

    <bean
        class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix">
            <value>/WEB-INF/views/jsp/</value>
        </property>
        <property name="suffix">
            <value>.jsp</value>
        </property>
    </bean>

    <mvc:resources mapping="/resources/**" location="/resources/" />

    <mvc:annotation-driven />

</beans>

2 ответа

  1. Я нахожу использование аннотации @Service в классе реализации Dao странным. Попробуйте заменить их на @Repository и добавить rollbackFor = {Exception.class}ко всем вашим транзакционным аннотациям.

  2. Для конфигураций 2 контекстов приложений необходимо по-разному указать базовый пакет. Не позволяйте контексту веб-приложения сканировать пакет DAO.