java – JUnit测试对@transactional @Async方法的调用导致超出锁定等待超时

我正在尝试测试异步运行的服务方法(@Async).

@Async
@Transactional(propagation=Propagation.SUPPORTS,isolation = Isolation.READ_UNCOMMITTED)
public Future


这是调用异步的测试方法：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(location = "...")
@TransactionConfiguration(transactionManager = "txManager",defaultRollback = false)
@Transactional(isolation = Isolation.READ_UNCOMMITTED)
@TestExecutionListeners( {  DependencyInjectionTestExecutionListener.class,DirtiesContextTestExecutionListener.class,TransactionalTestExecutionListener.class })
public class MessagingServiceTest {

   @Before
   public void setUp() {        
     //Avant tout mettre tout les sms en lu 
     smsDao.deleteallSms(1);
     sessionFactory.getCurrentSession().flush();

     //On vérifie bien qu'il n y a plus de sms
     Listtest() throws InterruptedException,ExecutionException {
     User user = (User) sessionFactory.getCurrentSession().load(User.class,new Long(1));//idUser = 1
     // We explicitly blank the preference from db
     prefsDao.saveLanguagePref(new UserPrefs("",user));

     Futurestem.out.println("wait completion of async task");           
     prefs.get();
     System.out.println("Async task has finished");
   }
}

当prefs.get()执行时,我有这个错误：

Caused by: org.springframework.orm.hibernate3.HibernateJdbcException: JDBC exception on Hibernate data access: sqlException for sql [insert into SmsBean (destination,message,origin,sens,status,USER_ID) values (?,?,?)]; sql state [41000]; error code [1205]; Could not insert:

Caused by: java.sql.sqlException: Lock wait timeout exceeded; try restarting transaction

    at com.MysqL.jdbc.sqlError.createsqlException(sqlError.java:1075)
    at com.MysqL.jdbc.MysqLIO.checkerrorPacket(MysqLIO.java:3562)
    at com.MysqL.jdbc.MysqLIO.checkerrorPacket(MysqLIO.java:3494)
    at com.MysqL.jdbc.MysqLIO.sendCommand(MysqLIO.java:1960)
    at com.MysqL.jdbc.MysqLIO.sqlQueryDirect(MysqLIO.java:2114)
    at com.MysqL.jdbc.ConnectionImpl.execsql(ConnectionImpl.java:2696)
    at com.MysqL.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:2105)
    at com.MysqL.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2398)
    at com.MysqL.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2316)
    at com.MysqL.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2301)
    at org.apache.commons.dbcp.DelegatingPreparedStatement.executeUpdate(DelegatingPreparedStatement.java:101)
    at org.hibernate.id.IdentityGenerator$GetGeneratedKeysDelegate.executeAndExtract(IdentityGenerator.java:94)
    at org.hibernate.id.insert.AbstractReturningDelegate.performInsert(AbstractReturningDelegate.java:57)
    ... 39 more

这是因为setup方法中的smsDao.deleteallSms在sms表上持有一个锁.
如何正确避免此锁定超时并能够成功运行我的测试？
谢谢你的帮助.
仅供参考,这是一些控制台输出：

DEBUG - Adding transactional method 'checkLanguagePreferenceTest' with attribute: PROPAGATION_required,ISOLATION_READ_COMMITTED; ''
DEBUG - Explicit transaction deFinition [PROPAGATION_required,ISOLATION_READ_COMMITTED; ''] found for test context [[TestContext@b76fa testClass = MessagingServiceTest,locations = array['file:src/main/resources/myapp-context.xml','file:src/main/resources/myapp-data.xml','file:src/main/resources/myapp-services.xml'],testInstance = fr.myapp.service.MessagingServiceTest@b01d43,testMethod = checkLanguagePreferenceTest@MessagingServiceTest,testException = [null]]]
DEBUG - Retrieved @TransactionConfiguration [@org.springframework.test.context.transaction.Tran sactionConfiguration(defaultRollback=false,transactionManager=txManager)] for test class [class fr.myapp.service.MessagingServiceTest]
DEBUG - Retrieved TransactionConfigurationAttributes [[TransactionConfigurationAttributes@5f7d3f transactionManagerName = 'txManager',defaultRollback = false]] for class [class fr.myapp.service.MessagingServiceTest]
DEBUG - Returning cached instance of singleton bean 'txManager'
DEBUG - Creating new transaction with name [checkLanguagePreferenceTest]: PROPAGATION_required,ISOLATION_READ_COMMITTED; ''
DEBUG - Opened new Session [org.hibernate.impl.SessionImpl@666a53] for Hibernate transaction
DEBUG - Preparing JDBC Connection of Hibernate Session [org.hibernate.impl.SessionImpl@666a53]
DEBUG - Changing isolation level of JDBC Connection [org.apache.commons.dbcp.PoolableConnection@1bde3d2] to 2
DEBUG - Exposing Hibernate transaction as JDBC transaction [org.apache.commons.dbcp.PoolableConnection@1bde3d2]
DEBUG - No method-level @Rollback override: using default rollback [false] for test context [[TestContext@b76fa testClass = MessagingServiceTest,testException = [null]]]
INFO - Began transaction (1): transaction manager [org.springframework.orm.hibernate3.HibernateTransa ctionManager@17753a8]; rollback [false]
Hibernate: delete from SmsBean where USER_ID=?
Hibernate: select user0_.id as id3_1_,user0_.email as email3_1_,user0_.login as login3_1_,user0_.passwd as passwd3_1_,smsbeans1_.USER_ID as USER7_3_3_,smsbeans1_.id as id3_,smsbeans1_.id as id0_0_,smsbeans1_.destination as destinat2_0_0_,smsbeans1_.message as message0_0_,smsbeans1_.origin as origin0_0_,smsbeans1_.sens as sens0_0_,smsbeans1_.status as status0_0_,smsbeans1_.USER_ID as USER7_0_0_ from User user0_ left outer join SmsBean smsbeans1_ on user0_.id=smsbeans1_.USER_ID where user0_.id=?
Hibernate: select user0_.id as id3_,user0_.email as email3_,user0_.login as login3_,user0_.passwd as passwd3_ from User user0_ where user0_.login=?
Hibernate: select userprefs0_.id as id2_,userprefs0_.language as language2_,userprefs0_.USER_ID as USER3_2_ from user_prefs userprefs0_ where userprefs0_.USER_ID=?
wait completion of async task
DEBUG - Returning cached instance of singleton bean 'txManager'
INFO - Ener dans checkLanguagePreference(1)
DEBUG - opening Hibernate Session
DEBUG - Registering Spring transaction synchronization for new Hibernate Session
Hibernate: select userprefs0_.id as id2_,userprefs0_.USER_ID as USER3_2_ from user_prefs userprefs0_ where userprefs0_.USER_ID=?
Hibernate: select user0_.id as id3_1_,smsbeans1_.USER_ID as USER7_0_0_ from User user0_ left outer join SmsBean smsbeans1_ on user0_.id=smsbeans1_.USER_ID where user0_.id=?
INFO - Checking if same sms command already exist
Hibernate: select * from smsbean S where S.USER_ID=? and S.status=? and S.message=?
DEBUG - Flushing Hibernate Session on transaction synchronization

//Deadlock here :
Hibernate: insert into SmsBean (destination,?)
DEBUG - Closing Hibernate Session
58799 [SimpleAsyncTaskExecutor-1] WARN org.hibernate.util.JDBCExceptionReporter - sql Error: 1205,sqlState: 41000
58799 [SimpleAsyncTaskExecutor-1] ERROR org.hibernate.util.JDBCExceptionReporter - Lock wait timeout exceeded; try restarting transaction

已经解决了,但我之前已经创建了一个关于MysqL论坛的一个主题,关于为什么我从DBMS的角度来看这个死锁.这是链接(也解释得很好)：
http://forums.mysql.com/read.php?97,409237#msg-409237


最佳答案
由于您的测试被声明为@Transactional,因此您有一个大的事务,该事务遍及setUp方法和测试方法的执行.此事务死锁与另一个事务在异步操作中启动(异步操作等待释放主事务获取的锁,主事务等待异步操作完成).
您可以通过将主事务分成几个单独的事务来解决它：

@Before
@Transactional // separate transaction for setUp
public void setUp() {        
    //Avant tout mettre tout les sms en lu 
    smsDao.deleteallSms(1);
    sessionFactory.getCurrentSession().flush();

    //On vérifie bien qu'il n y a plus de sms
    Listdisable main transaction
public void checkLanguagePreferencetest() throws InterruptedException,ExecutionException {

    // Programmatic transaction for test preparation
    User user = tx.execute(new TransactionCallbackstem.out.println("wait completion of async task");            
    prefs.get();
    System.out.println("Async task has finished");
}

private TransactionTemplate tx;

@Autowired
public void setPtm(PlatformTransactionManager ptm) {
    tx = new TransactionTemplate(ptm);
}



                
                                 版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。

java – JUnit测试对@transactional @Async方法的调用导致超出锁定等待超时

相关推荐