Spring глобальная транзакция совершается после получения элемента - PullRequest
Новая
       19

Spring глобальная транзакция совершается после получения элемента

0 голосов
/ 28 июня 2011

Я использую Spring и Hibernate с Jta Transactions, у меня есть 2 базы данных, и у меня возникла проблема в транзакционном методе.

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

Но если я добавлю строку в метод, который получает объекты из той же таблицы, объекты будут зафиксированы в базе данных.

Я думаю, что когда я делаю SELECT, объекты автоматически фиксируются, потому что исключение выдается снова и объекты сохраняются в базе данных.

Мой xml и код:

dao.xml 

<bean
    class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    <property name="locations" value="classpath:configuracion_dao.properties" />
</bean>

<bean name="productosDAO" class="practica1.hibernate.HibernateProductosDAOImpl"
    parent="abstractPracticaBean">
    <property name="sessionFactory" ref="hibernateSessionFactory" />
</bean>

<bean name="tercerosDAO" class="${tercerosDAO.classname}" parent="abstractPracticaBean">
    <property name="dataSource" ref="dataSourceDatos" />
</bean>

<bean name="auditoriaDAO" class="practica1.hibernate.HibernateAuditoriaDAOImpl" parent="abstractPracticaBean">
    <property name="sessionFactory" ref="hibernateSessionFactory2" />
</bean>


<bean id="hibernateSessionFactory"
    class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
    <property name="dataSource" ref="dataSourceDatos" />
    <property name="mappingResources">
        <list>
            <value>hibernate-mappings.hbm.xml</value>
        </list>
    </property>
    <property name="hibernateProperties">
        <value>
            hibernate.dialect=org.hibernate.dialect.HSQLDialect
  </value>
    </property>
</bean>

<bean id="hibernateSessionFactory2"
    class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
    <property name="dataSource" ref="dataSourceAuditoria" />
    <property name="mappingResources">
        <list>
            <value>hibernate-mappings-auditoria.hbm.xml</value>
        </list>
    </property>
    <property name="hibernateProperties">
        <value>
            hibernate.dialect=org.hibernate.dialect.HSQLDialect
  </value>
    </property>
</bean>


<bean name="dataSourceDatos" class="org.enhydra.jdbc.standard.StandardXADataSource">
    <property name="driverName" value="org.apache.derby.jdbc.EmbeddedDriver" />
    <property name="url" value="jdbc:derby:/tmp/datos.db;create=true" />
    <property name="transactionManager" value="#{txManager.transactionManager}" />
</bean>

<jdbc:initialize-database data-source="dataSourceDatos"
    ignore-failures="ALL">
    <jdbc:script location="classpath:practica1/sql/creacion_derby.sql" />
    <jdbc:script location="classpath:practica1/sql/datos.sql" />
</jdbc:initialize-database>

<bean name="dataSourceAuditoria" class="org.enhydra.jdbc.standard.StandardXADataSource">
    <property name="driverName" value="org.apache.derby.jdbc.EmbeddedDriver" />
    <property name="url" value="jdbc:derby:/tmp/auditoria.db;create=true" />
    <property name="transactionManager" value="#{txManager.transactionManager}" />
</bean>

<jdbc:initialize-database data-source="dataSourceAuditoria"
    ignore-failures="ALL">
    <jdbc:script location="classpath:practica1/sql/creacion_auditoria_derby.sql" />
</jdbc:initialize-database>

<bean id="txManager"
    class="org.springframework.transaction.jta.JtaTransactionManager">
    <property name="transactionManager" value="#{jotm.transactionManager}" />
    <property name="userTransaction" value="#{jotm.userTransaction}" />
</bean>

<bean id="jotm" class="org.objectweb.jotm.Jotm" destroy-method="stop">
    <constructor-arg value="true" />
    <constructor-arg value="false" />
</bean>

<tx:annotation-driven transaction-manager="txManager" />

bo.xml 

<bean name="tercerosBO" class="practica1.impl.TercerosBOImpl"
    parent="abstractPracticaBean" autowire="constructor">

</bean>
<bean name="productosBO" class="practica1.impl.ProductosBOImpl"
    parent="abstractPracticaBean">
    <property name="productosDAO" ref="productosDAO" />
    <property name="auditoriaDAO" ref="auditoriaDAO" />
</bean>

aplicacion.xml 

<bean id="messageSource"
    class="org.springframework.context.support.ResourceBundleMessageSource">
    <property name="basenames" value="mensajes" />
</bean>

<bean id="abstractPracticaBean" class="practica1.impl.AbstractPracticaBean" abstract="true">
    <property name="messageSource" ref="messageSource"></property>
</bean>

<import resource="bo.xml" />
<import resource="dao.xml" />

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

@Transactional
@Override
public void actualizaPrecio(double porcentaje) {
    internalActualizaPrecio(porcentaje);
}
private void internalActualizaPrecio(double porcentaje) {
    auditoriaDAO.insertAuditoria(getMessageSource().getMessage(
            "mensaje.actualizar_productos", new Object[] { porcentaje },
            null));
    int i = 0;
    auditoriaDAO.getAuditorias(); // Without this line its works like I expected
    List<Producto> productos = productosDAO.getProductos();
    for (Producto producto : productos) {
        i++;
        if (i > 3)
            throw new UnsupportedOperationException(
                    "Error para que veamos las transacciones");
        producto.setPrecio(producto.getPrecio().multiply(
                new BigDecimal(porcentaje).divide(new BigDecimal(100))));
        productosDAO.updateProducto(producto);
    }
}

Я понял, что если я использую auditoriaDAO.getAuditorias (), откат влияет только на Producto, но если я использую productoDAO.getProductos (), откат влияет только на Auditoria ...

Ответы [ 2 ]

1 голос
/ 28 июня 2011

Вы можете смешивать flush и commit здесь: оператор SELECT обычно сбрасывает все предыдущие операторы SQL, чтобы получить свежие данные (относительно предыдущих изменений Вы сделали в TX). Может случиться так, что перед выполнением такого оператора SELECT (если я не ошибаюсь, 2nd sessionFactory выполняются следующие вызовы DAO), исключение выходит из метода без flush . Следовательно, нет изменений в базе данных.

Итак, вопрос: вы уверены, что эффективно откатываете передачу? Я вижу, вы аннотировали метод private: механизм Spring AOP на основе прокси не справляется с этим! Вы должны аннотировать метод public и вызывать его извне класса аннотированного метода из-за этого очень основанного на прокси механизма. См. «Видимость метода и @Transactional» в документации .

Другой вывод: у вас есть 2 sessionFactories, поэтому я предполагаю, что вы используете транзакции / источники данных XA: вы уверены, что эта часть конфигурации в порядке?

0 голосов
/ 28 июня 2011

Пожалуйста, проверьте auditoriaDAO и productosDAO и для поиска другой транзакционной аннотации . Я думаю, что новая транзакция создается где-то, и UnsupportedException откатывает только последнюю транзакцию , и родительская транзакция фиксируется. Надеюсь, я помог!

Я нашел два примера. Пожалуйста, проверьте это.

JOTM транзакции весной и в спящем режиме

Доступ к нескольким базам данных с использованием Spring 3, Hibernate 3 и Atomikos

...