spring - 使用 isolation_serializable 使用 Spring 和 hibernate 进行事务管理

Question

我正在使用 Spring 事务管理来控制带休眠的应用程序，它使用两个线程实例来访问并发数据库并修改一个表。它确保值被保存。之前的表格是:

   quantidade_livro_id | quantidade | livro_id | tt 
  ---------------------+------------+----------+----
                     7 |        100 |        3 | as 
                     5 |        100 |        1 | as
                     6 |        100 |        2 | as

后面的表格:

   quantidade_livro_id | quantidade | livro_id | tt 
  ---------------------+------------+----------+----
               7 |        100 |        3 | as
               5 |         50 |        1 | as
               6 |        150 |        2 | as

主要代码启动了两个线程:

        Servico t1 = new Servico();
        Servico t2 = new Servico();
        //transaction 1
        t1.setId1(5);
        t1.setValorTransacao(50);
        t1.setId2(6);
        //transaction 2     
        t2.setId1(5);   
        t2.setValorTransacao(100);
        t2.setId2(7);   

        //start transaction 1
        t1.start();
        //start transaction 2
        t2.start(); 

Servico 类是:

public void run() {
        executa();
    }


public void executa(){
    ApplicationContext appContext = 
            new ClassPathXmlApplicationContext("spring/config/BeanLocations.xml");

    livroQuantidadeBo = (LivroQuantBo)appContext.getBean("livroQuantBoProxy");
    try {
        livroQuantidadeBo.transacao(getId1(),getValorTransacao(),getId2());
    } catch (RuntimeException e) {
        // TODO Auto-generated catch block
        System.out.println(e);
    }

类 LivroQuantBoImpl 有方法:

public void transacao(int id1,int valorTransferencia, int id2) throws RuntimeException{
    LivroQuantidade livroQ = livroQuantDao.find(id1);
    LivroQuantidade livroQ2 = livroQuantDao.find(id2);
    if(livroQ.getQuantidade() - valorTransferencia >= 0){
        livroQ.setQuantidade(livroQ.getQuantidade() - valorTransferencia);
        livroQ2.setQuantidade(valorTransferencia + livroQ2.getQuantidade());
        livroQuantDao.update(livroQ);
        livroQuantDao.update(livroQ2);
    }
}

我的 Spring .conf 是:

    <!--  DATASOURCE -->  
    <bean 
    class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location">
            <value>properties/database.properties</value>
        </property>
    </bean>

    <bean id="dataSource" 
             class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="${jdbc.driverClassName}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
    </bean>


    <!-- HIBERNATE -->

    <!-- Hibernate session factory -->
    <bean id="sessionFactory" 
         class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">

        <property name="dataSource">
          <ref bean="dataSource"/>
        </property>

        <property name="hibernateProperties">
           <props>
             <prop key="hibernate.dialect">org.hibernate.dialect.PostgreSQLDialect</prop>
             <prop key="hibernate.show_sql">true</prop>
           </props>
         </property>

         <property name="mappingResources">
        <list>
               <value>hibernate/Livro.hbm.xml</value>
               <value>hibernate/LivroQuantidade.hbm.xml</value>
        </list>
          </property>   

        </bean>

    <!-- TRANSAÇÃO  -->

    <bean id="transactionInterceptor" class="org.springframework.transaction.interceptor.TransactionInterceptor">
        <property name="transactionManager" ref="transactionManager" />
        <property name="transactionAttributes">
        <props>
        <prop key="save">PROPAGATION_REQUIRED</prop>
        <prop key="transacao">PROPAGATION_REQUIRED</prop>
        <prop key="transacao">ISOLATION_SERIALIZABLE</prop>
        </props>
        </property>
    </bean>

    <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <property name="dataSource" ref="dataSource" />
        <property name="sessionFactory" ref="sessionFactory" />
    </bean>


    <!-- BEANS -->
        <!-- Livro business object -->
       <bean id="livroBo" class="br.com.spring.bo.LivroBoImpl" >
            <property name="livroDao" ref="livroDao" />
            <property name="livroQuantBo" ref="livroQuantBo" />
       </bean>

       <!-- Livro Data Access Object -->
       <bean id="livroDao" class="br.com.spring.dao.LivroDaoImpl" >
            <property name="sessionFactory" ref="sessionFactory"></property>
       </bean>

        <!-- ProductQoh business object -->
       <bean id="livroQuantBo" class="br.com.spring.bo.LivroQuantBoImpl" >
            <property name="livroQuantDao" ref="livroQuantDao" />
       </bean>

       <!-- ProductQoh Data Access Object -->
       <bean id="livroQuantDao" class="br.com.spring.dao.LivroQuantDaoImpl" >
            <property name="sessionFactory" ref="sessionFactory"></property>
       </bean>

     <!-- PROXY -->

       <bean id="livroBoProxy"
            class="org.springframework.aop.framework.ProxyFactoryBean">
            <property name="target" ref="livroBo" />
            <property name="interceptorNames">
                <list>
                    <value>transactionInterceptor</value>
                </list>
            </property>
       </bean>

        <bean id="livroQuantBoProxy"
            class="org.springframework.aop.framework.ProxyFactoryBean">
            <property name="target" ref="livroQuantBo" />
            <property name="interceptorNames">
                <list>
                    <value>transactionInterceptor</value>
                </list>
            </property>
       </bean>

它正在执行此运行时异常:

 Hibernate: select livroquant0_.quantidade_livro_id as quantidade1_2_, livroquant0_.quantidade as quantidade2_, livroquant0_.livro_id as livro3_2_ from springhibernate2.quantidadeLivro livroquant0_ where livroquant0_.quantidade_livro_id=?
 Hibernate: select livroquant0_.quantidade_livro_id as quantidade1_3_, livroquant0_.quantidade as quantidade3_, livroquant0_.livro_id as livro3_3_ from springhibernate2.quantidadeLivro livroquant0_ where livroquant0_.quantidade_livro_id=?
 Hibernate: select livroquant0_.quantidade_livro_id as quantidade1_3_, livroquant0_.quantidade as quantidade3_, livroquant0_.livro_id as livro3_3_ from springhibernate2.quantidadeLivro livroquant0_ where livroquant0_.quantidade_livro_id=?
 Hibernate: select livroquant0_.quantidade_livro_id as quantidade1_2_, livroquant0_.quantidade as quantidade2_, livroquant0_.livro_id as livro3_2_ from springhibernate2.quantidadeLivro livroquant0_ where livroquant0_.quantidade_livro_id=?
 Hibernate: update springhibernate2.quantidadeLivro set quantidade=?, livro_id=? where quantidade_livro_id=?
 Hibernate: update springhibernate2.quantidadeLivro set quantidade=?, livro_id=? where quantidade_livro_id=?
 Hibernate: update springhibernate2.quantidadeLivro set quantidade=?, livro_id=? where quantidade_livro_id=?
 Hibernate: update springhibernate2.quantidadeLivro set quantidade=?, livro_id=? where quantidade_livro_id=?
 Nov 6, 2012 3:02:49 PM org.hibernate.util.JDBCExceptionReporter logExceptions
 WARNING: SQL Error: 0, SQLState: 40001
 Nov 6, 2012 3:02:49 PM org.hibernate.util.JDBCExceptionReporter logExceptions
 SEVERE: Batch entry 0 update springhibernate2.quantidadeLivro set quantidade='0', livro_id='1' where quantidade_livro_id='5' was aborted.  Call getNextException to see the cause.
 Nov 6, 2012 3:02:49 PM org.hibernate.util.JDBCExceptionReporter logExceptions
 WARNING: SQL Error: 0, SQLState: 40001
 Nov 6, 2012 3:02:49 PM org.hibernate.util.JDBCExceptionReporter logExceptions
 SEVERE: ERROR: could not serialize access due to concurrent update
 Nov 6, 2012 3:02:49 PM org.hibernate.event.def.AbstractFlushingEventListener performExecutions
 SEVERE: Could not synchronize database state with session
 org.hibernate.exception.LockAcquisitionException: Could not execute JDBC batch update
     at org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:82)
     at org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:43)
     at org.hibernate.jdbc.AbstractBatcher.executeBatch(AbstractBatcher.java:254)
     at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:237)
     at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:142)
     at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:298)
     at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:27)
     at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1000)
     at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:338)
     at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:106)
     at org.springframework.orm.hibernate3.HibernateTransactionManager.doCommit(HibernateTransactionManager.java:656)
     at org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(AbstractPlatformTransactionManager.java:754)
     at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:723)
     at org.springframework.transaction.interceptor.TransactionAspectSupport.commitTransactionAfterReturning(TransactionAspectSupport.java:393)
     at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:120)
     at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
     at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:202)
     at $Proxy0.transacao(Unknown Source)
     at br.com.spring.service.Servico.executa(Servico.java:29)
     at br.com.spring.service.Servico.run(Servico.java:19)
  Caused by: java.sql.BatchUpdateException: Batch entry 0 update springhibernate2.quantidadeLivro set quantidade='0', livro_id='1' where quantidade_livro_id='5' was aborted.  Call getNextException to see the cause.
at org.postgresql.jdbc2.AbstractJdbc2Statement$BatchResultHandler.handleError(AbstractJdbc2Statement.java:2621)
at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1837)
at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:407)
at org.postgresql.jdbc2.AbstractJdbc2Statement.executeBatch(AbstractJdbc2Statement.java:2754)
at org.hibernate.jdbc.BatchingBatcher.doExecuteBatch(BatchingBatcher.java:48)
at org.hibernate.jdbc.AbstractBatcher.executeBatch(AbstractBatcher.java:247)
... 17 more
   org.springframework.dao.CannotAcquireLockException: Could not execute JDBC batch update; SQL [update springhibernate2.quantidadeLivro set quantidade=?, livro_id=? where quantidade_livro_id=?]; nested exception is org.hibernate.exception.LockAcquisitionException: Could not execute JDBC batch update

怎么了？

Answer 1

您可以查看以下链接以了解主题 12.2.2。可序列化隔离级别

http://www.postgresql.org/docs/8.1/static/transaction-iso.html