Откат не работает для моего автономного приложения Spring

Я работаю над автономным приложением spring/jpa/hibernate.

Проблема, с которой я сталкиваюсь, заключается в том, что мое приложение не отменяет транзакции, даже если возникает исключение RuntimeException.

Вот моя конфигурация:

 <context:annotation-config />
    <context:component-scan base-package="com.jeanbaptistemartin"/>
    <context:property-placeholder location="classpath:application.properties"/>
    <bean id="gestionnaireMailing" class="com.jeanbaptistemartin.desktop.JFrameGestionnaireMailing" init-method="init" >

    </bean>

    <bean id="cacheManager" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean">
        <property name="configLocation" value="classpath:ehcache.xml"/>
        <property name="shared" value="true"/>
    </bean>

    <bean id="mailSender" class="org.springframework.mail.javamail.JavaMailSenderImpl">
        <property name="host" value="${mail.server}"/>
        <property name="port" value="${mail.port}"/>
        <property name="javaMailProperties">
            <props>
                <prop key="mail.smtp.connectiontimeout">2000</prop>    
                <prop key="mail.smtp.timeout">2000</prop>    
            </props>    
        </property>
    </bean>
    <bean id="velocityEngine" class="org.springframework.ui.velocity.VelocityEngineFactoryBean">
        <property name="velocityProperties">
            <value>
            resource.loader=class
            class.resource.loader.class=org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader
            </value>
        </property>
    </bean>
    <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
        <property name="persistenceUnitName" value="jbmPU" />
        <property name="persistenceXmlLocation" value="classpath:/META-INF/persistence.xml" />
        <property name="dataSource" ref="dataSource" />
        <property name="jpaVendorAdapter">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
                <property name="showSql" value="${database.showSql}" />
                <property name="generateDdl" value="${database.generateDdl}"/>
                <property name="databasePlatform" value="${database.dialect}"/>
            </bean>
        </property>
    </bean>
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${database.driver}"/>
        <property name="jdbcUrl" value="${database.url}"/>
        <property name="user" value="${database.username}"/>
        <property name="password" value="${database.password}"/>
        <property name="minPoolSize" value="5" />
        <property name="maxPoolSize" value="20" />
        <property name="idleConnectionTestPeriod" value="3000" />
        <property name="loginTimeout" value="300" />
    </bean>
    <bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" />
    <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
        <property name="entityManagerFactory" ref="entityManagerFactory" />
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <tx:annotation-driven transaction-manager="transactionManager" />

Мой транзакционный метод:

 @Transactional(propagation = Propagation.REQUIRED, rollbackFor = {RuntimeException.class})
    public boolean mailAbonne(List<Sculpture> sculpturesChoisiesPourMailing, Abonne abonne) {
        try {
            for (Sculpture sculpture : sculpturesChoisiesPourMailing) {
                MailingAbonnePK mapk = new MailingAbonnePK(sculpture.getSculptureID(), abonne.getAbonneID());
                MailingAbonne ma = new MailingAbonne(mapk, new Date());
                dao.persistMailingAbonnee(ma);
            }
            envoyerMail(sculpturesChoisiesPourMailing, abonne);//this method sometimes throws a RuntimeException.
            return true;
        } catch (RuntimeException e) {
            log.error("Exception");
            log.error(e);
            throw new RuntimeException();
        }
    }

В моем дао:

@PersistenceContext(type = PersistenceContextType.TRANSACTION)
    private EntityManager entityManager;

Теперь немного о текущем поведении моего приложения:

когда envoyerMail вызывает исключение RuntimeException или его подкласс, приложения просто зависают на неопределенный срок.

Теперь еще одно слово о желаемом поведении моего приложения.

Мой метод mailAbonne вызывается в цикле следующим образом:

 for (Abonne abonne : totalAbonnes) {
   mailAbonne(sculpturesChoisiesPourMailing, abonne);
}

В идеале я хотел бы, чтобы одна итерация цикла завершилась неудачей или завершилась успешно атомарно, т. е. если исключение RuntimeException возникает на итерации 3 из 5 итераций, я должен иметь в своей базе данных данные, соответствующие 4 успешных итерации, и данные, соответствующие неудачной итерации, будут отброшены.

Кто-нибудь может помочь?

J.


person balteo    schedule 06.05.2011    source источник


Ответы (1)


Прежде всего, вам не нужно указывать rollbackFor = {RuntimeException.class}. Поведение по умолчанию — откат для любого исключения времени выполнения.

Ваша проблема заключается в том, что вы вызываете свой транзакционный метод из другого метода того же компонента. Spring запускает и останавливает транзакции автоматически, потому что он оборачивает каждый bean-компонент внутри прокси-сервера, который обрабатывает эту работу с транзакциями. Когда вы вызываете метод из того же bean-компонента, прокси-сервер не может перехватить вызов и запустить/остановить транзакцию за вас. Таким образом, вы должны поместить транзакционный метод в другой компонент.

Тогда для вашей итерации. Для работы нужно

  • сделать метод, содержащий цикл, не транзакционным, чтобы каждый вызов mailAbonne запускал новую транзакцию
  • или сделать распространение метода mailAbonne REQUIRES_NEW, чтобы он имел свою собственную независимую транзакцию

Конечно, вам также необходимо заключать каждый вызов mailAbonne в цикл внутри блока try/catch, чтобы перехватывались исключения во время выполнения и можно было выполнить следующий вызов mailAbonne, даже если текущий не удался.

person JB Nizet    schedule 06.05.2011
comment
Большое спасибо JB Nizet! Я не знал об этом весной. Ваш совет решил проблему. Еще раз спасибо, Жюльен. - person balteo; 06.05.2011