MyBatis在Spring環(huán)境下的事務(wù)管理
MyBatis的設(shè)計(jì)思想很簡單,可以看做是對JDBC的一次封裝,并提供強(qiáng)大的動態(tài)SQL映射功能。但是由于它本身也有一些緩存、事務(wù)管理等功能,所以實(shí)際使用中還是會碰到一些問題——另外,最近接觸了JFinal,其思想和Hibernate類似,但要更簡潔,和MyBatis的設(shè)計(jì)思想不同,但有一點(diǎn)相同:都是想通過簡潔的設(shè)計(jì)最大限度地簡化開發(fā)和提升性能——說到性能,前段時(shí)間碰到兩個(gè)問題:
1.在一個(gè)上層方法(DAO方法的上層)內(nèi)刪除一條記錄,然后再插入一條相同主鍵的記錄時(shí),會報(bào)主鍵沖突的錯(cuò)誤。
2.某些項(xiàng)目中的DAO方法平均執(zhí)行時(shí)間會是其他一些項(xiàng)目中的 2倍 。
第一個(gè)問題是偶爾會出現(xiàn),在實(shí)驗(yàn)環(huán)境無論如何也重現(xiàn)不了,經(jīng)過分析MyBatis的邏輯,估計(jì)是兩個(gè)DAO分別拿到了兩個(gè)不同的Connection,第二個(gè)語句比第一個(gè)更早的被提交,導(dǎo)致了主鍵沖突,有待進(jìn)一步的分析和驗(yàn)證。對于第二個(gè)問題,本文將嘗試通過分析源代碼和實(shí)驗(yàn)找到它的root cause,主要涉及到以下內(nèi)容:
1.問題描述與分析
2.MyBatis在Spring環(huán)境下的載入過程
3.MyBatis在Spring環(huán)境下事務(wù)的管理
4.實(shí)驗(yàn)驗(yàn)證
項(xiàng)目環(huán)境
整個(gè)系統(tǒng)是微服務(wù)架構(gòu),這里討論的「項(xiàng)目」是指一個(gè)單獨(dú)的服務(wù)。單個(gè)項(xiàng)目的框架基本是Spring+MyBatis,具體版本如下:
Spring 3.2.9/4.3.5 + Mybatis 3.2.6 + mybatis-spring 1.2.2 + mysql connector 5.1.20 + commons-dbcp 1.4
與MyBatis和事務(wù)相關(guān)的配置如下:
//代碼1
<!-- bean#1-->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<!-- 一些數(shù)據(jù)庫信息配置-->
<!-- 一些DBCP連接池配置 -->
//在這里設(shè)置是否自動提交
<property name="defaultAutoCommit" value="${dbcp.defaultAutoCommit}" />
</bean>
<!-- bean#2-->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="mapperLocations" value="classpath*:path/to/mapper/**/*.xml" />
</bean>
<!-- bean#3 -->
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<!-- bean#4-->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value=".path.to.mapper" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
</bean>
<!-- bean5 -->
<tx:annotation-driven transaction-manager="transactionManager" />
問題描述與分析
一倍的時(shí)間差挺嚴(yán)重的,平均到每次調(diào)用,正常的大約在6到10幾 ms,慢的要近20 ms,由于調(diào)用次數(shù)很多,導(dǎo)致整體性能會有很大的差別。經(jīng)過仔細(xì)比對這幾個(gè)項(xiàng)目,發(fā)現(xiàn)DAO執(zhí)行慢的項(xiàng)目的數(shù)據(jù)源配置(bean#1)中 defaultAutoCommit的配置都是 false。而且將此配置改為 true之后就恢復(fù)了正常。
由此推斷是在MyBatis在執(zhí)行「非自動提交」語句時(shí),進(jìn)行等待,或者多提交了一次,導(dǎo)致實(shí)際調(diào)用數(shù)據(jù)庫API次數(shù)增多。但是這個(gè)推斷也有個(gè)問題,由于整個(gè)項(xiàng)目是在Spring環(huán)境中運(yùn)行的,而且也開啟了Spring的事務(wù)管理,所以還是需要詳細(xì)的看一下MyBatis到底是如何裝配DAO方法與管理事務(wù)的,才能徹底解開謎團(tuán)。
問題重現(xiàn)
首先寫一個(gè)Service,其中調(diào)用了同一個(gè)mapper類的兩個(gè)方法分別2次, insertModelList()會在數(shù)據(jù)庫中插入兩條記錄, delModels()方法會刪除這兩條記錄,代碼如下:
//代碼2
//@Transactional
public void testIS(){
List<Model> models= new ArrayList<>();
//省略一些數(shù)據(jù)工作。。。
modelMapper.insertModelList(50001l, models);
modelMapper.delModels(50001);
if (CollectionUtils.isNotEmpty(models))
modelMapper.insertModelList(50001, models);
modelMapper.delModels(50001);
}
public void testOther(){
System.out.println("加載類:");
System.out.println(modelMapper.getClass().getClassLoader());
modelMapper.delModels(50001);
}
實(shí)際項(xiàng)目中使用cat來進(jìn)行執(zhí)行時(shí)間的統(tǒng)計(jì),這里也仿照cat,使用一個(gè)單獨(dú)的AOP類實(shí)現(xiàn)時(shí)間的計(jì)算:
//代碼2
//@Transactional
public void testIS(){
List<Model> models= new ArrayList<>();
//省略一些數(shù)據(jù)工作。。。
modelMapper.insertModelList(50001l, models);
modelMapper.delModels(50001);
if (CollectionUtils.isNotEmpty(models))
modelMapper.insertModelList(50001, models);
modelMapper.delModels(50001);
}
public void testOther(){
System.out.println("加載類:");
System.out.println(modelMapper.getClass().getClassLoader());
modelMapper.delModels(50001);
}
測試代碼:
//代碼4
public static void test(){
System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date())
+ " 開始測試!");
for (int i = 0; i < TEST_NUM; i++) {
ItemStrategyServiceTest ist = (ItemStrategyServiceTest) context.getBean("isTS");
ist.testIS();
if (i % 1000 == 0) {
System.out.println("1000次");
}
}
DaoTimeAdvice ad = (DaoTimeAdvice) context.getBean("daoTimeAdvice");
ad.printInfo();
ItemStrategyServiceTest ist = (ItemStrategyServiceTest) context.getBean("isTS");
ist.testOther();
System.exit(1);
}
測試結(jié)果:
| defaultAutoCommit | 循環(huán)次數(shù) | 共消耗時(shí)間(ns) | 平均時(shí)間(ns) |
|---|---|---|---|
| true | 40000 | 17831088316 | 445777 |
| true | 40000 | 17881589992 | 447039 |
| false | 40000 | 27280458229 | 682011 |
| false | 40000 | 27237413893 | 680935 |
defaultAutoCommit為 false時(shí)的執(zhí)行時(shí)間是 true的近1.5倍,并沒有重現(xiàn)2倍的時(shí)間消耗,估計(jì)是在cat統(tǒng)計(jì)或者其他AOP方法的執(zhí)行時(shí)還有其他消耗,從而擴(kuò)大了 false和 true之間的區(qū)別。
MyBatis在Spring環(huán)境下的載入過程
按照第一節(jié)中的配置文件,整個(gè)MyBatis中DAO的bean的裝配應(yīng)該是這樣的:
1.先使用BasicDataSource裝配一個(gè)數(shù)據(jù)源的bean(bean#1),名字叫做 dataSource。
這個(gè)bean很簡單,就是實(shí)例化并注冊到Spring的上下文中。
2.使用 dataSource來創(chuàng)建 sqlSessionFactory(bean#2),這個(gè)bean創(chuàng)建時(shí)會掃描MyBatis的語句映射文件并解析。
在MyBatis中,真正的數(shù)據(jù)庫讀寫操作是通過SqlSession的實(shí)例來實(shí)現(xiàn)的,而SqlSession要通過SQLSessionFactory來管理。這里的 org.mybatis.spring.SqlSessionFactoryBean實(shí)現(xiàn)了FactoryBean類(這個(gè)類比較特殊,與主題無關(guān),這里不再贅述),Spring會從這個(gè)bean中會獲取真正的SQLSessionFactory的實(shí)例,源代碼中顯示,實(shí)際返回的對象是DefaultSqlSessionFactory的實(shí)例。
3.使用 sqlSessionFactory這個(gè)工廠類來創(chuàng)建mapper掃描器(bean#4),并創(chuàng)建含有DAO方法的實(shí)例。
為了讓上層方法可以通過普通的方法調(diào)用來使用DAO方法,需要往Spring上下文里注冊相應(yīng)的bean,而在MyBatis的普通使用場景中是沒有mapper的實(shí)現(xiàn)類的(具體的SQL語句映射通過注解或者XML文件來實(shí)現(xiàn)),只有接口,在MyBatis中這些接口是通過動態(tài)代理實(shí)現(xiàn)的。這里使用的類是 org.mybatis.spring.mapper.MapperScannerConfigurer,它實(shí)現(xiàn)了 org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor接口,所以會在Spring中「所有的bean定義全部注冊完成,但還沒有實(shí)例化」之前,調(diào)用方法向Spring上下文注冊mapper實(shí)現(xiàn)類(動態(tài)代理的對象)。具體代碼如下:
//代碼5
@Override
public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) {
if (this.processPropertyPlaceHolders) {
processPropertyPlaceHolders();
}
ClassPathMapperScanner scanner = new ClassPathMapperScanner(registry);
//設(shè)置一些屬性
scanner.scan(StringUtils.tokenizeToStringArray(this.basePackage, ConfigurableApplicationContext.CONFIG_LOCATION_DELIMITERS));
}
/**
* Perform a scan within the specified base packages.
* @param basePackages the packages to check for annotated classes
* @return number of beans registered
*/
public int scan(String... basePackages) {
int beanCountAtScanStart = this.registry.getBeanDefinitionCount();
doScan(basePackages);
// Register annotation config processors, if necessary.
if (this.includeAnnotationConfig) {
AnnotationConfigUtils.registerAnnotationConfigProcessors(this.registry);
}
return (this.registry.getBeanDefinitionCount() - beanCountAtScanStart);
}
在源代碼里可以看到,真正的mapper實(shí)現(xiàn)類是 org.mybatis.spring.mapper.MapperFactoryBean<Object>,具體的邏輯在方法 org.mybatis.spring.mapper.ClassPathMapperScanner.processBeanDefinitions(Set<BeanDefinitionHolder>)里。最后,每一個(gè)方法的執(zhí)行,最終落入了 org.mybatis.spring.SqlSessionTemplate的某個(gè)方法中,并被如下這個(gè)攔截器攔截:
//代碼6
/**
* Proxy needed to route MyBatis method calls to the proper SqlSession got
* from Spring's Transaction Manager
* It also unwraps exceptions thrown by {@code Method#invoke(Object, Object...)} to
* pass a {@code PersistenceException} to the {@code PersistenceExceptionTranslator}.
*/
private class SqlSessionInterceptor implements InvocationHandler {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
SqlSession sqlSession = getSqlSession(
SqlSessionTemplate.this.sqlSessionFactory,
SqlSessionTemplate.this.executorType,
SqlSessionTemplate.this.exceptionTranslator);
try {
Object result = method.invoke(sqlSession, args);
if (!isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {
// force commit even on non-dirty sessions because some databases require
// a commit/rollback before calling close()
sqlSession.commit(true);
}
return result;
} catch (Throwable t) {
//省略一些錯(cuò)誤處理
throw unwrapped;
} finally {
if (sqlSession != null) {
closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
}
}
}
}
4.MyBatis在Spring環(huán)境下事務(wù)的管理
從源代碼中知道真正的SqlSessionFactory使用的是 org.apache.ibatis.session.defaults.DefaultSqlSessionFactory的實(shí)例,同時(shí),事務(wù)管理使用 org.mybatis.spring.transaction.SpringManagedTransactionFactory。但是在代碼1的配置中,還添加了Spring事務(wù)管理的配置,就是在某個(gè)Service方法(或某個(gè)其他可被掃描到的方法)上加上 @Transactional注解,那么Spring的事務(wù)管理會自動創(chuàng)建事務(wù),那么它和MyBatis的事務(wù)之間是怎么協(xié)作的呢?
可以看到在代碼6中的方法 isSqlSessionTransactional(),它會返回上層代碼中是否有Spring的事務(wù),如果有,將不會執(zhí)行下邊的 commit()。在我的項(xiàng)目中的實(shí)際情況是沒有Spring事務(wù),所以肯定是走到了下面的 commit(),這個(gè)方法最終落到了SpringManagedTransactionFactory中的 commit(),看代碼:
//代碼7
private void openConnection() throws SQLException {
this.connection = DataSourceUtils.getConnection(this.dataSource);
this.autoCommit = this.connection.getAutoCommit();
this.isConnectionTransactional = DataSourceUtils.isConnectionTransactional(this.connection, this.dataSource);
}
public void commit() throws SQLException {
if (this.connection != null && !this.isConnectionTransactional && !this.autoCommit) {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Committing JDBC Connection [" + this.connection + "]");
}
this.connection.commit();
}
}
可以看到,此處是否要執(zhí)行 commit()操作是由3個(gè)變量決定的,如果DataSource的 autoCommit是 false,則其結(jié)果一定為 true,控制臺也會看到一行日志: Committing JDBC Connection [xxxxxx],剛好與項(xiàng)目中遇到的情況相同。這個(gè)提交動作是需要和數(shù)據(jù)庫交互的,比較耗時(shí)。
實(shí)驗(yàn)驗(yàn)證
由上一節(jié)分析得出,造成DAO方法執(zhí)行時(shí)間變長的原因是會多執(zhí)行一次提交,那么如果上層方法被Spring事務(wù)管理器托管(或者數(shù)據(jù)源的 defaultAutoCommit為 true,這個(gè)條件已經(jīng)在剛開始的問題重現(xiàn)被驗(yàn)證),則不會執(zhí)行MyBatis的提交動作,DAO方法應(yīng)該相應(yīng)的執(zhí)行時(shí)間會變短。于是將Service方法加上 @transactional注解,分別測試 true和 false的情況。結(jié)果:

可以看到執(zhí)行的時(shí)間已經(jīng)基本接近,由此基本可以確定是這個(gè)原因造成的。這里仍然有幾個(gè)疑點(diǎn),尤其是問題重現(xiàn)時(shí)沒有出現(xiàn)2倍的時(shí)間消耗,如果你有別的想法,也歡迎提出來討論。
總結(jié)
以上所述是小編給大家介紹的MyBatis在Spring環(huán)境下的事務(wù)管理,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時(shí)回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
如果你覺得本文對你有幫助,歡迎轉(zhuǎn)載,煩請注明出處,謝謝!
- SpringMVC+MyBatis 事務(wù)管理(實(shí)例)
- mybatis開啟spring事務(wù)代碼解析
- springboot使用mybatis開啟事務(wù)回滾
- Spring事務(wù)&Spring整合MyBatis的兩種方式
- springboot配置mybatis和事務(wù)管理方式
- springboot mybatis手動事務(wù)的實(shí)現(xiàn)
- Mybatis事務(wù)如何跟Spring結(jié)合(數(shù)據(jù)庫事務(wù)特性和Spring事務(wù)管理源碼)
- MyBatisPlus+Spring實(shí)現(xiàn)聲明式事務(wù)的方法實(shí)現(xiàn)
相關(guān)文章
詳解IDEA 啟動tomcat 端口占用原因以及解決方法( 使用debug模式)
這篇文章主要介紹了詳解IDEA 啟動tomcat 端口占用原因以及解決方法( 使用debug模式) ,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-08-08
Java實(shí)現(xiàn)導(dǎo)入csv的示例代碼
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)導(dǎo)入csv的相關(guān)知識,文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,有需要的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-03-03
Spring?中?PageHelper?不生效問題及解決方法
這篇文章主要介紹了Spring?中?PageHelper?不生效問題,使用這個(gè)插件時(shí)要注意版本的問題,不同的版本可能 PageHelper 不會生效,本文結(jié)合示例代碼給大家介紹的非常詳細(xì),需要的朋友可以參考下2022-12-12
springBoot下實(shí)現(xiàn)java自動創(chuàng)建數(shù)據(jù)庫表
這篇文章主要介紹了springBoot下實(shí)現(xiàn)java自動創(chuàng)建數(shù)據(jù)庫表的操作,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-07-07
dubbo如何實(shí)現(xiàn)consumer從多個(gè)group中調(diào)用指定group的provider
這篇文章主要介紹了dubbo如何實(shí)現(xiàn)consumer從多個(gè)group中調(diào)用指定group的provider問題,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-03-03
Spring?Boot如何通過Actuator顯示git和build的信息
這篇文章主要介紹了Spring?Boot通過Actuator顯示git和build的信息,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-01-01

