在描述問題之前先說明幾個前提,假設在Spring的配置文件中使用下面的方式配置了數據庫的事務:
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <tx:annotation-driven transaction-manager="transactionManager" />
現在有UserDao和SecurityService:
@Repository public class UserDao { public User getUser() { // query user from user table return queryObject("select * from user order by id desc limit 1"); } }
@Service @Transactional public class SecurityService { @Autowired private UserDao userDao; public void checkUserInfo() { while(true) { User user = userDao.getUser(); if(user != null && "Tom".equals(user.getName()) { System.out.println("Tom is here"); break; } } } }
在調用SecurityService#checkUserInfo()方法的過程中,通過userDao#getUser()方法獲取到的數據是不變的,即使這個時候新插入了一條name為Tom的數據循環也不會結束。另外將SecurityService上面的@Transactional注解去掉也無濟於事。
首先想到會不會是數據庫連接池的問題,換成了Spring自帶的也是如此;然後從JdbcTemplate裡面直接調用了Connection對象,使用原始的JDBC方式操作數據庫,這個時候數據是實時變化的,於是想到應該是Spring的事務和當前操作線程進行綁定了。查看源代碼進入之後果然在DataSourceUtils#doGetConnection方法裡面發現了Spring在每個線程的每個DataSource上創建了一個Connection並且與事務進行了綁定。因為tx:annotation-driven配置文件對所有的Service層(加了@Service注解的類)進行了事務綁定,所以無論是否使用@Transactional都在同一個線程中綁定了同一個Connection,只是不進行事務操作而已。
經過多次實驗和查找資料,最後終於找到了完美的解決方法:只要在上述的checkUserInfo方法中加上 @Transactional(propagation = Propagation.NOT_SUPPORTED) 注解就可以了。當然也可以獲取到Connection然後手工進行操作,也可以使用DateUtils包進行操作。