我对@Transactional 超时属性的行为感到困惑

我有以下顺序

Main ->
UserExecutionServiceImpl.executeRecordInvoice ->
ProcessInvoiceServiceImpl.recordInvoice ->
WarehouseServiceImpl.checkStockAvailability

强制回滚异常超时设置为0。

如果executeRecordInvoice 具有@Transactional(timeout=0),则会引发异常,并停止所有操作。有道理

如果 executeRecordInvoice 具有@Transactional recordInvoice 具有@Transactional(timeout=0),则不会引发异常。实际上,超时值已被忽略。

我可以假设是因为事务处理实际上是从 executeRecordInvoice 开始的,而且因为这两种方法默认都具有Propagation.Required,这意味着,第二个方法( recordInvoice )被认为是在第一个事务( executeRecordInvoice )内,即已存在的事务跑步

更重要的是,我做了两个简单的实验:
  • 如果 executeRecordInvoice 具有@Transactional,而 recordInvoice 具有@Transactional(propagation.Propagation.REQUIRES_NEW, timeout=0),则引发异常。现在可以使用,因为新的事务在记录中开始发票,因此考虑了超时
  • 直接从Main类中调用ProcessInvoiceServiceImpl.recordInvoice,使用@Transactional(propagation.Propagation.REQUIRED, timeout=0)@Transactional(propagation.Propagation.REQUIRES_NEW, timeout=0)调用它,再次考虑超时

  • 到这里为止,我很好,所有人都有道理。但是将1和2应用于 WarehouseServiceImpl.checkStockAvailability ,则不起作用:
  • 如果 executeRecordInvoice record发票具有@Transactional(因此默认为Propagation.REQUIRED)和 checkStockAvailability 具有@Transactional(propagation.Propagation.REQUIRES_NEW, timeout=0)。唯一的例外是而不是!
  • 直接从Main类中调用WarehouseServiceImpl.checkStockAvailability,它是@Transactional(propagation.Propagation.REQUIRED, timeout=0)@Transactional(propagation.Propagation.REQUIRES_NEW, timeout=0),再次是超时,而不是

  • 类声明
    @Service
    @Transactional
    @Scope("prototype")
    public class WarehouseServiceImpl implements WarehouseService {
    
        // Unique method implementation
        @Transactional(propagation = Propagation.REQUIRES_NEW, timeout=0)
        public boolean checkStockAvailability(Product product, BigDecimal quantity) {
    
            ...
    
        return true;
    
        }
    }
    

    任何想法或建议都欢迎。

    Spring Framework 4.0.5

    谢谢。

    在提出安德烈的建议之后,我有以下几点:
    @Transactional
    @Scope("prototype")
    @Service("processInvoiceService")
    public class ProcessInvoiceServiceImpl implements ProcessInvoiceService {
    
        @Override
        @Transactional(propagation = Propagation.REQUIRES_NEW, timeout=0)
        public void recordInvoice(InvoiceHeader invoiceHeader) {
    

    并在MainTest类中
    ProcessInvoiceService processInvoiceService = context.getBean(ProcessInvoiceService.class);
    
            try{
                processInvoiceService.recordInvoice(invoiceHeader03);
            }
            catch(Exception e){
                logger.error("ERROR ALFA: {}", e.getMessage());
            }
    

    使用显示控制台,部分显示在结果输出中
    Creating instance of bean 'processInvoiceService'
    20:16:57,320 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'productService'
    20:16:57,320 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'invoiceHeaderService'
    20:16:57,320 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'invoiceDetailService'
    20:16:57,321 DEBUG ctory.support.DefaultListableBeanFactory: 449 - Creating instance of bean 'warehouseServiceImpl'
    20:16:57,321 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'org.springframework.transaction.config.internalTransactionAdvisor'
    20:16:57,321 DEBUG xy.InfrastructureAdvisorAutoProxyCreator: 593 - Creating implicit proxy for bean 'warehouseServiceImpl' with 0 common interceptors and 1 specific interceptors
    20:16:57,321 DEBUG amework.aop.framework.JdkDynamicAopProxy: 117 - Creating JDK dynamic proxy: target source is SingletonTargetSource for target object [com.manuel.jordan.model.service.support.impl.WarehouseServiceImpl@7b4c50bc]
    20:16:57,321 DEBUG ctory.support.DefaultListableBeanFactory: 477 - Finished creating instance of bean 'warehouseServiceImpl'
    20:16:57,322  INFO e.process.impl.ProcessInvoiceServiceImpl:  46 - ProcessInvoiceServiceImpl arg constructor
    20:16:57,322 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'org.springframework.transaction.config.internalTransactionAdvisor'
    20:16:57,322 DEBUG xy.InfrastructureAdvisorAutoProxyCreator: 593 - Creating implicit proxy for bean 'processInvoiceService' with 0 common interceptors and 1 specific interceptors
    20:16:57,322 DEBUG amework.aop.framework.JdkDynamicAopProxy: 117 - Creating JDK dynamic proxy: target source is SingletonTargetSource for target object [com.manuel.jordan.model.service.process.impl.ProcessInvoiceServiceImpl@5884a914]
    20:16:57,322 DEBUG ctory.support.DefaultListableBeanFactory: 477 - Finished creating instance of bean 'processInvoiceService'
    20:16:57,322 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    20:16:57,322 DEBUG .datasource.DataSourceTransactionManager: 367 - Creating new transaction with name [com.manuel.jordan.model.service.process.impl.ProcessInvoiceServiceImpl.recordInvoice]: PROPAGATION_REQUIRES_NEW,ISOLATION_DEFAULT,timeout_0; ''
    20:16:57,322 DEBUG k.jdbc.datasource.SimpleDriverDataSource: 138 - Creating new JDBC Driver Connection to [jdbc:hsqldb:mem:testdb]
    20:16:57,323 DEBUG .datasource.DataSourceTransactionManager: 206 - Acquired Connection [org.hsqldb.jdbc.JDBCConnection@50378a4] for JDBC transaction
    20:16:57,323 DEBUG .datasource.DataSourceTransactionManager: 223 - Switching JDBC Connection [org.hsqldb.jdbc.JDBCConnection@50378a4] to manual commit
    20:16:57,323  INFO e.process.impl.ProcessInvoiceServiceImpl:  59 - ProcessInvoiceServiceImpl recordInvoice - start
    20:16:57,323 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    20:16:57,323 DEBUG .datasource.DataSourceTransactionManager: 472 - Participating in existing transaction
    20:16:57,323 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    20:16:57,323 DEBUG .datasource.DataSourceTransactionManager: 472 - Participating in existing transaction
    20:16:57,324 DEBUG g.springframework.jdbc.core.JdbcTemplate: 908 - Executing prepared SQL update
    20:16:57,324 DEBUG g.springframework.jdbc.core.JdbcTemplate: 627 - Executing prepared SQL statement [INSERT INTO invoiceheader(id, number, date, total) VALUES(?, ?, ?, ?)]
    20:16:57,324 DEBUG .datasource.DataSourceTransactionManager: 854 - Participating transaction failed - marking existing transaction as rollback-only
    20:16:57,324 DEBUG .datasource.DataSourceTransactionManager: 295 - Setting JDBC transaction [org.hsqldb.jdbc.JDBCConnection@50378a4] rollback-only
    20:16:57,324 DEBUG .datasource.DataSourceTransactionManager: 854 - Participating transaction failed - marking existing transaction as rollback-only
    20:16:57,325 DEBUG .datasource.DataSourceTransactionManager: 295 - Setting JDBC transaction [org.hsqldb.jdbc.JDBCConnection@50378a4] rollback-only
    20:16:57,325 DEBUG .datasource.DataSourceTransactionManager: 847 - Initiating transaction rollback
    20:16:57,325 DEBUG .datasource.DataSourceTransactionManager: 281 - Rolling back JDBC transaction on Connection [org.hsqldb.jdbc.JDBCConnection@50378a4]
    20:16:57,325 DEBUG .datasource.DataSourceTransactionManager: 324 - Releasing JDBC Connection [org.hsqldb.jdbc.JDBCConnection@50378a4] after transaction
    20:16:57,325 DEBUG ramework.jdbc.datasource.DataSourceUtils: 327 - Returning JDBC Connection to DataSource
    20:16:57,325 ERROR          com.manuel.jordan.main.MainTest:  93 - ERROR ALFA: Transaction timed out: deadline was Mon Jun 30 20:16:57 PET 2014
    20:16:57,325 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    

    错误消息出现在预期的样子。

    现在换另一班
    @Service
    @Transactional
    @Scope("prototype")
    public class WarehouseServiceImpl implements WarehouseService {
    
        private static final Logger logger = LoggerFactory.getLogger(WarehouseServiceImpl.class);
    
        @Override
        @Transactional(propagation = Propagation.REQUIRES_NEW, timeout=0)
        public boolean checkStockAvailability(Product product, BigDecimal quantity) {
    

    并在MainTest类中
    WarehouseService warehouseService = context.getBean(WarehouseService.class);
    
            try{
                logger.info("Pre");
                boolean result = warehouseService.checkStockAvailability(product01, BigDecimal.ZERO);
                logger.info("result: {}", result);
                logger.info("Post");
            }
            catch(Exception e){
                logger.error("ERROR BETA: {}", e.getMessage());
            }
    

    使用显示控制台,部分显示在结果输出中
    20:16:57,337 DEBUG ctory.support.DefaultListableBeanFactory: 449 - Creating instance of bean 'warehouseServiceImpl'
    20:16:57,337 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'org.springframework.transaction.config.internalTransactionAdvisor'
    20:16:57,338 DEBUG xy.InfrastructureAdvisorAutoProxyCreator: 593 - Creating implicit proxy for bean 'warehouseServiceImpl' with 0 common interceptors and 1 specific interceptors
    20:16:57,338 DEBUG amework.aop.framework.JdkDynamicAopProxy: 117 - Creating JDK dynamic proxy: target source is SingletonTargetSource for target object [com.manuel.jordan.model.service.support.impl.WarehouseServiceImpl@23f5b5dc]
    20:16:57,338 DEBUG ctory.support.DefaultListableBeanFactory: 477 - Finished creating instance of bean 'warehouseServiceImpl'
    20:16:57,338  INFO          com.manuel.jordan.main.MainTest: 102 - Pre
    20:16:57,338 DEBUG ion.AnnotationTransactionAttributeSource: 108 - Adding transactional method 'WarehouseServiceImpl.checkStockAvailability' with attribute: PROPAGATION_REQUIRES_NEW,ISOLATION_DEFAULT,timeout_0; ''
    20:16:57,338 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    20:16:57,339 DEBUG .datasource.DataSourceTransactionManager: 367 - Creating new transaction with name [com.manuel.jordan.model.service.support.impl.WarehouseServiceImpl.checkStockAvailability]: PROPAGATION_REQUIRES_NEW,ISOLATION_DEFAULT,timeout_0; ''
    20:16:57,339 DEBUG k.jdbc.datasource.SimpleDriverDataSource: 138 - Creating new JDBC Driver Connection to [jdbc:hsqldb:mem:testdb]
    20:16:57,339 DEBUG .datasource.DataSourceTransactionManager: 206 - Acquired Connection [org.hsqldb.jdbc.JDBCConnection@34bde49d] for JDBC transaction
    20:16:57,339 DEBUG .datasource.DataSourceTransactionManager: 223 - Switching JDBC Connection [org.hsqldb.jdbc.JDBCConnection@34bde49d] to manual commit
    20:16:57,339 DEBUG .datasource.DataSourceTransactionManager: 755 - Initiating transaction commit
    20:16:57,339 DEBUG .datasource.DataSourceTransactionManager: 266 - Committing JDBC transaction on Connection [org.hsqldb.jdbc.JDBCConnection@34bde49d]
    20:16:57,339 DEBUG .datasource.DataSourceTransactionManager: 324 - Releasing JDBC Connection [org.hsqldb.jdbc.JDBCConnection@34bde49d] after transaction
    20:16:57,339 DEBUG ramework.jdbc.datasource.DataSourceUtils: 327 - Returning JDBC Connection to DataSource
    20:16:57,339  INFO          com.manuel.jordan.main.MainTest: 104 - result: true
    20:16:57,339  INFO          com.manuel.jordan.main.MainTest: 105 - Post
    

    错误未按预期抛出。

    Omicron

    新的更新代码:
    @Service
    @Transactional
    @Scope("prototype")
    public class WarehouseServiceImpl implements WarehouseService {
    
        private static final Logger logger = LoggerFactory.getLogger(WarehouseServiceImpl.class);
    
        private ProductService productService;
    
        @Autowired
        public WarehouseServiceImpl(ProductService productService){
            this.productService = productService;
        }
    
        @Override
        @Transactional(propagation = Propagation.REQUIRES_NEW, timeout=0)
        public boolean checkStockAvailability(Product product, BigDecimal quantity) {
    
            logger.info("Amount: {}", this.productService.getAmountProducts());
            ...
            return true;
    
        }
    
    }
    

    上面显示的代码对于这两个项目是相同的,对于一个使用JdbcTemplate的项目,一切正常,抛出了预期的错误,但是使用Hibernate的另一个项目未引发预期的错误。在结果输出下方。
    08:27:06,782  INFO          com.manuel.jordan.main.MainTest: 102 - Pre
    08:27:06,782 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    08:27:06,782 DEBUG m.hibernate4.HibernateTransactionManager: 367 - Creating new transaction with name [com.manuel.jordan.model.service.support.impl.WarehouseServiceImpl.checkStockAvailability]: PROPAGATION_REQUIRES_NEW,ISOLATION_DEFAULT,timeout_0; ''
    08:27:06,783 DEBUG m.hibernate4.HibernateTransactionManager: 417 - Opened new Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=org.hibernate.engine.spi.ExecutableList@57ce634f updates=org.hibernate.engine.spi.ExecutableList@b8a7e43 deletions=org.hibernate.engine.spi.ExecutableList@35835fa orphanRemovals=org.hibernate.engine.spi.ExecutableList@56f71edb collectionCreations=org.hibernate.engine.spi.ExecutableList@7207cb51 collectionRemovals=org.hibernate.engine.spi.ExecutableList@2a27cb34 collectionUpdates=org.hibernate.engine.spi.ExecutableList@6892cc6f collectionQueuedOps=org.hibernate.engine.spi.ExecutableList@6fd1660 unresolvedInsertDependencies=UnresolvedEntityInsertActions[]])] for Hibernate transaction
    08:27:06,783 DEBUG m.hibernate4.HibernateTransactionManager: 427 - Preparing JDBC Connection of Hibernate Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=org.hibernate.engine.spi.ExecutableList@57ce634f updates=org.hibernate.engine.spi.ExecutableList@b8a7e43 deletions=org.hibernate.engine.spi.ExecutableList@35835fa orphanRemovals=org.hibernate.engine.spi.ExecutableList@56f71edb collectionCreations=org.hibernate.engine.spi.ExecutableList@7207cb51 collectionRemovals=org.hibernate.engine.spi.ExecutableList@2a27cb34 collectionUpdates=org.hibernate.engine.spi.ExecutableList@6892cc6f collectionQueuedOps=org.hibernate.engine.spi.ExecutableList@6fd1660 unresolvedInsertDependencies=UnresolvedEntityInsertActions[]])]
    08:27:06,783 DEBUG gine.jdbc.internal.LogicalConnectionImpl: 226 - Obtaining JDBC connection
    08:27:06,783 DEBUG k.jdbc.datasource.SimpleDriverDataSource: 138 - Creating new JDBC Driver Connection to [jdbc:hsqldb:mem:testdb]
    08:27:06,783 DEBUG gine.jdbc.internal.LogicalConnectionImpl: 232 - Obtained JDBC connection
    08:27:06,783 DEBUG .transaction.spi.AbstractTransactionImpl: 160 - begin
    08:27:06,783 DEBUG ransaction.internal.jdbc.JdbcTransaction:  69 - initial autocommit status: true
    08:27:06,783 DEBUG ransaction.internal.jdbc.JdbcTransaction:  71 - disabling autocommit
    08:27:06,784 DEBUG m.hibernate4.HibernateTransactionManager: 488 - Exposing Hibernate transaction as JDBC transaction [org.hsqldb.jdbc.JDBCConnection@4a6c18ad]
    08:27:06,784 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    08:27:06,784 DEBUG m.hibernate4.HibernateTransactionManager: 362 - Found thread-bound Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=org.hibernate.engine.spi.ExecutableList@57ce634f updates=org.hibernate.engine.spi.ExecutableList@b8a7e43 deletions=org.hibernate.engine.spi.ExecutableList@35835fa orphanRemovals=org.hibernate.engine.spi.ExecutableList@56f71edb collectionCreations=org.hibernate.engine.spi.ExecutableList@7207cb51 collectionRemovals=org.hibernate.engine.spi.ExecutableList@2a27cb34 collectionUpdates=org.hibernate.engine.spi.ExecutableList@6892cc6f collectionQueuedOps=org.hibernate.engine.spi.ExecutableList@6fd1660 unresolvedInsertDependencies=UnresolvedEntityInsertActions[]])] for Hibernate transaction
    08:27:06,784 DEBUG m.hibernate4.HibernateTransactionManager: 472 - Participating in existing transaction
    08:27:06,784 DEBUG ctory.support.DefaultListableBeanFactory: 249 - Returning cached instance of singleton bean 'transactionManager'
    08:27:06,784 DEBUG m.hibernate4.HibernateTransactionManager: 362 - Found thread-bound Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=org.hibernate.engine.spi.ExecutableList@57ce634f updates=org.hibernate.engine.spi.ExecutableList@b8a7e43 deletions=org.hibernate.engine.spi.ExecutableList@35835fa orphanRemovals=org.hibernate.engine.spi.ExecutableList@56f71edb collectionCreations=org.hibernate.engine.spi.ExecutableList@7207cb51 collectionRemovals=org.hibernate.engine.spi.ExecutableList@2a27cb34 collectionUpdates=org.hibernate.engine.spi.ExecutableList@6892cc6f collectionQueuedOps=org.hibernate.engine.spi.ExecutableList@6fd1660 unresolvedInsertDependencies=UnresolvedEntityInsertActions[]])] for Hibernate transaction
    08:27:06,784 DEBUG m.hibernate4.HibernateTransactionManager: 472 - Participating in existing transaction
    08:27:06,785 DEBUG                        org.hibernate.SQL: 109 - select count(*) as col_0_0_ from product product0_
    08:27:06,785 DEBUG              org.hibernate.loader.Loader: 951 - Result set row: 0
    08:27:06,786 DEBUG              org.hibernate.loader.Loader:1485 - Result row:
    08:27:06,786  INFO ervice.support.impl.WarehouseServiceImpl:  45 - Amount: 6
    08:27:06,786 DEBUG m.hibernate4.HibernateTransactionManager: 755 - Initiating transaction commit
    08:27:06,786 DEBUG m.hibernate4.HibernateTransactionManager: 551 - Committing Hibernate transaction on Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=org.hibernate.engine.spi.ExecutableList@57ce634f updates=org.hibernate.engine.spi.ExecutableList@b8a7e43 deletions=org.hibernate.engine.spi.ExecutableList@35835fa orphanRemovals=org.hibernate.engine.spi.ExecutableList@56f71edb collectionCreations=org.hibernate.engine.spi.ExecutableList@7207cb51 collectionRemovals=org.hibernate.engine.spi.ExecutableList@2a27cb34 collectionUpdates=org.hibernate.engine.spi.ExecutableList@6892cc6f collectionQueuedOps=org.hibernate.engine.spi.ExecutableList@6fd1660 unresolvedInsertDependencies=UnresolvedEntityInsertActions[]])]
    08:27:06,786 DEBUG .transaction.spi.AbstractTransactionImpl: 175 - committing
    08:27:06,786 DEBUG ransaction.internal.jdbc.JdbcTransaction: 113 - committed JDBC Connection
    08:27:06,786 DEBUG ransaction.internal.jdbc.JdbcTransaction: 126 - re-enabling autocommit
    08:27:06,787 DEBUG m.hibernate4.HibernateTransactionManager: 633 - Closing Hibernate Session [SessionImpl(PersistenceContext[entityKeys=[],collectionKeys=[]];ActionQueue[insertions=org.hibernate.engine.spi.ExecutableList@57ce634f updates=org.hibernate.engine.spi.ExecutableList@b8a7e43 deletions=org.hibernate.engine.spi.ExecutableList@35835fa orphanRemovals=org.hibernate.engine.spi.ExecutableList@56f71edb collectionCreations=org.hibernate.engine.spi.ExecutableList@7207cb51 collectionRemovals=org.hibernate.engine.spi.ExecutableList@2a27cb34 collectionUpdates=org.hibernate.engine.spi.ExecutableList@6892cc6f collectionQueuedOps=org.hibernate.engine.spi.ExecutableList@6fd1660 unresolvedInsertDependencies=UnresolvedEntityInsertActions[]])] after transaction
    08:27:06,787 DEBUG gine.jdbc.internal.LogicalConnectionImpl: 246 - Releasing JDBC connection
    08:27:06,787 DEBUG gine.jdbc.internal.LogicalConnectionImpl: 264 - Released JDBC connection
    08:27:06,787  INFO          com.manuel.jordan.main.MainTest: 104 - result: true
    08:27:06,787  INFO          com.manuel.jordan.main.MainTest: 105 - Post
    

    有一些线索吗? DataAccess当然存在...

    最佳答案

    查看您的第一个日志(与recordInvoicecheckStockAvailability的超时问题有关),这些确实表明事务行为已正确应用:在Java代码级别,事务已启动并提交。日志中唯一的区别是,使用recordInvoice时,将对数据库执行实际查询,而使用checkStockAvailability时,则没有这种查询。

    对此的可能答案是,如果数据库没有 Activity ,则没有数据库级事务。 Java代码中的内容反映在数据库级别。例如,如果您打开MySQL控制台并在表中插入内容,则最后需要提交以查看DB中的结果。

    与第二个问题有关,您在其中一个测试中使用JdbcTemplate,而在另一项测试中使用Hibernate(带有HibernateTransactionManager),查看source code for the Hibernate transaction似乎只考虑了严格大于0的值。因此,一个简单的测试将超时设置为一秒,而在事务方法checkStockAvailability中,可以添加一个Thread.sleep(1500)可以表明,忽略了0秒的超时值,从而解释了测试结果。

    10-02 21:43