Transacciones en Spring e ibatis

edjuradob · #1 (**permalink**) 22/07/2011, 01:12

Hola

Tengo un proyecto en el que estoy utilizando spring 1.2, ibatis 2.3 y Tomcat 6
Estoy configurando las transacciones para que se manejen mediante Spring, sin embargo, no esta funcionando correctamente.
Lo que quiero es que las transacciones esten a nivel de servicio y no a nivel DAO (para no poner toda la lógica de negocio en el DAO).
El problema es que esta generando dos transacciones distintas para cada inserción, por tanto, si genero un error, no hace el rollback y si lo dejo que ponga el read uncommited, da un error de restricción de integridad (no existe la Foreign key de la primera inserción)

Abajo mi código:

transaction-context:

Código XML:

Ver original<bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
    </bean>
 
<bean id="baseTransactionProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" abstract="true">
        <property name="transactionManager" ref="transactionManager"/>
        <property name="transactionAttributes">
            <props>
                <prop key="insert*">
                    PROPAGATION_REQUIRED,                   ISOLATION_READ_UNCOMMITTED,-BDException,-TablonException
                </prop>
            </props>
<!--siguientes prop keys...-->
        </property>
    </bean>
<!-- datasource -->
    <bean id="dataSource" class="com.ibatis.common.jdbc.SimpleDataSource"
    destroy-method="close">
 
        <constructor-arg>
            <map>
                <entry key="JDBC.Driver">
                    <value>${jdbc.driverClassName}</value>
                </entry>
                <entry key="JDBC.ConnectionURL">
                    <value>${jdbc.url}</value>
                </entry>
                <entry key="JDBC.Username">
                    <value>${jdbc.username}</value>
                </entry>
                <entry key="JDBC.Password">
                    <value>${jdbc.password}</value>
                </entry>
                <entry key="JDBC.DefaultAutoCommit">
                    <value>false</value>
                </entry>
            </map>
        </constructor-arg>
 
    </bean>

en persistence-comu-context:

Código XML:

Ver original<bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
        <property name="configLocation">
            <value>
                /WEB-INF/config/sqlMapConfig.xml
            </value>
        </property>
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
    </bean>
<!--    DAOS:    -->
<bean id="UnDAOTarget" class="myPackage.dao.impl.UnDAOImpl" >
        <property name="sqlMapClient">
            <ref bean="sqlMapClient " />
        </property>
        <property name="dataSource" ref="dataSource" />
    </bean>

hualro · #2 (**permalink**) 22/07/2011, 18:14

Estas cerrando la transaccion primera en alguna parte? ya que tienes PROPAGATION_REQUIRED y se supone que deberia correr en la transaccion que esta en curso y si no, genera una.

edjuradob · #3 (**permalink**) 02/08/2011, 02:28

Hola

Que me he ido de vacaciones y no habia visto la respuesta.
No, no estoy cerrando las transacciones (al menos no explicitamente), de hecho, quiero que las dos inserciones se hagan en la misma transacción y solo especifico que haga el rollback en la captura de la excepcion. Lo que quiero es que si falla la segunda haga el rollback, pero no esta haciendo ni caso a esta configuración.

El hecho es que si le pongo en el datasource la propiedad

Código XML:

Ver original<entry key="JDBC.DefaultAutoCommit">
              <value>false</value>
 </entry>

da el error de integridad (no existe la foreign key que pretende usar en la segunda inserción, que debió insertarse en la primera inserción exitosa, aun teniendo el ISOLATION_READ_UNCOMMITTED).

Sin embargo, si le pongo el autocommit a true, cuando falla la segunda, no hace el rollback.

Lo he intentado ahora con el JOTM y he llegado al mismo punto.

edjuradob · #4 (**permalink**) 03/08/2011, 02:20

He logrado hacer que este todo en una sola transaccion utilizando el JOTM y JTA., sin embargo, no esta haciendo el commit en la base de datos, aunque en el log me dice que si que lo hace.

Mi código con JOTM:

Código XML:

Ver original<bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean"/>
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
  <property name="userTransaction">
   <ref local="jotm"/>
  </property>
 </bean>
 
 
<!-- <bean id="baseTransactionProxy" class="org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource" > -->
    <bean id="baseTransactionProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" >   
        <property name="transactionManager">
         <ref local="transactionManager"/>
        </property>
        <property name="target" ref="publicacionesTarget"/>
    
        <property name="transactionAttributes">
            <props>
                <prop key="update*">
                    PROPAGATION_REQUIRED,
                    ISOLATION_DEFAULT,-BDException,-TablonException,  readOnly
                </prop>
                <prop key="set*">
                    PROPAGATION_REQUIRED,
                    ISOLATION_DEFAULT,-BDException,-TablonException,  readOnly
                </prop>
                <prop key="insert*">
                    PROPAGATION_REQUIRED,
                    ISOLATION_READ_UNCOMMITTED,-BDException,-TablonException
                </prop>
                <prop key="delete*">
                    PROPAGATION_REQUIRED,
                    ISOLATION_DEFAULT,-BDException,-TablonException, readOnly
                </prop>
                <prop key="select*">
                    PROPAGATION_REQUIRED,
                    ISOLATION_READ_UNCOMMITTED,-BDException,-TablonException
                </prop>
                <!-- <prop key="select*">
                    PROPAGATION_SUPPORTS,
                    ISOLATION_READ_UNCOMMITTED, readOnly
                </prop> -->
                <prop key="get*">
                    PROPAGATION_SUPPORTS, ISOLATION_DEFAULT, readOnly
                </prop>
            </props>
        </property> 
    </bean>
    
    
    <!-- datasource -->
    <bean id="dataSource" class="com.ibatis.common.jdbc.SimpleDataSource"
    destroy-method="close">
<!--        destroy-method="finalize"> -->
        <constructor-arg>
            <map>
                <entry key="JDBC.Driver">
                    <value>${jdbc.driverClassName}</value>
                </entry>
                <entry key="JDBC.ConnectionURL">
                    <value>${jdbc.url}</value>
                </entry>
                <entry key="JDBC.Username">
                    <value>${jdbc.username}</value>
                </entry>
                <entry key="JDBC.Password">
                    <value>${jdbc.password}</value>
                </entry>
                <entry key="JDBC.DefaultAutoCommit">
                    <value>false</value>
                </entry>
            </map>
        </constructor-arg>
 
    </bean>

Ahora, en mi action, cuando le digo lo de la transacción hago lo siguiente:

Código Java:

Ver originalJtaTransactionManager tm = (JtaTransactionManager) CargadorBeans.localizar("transactionManager");           
        TransactionStatus transactionStatus =tm.getTransaction(null);       
 
        try {
            forward = ejecutar(mapping, form, request, response);
            tm.commit(transactionStatus);
    
        }catch (Exception e){ 
            //tratamiento excepciones
            tm.rollback(transactionStatus);
        
        }

y en el log, me dice que hace lo siguiente:

Código LOG:

Ver original2011/08/03 09:31:13,105 DEBUG org.springframework.transaction.support.AbstractPlatformTransactionManager.handleExistingTransaction(438)===> Participating in existing transaction
2011/08/03 09:31:13,105 DEBUG org.springframework.transaction.interceptor.TransactionAspectSupport.prepareTransactionInfo(279)===> Getting transaction for [MiPaquete.clase.metodo]
2011/08/03 09:31:13,105 DEBUG org.springframework.transaction.support.TransactionSynchronizationManager.getResource(140)===> Retrieved value [org.springframework.jdbc.datasource.ConnectionHolder@a65760] for key [com.ibatis.common.jdbc.SimpleDataSource@1b64b70] bound to thread [http-8080-1]
2011/08/03 09:31:13,105 DEBUG com.ibatis.common.logging.jakarta.JakartaCommonsLoggingImpl.debug(27)===> {conn-100020} Connection
 
...Sentencias SQL...

y despues de eejecutar las sentencias sql, sigue con lo siquiente:

Código LOG:

Ver original2011/08/03 09:31:13,136 DEBUG org.springframework.transaction.interceptor.TransactionAspectSupport.commitTransactionAfterReturning(309)===> Completing transaction for [miPaquete.clase.metodo]
2011/08/03 09:31:13,136 DEBUG org.springframework.transaction.support.AbstractPlatformTransactionManager.triggerBeforeCommit(822)===> Triggering beforeCommit synchronization
2011/08/03 09:31:13,136 DEBUG org.springframework.transaction.support.AbstractPlatformTransactionManager.triggerBeforeCompletion(835)===> Triggering beforeCompletion synchronization
2011/08/03 09:31:13,136 DEBUG org.springframework.transaction.support.TransactionSynchronizationManager.unbindResource(193)===> Removed value [org.springframework.jdbc.datasource.ConnectionHolder@a65760] for key [com.ibatis.common.jdbc.SimpleDataSource@1b64b70] from thread [http-8080-1]
2011/08/03 09:31:13,136 DEBUG org.springframework.jdbc.datasource.DataSourceUtils.doReleaseConnection(312)===> Returning JDBC Connection to DataSource
2011/08/03 09:31:13,136 DEBUG com.ibatis.common.logging.jakarta.JakartaCommonsLoggingImpl.debug(27)===> Returned connection 33020888 to pool.
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.TransactionImpl.getStatus(581)===> TransactionImpl.getStatus()
2011/08/03 09:31:13,136 DEBUG org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(649)===> Initiating transaction commit
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.Current.commit(464)===> tx=bb14:38:0:012ceab1ed5eb54f6c...980c02:
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.TransactionImpl.commit(209)===> TransactionImpl.commit (tx= bb14:38:0:012ceab1ed5eb54f6c...980c02:)
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.TransactionImpl.unsetTimer(919)===> unset timer for tx (timer=org.objectweb.jotm.TimerEvent@1c4d594, tx=bb14:38:0:012ceab1ed5eb54f6c...980c02:)
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.TimerEvent.unset(123)===> TimerEvent(bb14:38:0:012ceab1ed5eb54f6c...980c02:).unset
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.Current.forgetTx(1147)===> xid=bb14:38:0:012ceab1ed5eb54f6c...980c02:
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.Current.forgetTx(1156)===> threadTx.set = null
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.Current.removeTxXid(1756)===> remove tx from xid (xid=bb14:38:0:012ceab1ed5eb54f6c...980c02:)
2011/08/03 09:31:13,136 DEBUG org.objectweb.jotm.Current.commit(476)===> threadTx.set null

y el id de la transaccion (bb14:38:0:012ceab1ed5eb54f6c...980c02) es el mismo de la primera transacción generada, es decir, es correcta la transacción que se cierra y se supone hace el commit.

¿tengo algo mal? ¿me hace falta incluir algo?