Один метод Service вызывает внутренний множественный метод для транзакции Spring - PullRequest
Новая
       15

Один метод Service вызывает внутренний множественный метод для транзакции Spring

7 голосов
/ 29 августа 2011 
package com.bluesky;

public interface FooServiceIface {
    public  void insertA();
    public void insertB();
}

package com.bluesky;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class FooServiceImpl extends JdbcDaoSupport implements FooServiceIface {

    public void insertA() {
        this.getJdbcTemplate().execute("insert student(name) values('stuA')");
         insertB();
         int i=10/0;
    }

    public void insertB() {
        this.getJdbcTemplate().execute("insert student(name) values('stuB')");

    }

}

public class Client {

    public static void main(String[] args) {

        ApplicationContext appContxt = new ClassPathXmlApplicationContext("applicationContext.xml");

        FooServiceIface  fService= (FooServiceIface)appContxt.getBean("fooService");

        fService.insertA();

    }
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
       <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
       <property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&amp;characterEncoding=utf-8"/>
       <property name="username" value="root"/>
       <property name="password" value="root"/>
    </bean>

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

    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="insertA" propagation="REQUIRED" />
             <tx:method name="insertB" propagation="REQUIRES_NEW" />
        </tx:attributes>
    </tx:advice>

    <aop:config proxy-target-class="true">
        <aop:pointcut id="interceptorPointCuts" expression="execution(* com.bluesky.*Service*.*(..))" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="interceptorPointCuts" />       
    </aop:config>     
</beans>

Извините за Сложный код

Когда я запускаю клиентские журналы отладки, отображаются: 

21:44:19,546 DEBUG TransactionSynchronizationManager:183 - Bound value [org.springframework.jdbc.datasource.ConnectionHolder@ba86ef] for key [org.springframework.jdbc.datasource.DriverManagerDataSource@1b9658e] to thread [main]
21:44:19,546 DEBUG TransactionSynchronizationManager:258 - Initializing transaction synchronization
21:44:19,547 DEBUG TransactionInterceptor:362 - Getting transaction for [com.bluesky.FooServiceImpl.insertA]
21:44:19,547 DEBUG JdbcTemplate:416 - Executing SQL statement [insert student(name) values('stuA')]
21:44:19,592 DEBUG JdbcTemplate:416 - Executing SQL statement [insert student(name) values('stuB')]
21:44:19,594 DEBUG TransactionInterceptor:406 - Completing transaction for [com.bluesky.FooServiceImpl.insertA] after exception: java.lang.ArithmeticException: / by zero
21:44:19,594 DEBUG RuleBasedTransactionAttribute:130 - Applying rules to determine whether transaction should rollback on java.lang.ArithmeticException: / by zero
21:44:19,594 DEBUG RuleBasedTransactionAttribute:147 - Winning rollback rule is: null
21:44:19,595 DEBUG RuleBasedTransactionAttribute:152 - No relevant rollback rule found: applying default rules
21:44:19,595 DEBUG DataSourceTransactionManager:938 - Triggering beforeCompletion synchronization
21:44:19,595 DEBUG DataSourceTransactionManager:843 - Initiating transaction rollback
21:44:19,596 DEBUG DataSourceTransactionManager:279 - Rolling back JDBC transaction on Connection [com.mysql.jdbc.JDBC4Connection@167f4bf]
21:44:19,598 DEBUG DataSourceTransactionManager:967 - Triggering afterCompletion synchronization
21:44:19,598 DEBUG TransactionSynchronizationManager:316 - Clearing transaction synchronization

Я обнаружил, что при вызове метода insertA() этот метод запускает транзакцию, когда приходит код insertB(), транзакция для запуска отсутствует.

Есть что-то, что я не настроил, или какая-то проблема, которую я ошибся

Я собираюсь, когда insertA() позвонит insertB(), будет REQUIRES_NEW начало транзакции.

Ответы [ 3 ]

5 голосов
/ 29 августа 2011

Рекомендация KLE о рефакторинге вашего кода правильна, но что касается , почему не работает, Spring AOP использует динамические прокси JDK по умолчанию для обеспечения AOP.Это означает, что когда вы внедряете свой сервис во что-то, на самом деле внедряется экземпляр Proxy, который реализует интерфейс вашего сервиса.Когда метод вызывается на этом прокси-сервере, он запускает код транзакции перед передачей его фактическому экземпляру службы.Однако, когда поток управления находится внутри вашего сервиса, вызов другого метода через this.foo() (даже если this неявный) просто вызывает метод для того же экземпляра: вашего сервиса.Он не возвращается к прокси, который является единственным, что знает о транзакциях. Если бы вы переключили на создание байтового кода во время сборки или загрузки с AspectJ, то вы могли бы сделать это, и это сработало бы, как ожидалось, так как код, вызывающий транзакцию, был бы вплетен непосредственно в код вашего сервиса вместопроживание в отдельном объекте.

4 голосов
/ 29 августа 2011

Я понимаю вашу проблему. Есть несколько технически сложных способов заставить это работать, но мы обычно не считаем, что они того стоят. Я предлагаю другой подход, простой и мощный, который действительно улучшает ваш код.

Вместо того, чтобы использовать их на одном и том же весеннем бобе, используйте их на двух разных бобах, B вводится в A.

Я знаю, что не отвечаю на ваш вопрос, но подумайте о преимуществах:

  • Очень просто, это будет стоить вам очень немного времени .
  • Чтобы запросить новую транзакцию, B, вероятно, является другой проблемой. Иная забота - это другой класс, кажется, именно то, что мы ищем, хороший дизайн .
  • У вас нет ничего нового и сложного, чтобы объяснить его коллегам (или документ для будущих разработчиков), это простота делает это немедленно понятным .
2 голосов
/ 29 августа 2011

Ответ KLE - твердый совет. Чтобы завершить картину, есть - обходной путь, но он ломает все, что означает АОП: 

public void insertA() {
    this.getJdbcTemplate().execute("insert student(name) values('stuA')");
    // this works, but... gah!
    ((FooServiceIface) AopContext.currentProxy()).insertB();
    int i=10/0;
}

Справка:

...