真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

MyBatis在Spring環(huán)境下的事務(wù)管理

MyBatis的設(shè)計(jì)思想很簡(jiǎn)單，可以看做是對(duì)JDBC的一次封裝，并提供強(qiáng)大的動(dòng)態(tài)SQL映射功能。但是由于它本身也有一些緩存、事務(wù)管理等功能，所以實(shí)際使用中還是會(huì)碰到一些問題——另外，最近接觸了JFinal，其思想和Hibernate類似，但要更簡(jiǎn)潔，和MyBatis的設(shè)計(jì)思想不同，但有一點(diǎn)相同：都是想通過簡(jiǎn)潔的設(shè)計(jì)最大限度地簡(jiǎn)化開發(fā)和提升性能——說到性能，前段時(shí)間碰到兩個(gè)問題：

在平谷等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站 網(wǎng)站設(shè)計(jì)制作按需定制網(wǎng)站,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),成都品牌網(wǎng)站建設(shè),網(wǎng)絡(luò)營(yíng)銷推廣,外貿(mào)營(yíng)銷網(wǎng)站建設(shè),平谷網(wǎng)站建設(shè)費(fèi)用合理。

1.在一個(gè)上層方法（DAO方法的上層）內(nèi)刪除一條記錄，然后再插入一條相同主鍵的記錄時(shí)，會(huì)報(bào)主鍵沖突的錯(cuò)誤。

2.某些項(xiàng)目中的DAO方法平均執(zhí)行時(shí)間會(huì)是其他一些項(xiàng)目中的 2倍 。

第一個(gè)問題是偶爾會(huì)出現(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)證。對(duì)于第二個(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

 
  
  
   //在這里設(shè)置是否自動(dòng)提交

問題描述與分析

一倍的時(shí)間差挺嚴(yán)重的，平均到每次調(diào)用，正常的大約在6到10幾 ms，慢的要近20 ms，由于調(diào)用次數(shù)很多，導(dǎo)致整體性能會(huì)有很大的差別。經(jīng)過仔細(xì)比對(duì)這幾個(gè)項(xiàng)目，發(fā)現(xiàn)DAO執(zhí)行慢的項(xiàng)目的數(shù)據(jù)源配置（bean#1）中 defaultAutoCommit的配置都是 false。而且將此配置改為 true之后就恢復(fù)了正常。

由此推斷是在MyBatis在執(zhí)行「非自動(dòng)提交」語句時(shí)，進(jìn)行等待，或者多提交了一次，導(dǎo)致實(shí)際調(diào)用數(shù)據(jù)庫(kù)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()會(huì)在數(shù)據(jù)庫(kù)中插入兩條記錄， delModels()方法會(huì)刪除這兩條記錄，代碼如下：

//代碼2
//@Transactional
public void testIS(){
 List 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 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);
}

測(cè)試代碼：

//代碼4
public static void test(){
 System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date())
   + " 開始測(cè)試!");
 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);
}

測(cè)試結(jié)果：

defaultAutoCommit循環(huán)次數(shù)共消耗時(shí)間(ns)平均時(shí)間(ns)
true4000017831088316445777
true4000017881589992447039
false4000027280458229682011
false4000027237413893680935

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很簡(jiǎn)單，就是實(shí)例化并注冊(cè)到Spring的上下文中。

2.使用 dataSource來創(chuàng)建 sqlSessionFactory（bean#2)，這個(gè)bean創(chuàng)建時(shí)會(huì)掃描MyBatis的語句映射文件并解析。

在MyBatis中，真正的數(shù)據(jù)庫(kù)讀寫操作是通過SqlSession的實(shí)例來實(shí)現(xiàn)的，而SqlSession要通過SQLSessionFactory來管理。這里的 org.mybatis.spring.SqlSessionFactoryBean實(shí)現(xiàn)了FactoryBean類（這個(gè)類比較特殊，與主題無關(guān)，這里不再贅述），Spring會(huì)從這個(gè)bean中會(huì)獲取真正的SQLSessionFactory的實(shí)例，源代碼中顯示，實(shí)際返回的對(duì)象是DefaultSqlSessionFactory的實(shí)例。

3.使用 sqlSessionFactory這個(gè)工廠類來創(chuàng)建mapper掃描器（bean#4），并創(chuàng)建含有DAO方法的實(shí)例。

為了讓上層方法可以通過普通的方法調(diào)用來使用DAO方法，需要往Spring上下文里注冊(cè)相應(yīng)的bean，而在MyBatis的普通使用場(chǎng)景中是沒有mapper的實(shí)現(xiàn)類的（具體的SQL語句映射通過注解或者XML文件來實(shí)現(xiàn)），只有接口，在MyBatis中這些接口是通過動(dòng)態(tài)代理實(shí)現(xiàn)的。這里使用的類是 org.mybatis.spring.mapper.MapperScannerConfigurer，它實(shí)現(xiàn)了 org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor接口，所以會(huì)在Spring中「所有的bean定義全部注冊(cè)完成，但還沒有實(shí)例化」之前，調(diào)用方法向Spring上下文注冊(cè)mapper實(shí)現(xiàn)類（動(dòng)態(tài)代理的對(duì)象）。具體代碼如下：

 //代碼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，具體的邏輯在方法 org.mybatis.spring.mapper.ClassPathMapperScanner.processBeanDefinitions(Set)里。最后，每一個(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ù)管理會(huì)自動(dòng)創(chuàng)建事務(wù)，那么它和MyBatis的事務(wù)之間是怎么協(xié)作的呢？

可以看到在代碼6中的方法 isSqlSessionTransactional()，它會(huì)返回上層代碼中是否有Spring的事務(wù)，如果有，將不會(huì)執(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，控制臺(tái)也會(huì)看到一行日志： Committing JDBC Connection [xxxxxx]，剛好與項(xiàng)目中遇到的情況相同。這個(gè)提交動(dòng)作是需要和數(shù)據(jù)庫(kù)交互的，比較耗時(shí)。


實(shí)驗(yàn)驗(yàn)證

由上一節(jié)分析得出，造成DAO方法執(zhí)行時(shí)間變長(zhǎng)的原因是會(huì)多執(zhí)行一次提交，那么如果上層方法被Spring事務(wù)管理器托管（或者數(shù)據(jù)源的 defaultAutoCommit為 true，這個(gè)條件已經(jīng)在剛開始的問題重現(xiàn)被驗(yàn)證），則不會(huì)執(zhí)行MyBatis的提交動(dòng)作，DAO方法應(yīng)該相應(yīng)的執(zhí)行時(shí)間會(huì)變短。于是將Service方法加上 @transactional注解，分別測(cè)試 true和 false的情況。結(jié)果：

MyBatis在Spring環(huán)境下的事務(wù)管理

可以看到執(zhí)行的時(shí)間已經(jīng)基本接近，由此基本可以確定是這個(gè)原因造成的。這里仍然有幾個(gè)疑點(diǎn)，尤其是問題重現(xiàn)時(shí)沒有出現(xiàn)2倍的時(shí)間消耗，如果你有別的想法，也歡迎提出來討論。

總結(jié)

以上所述是小編給大家介紹的MyBatis在Spring環(huán)境下的事務(wù)管理,希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)創(chuàng)新互聯(lián)網(wǎng)站的支持！
如果你覺得本文對(duì)你有幫助，歡迎轉(zhuǎn)載，煩請(qǐng)注明出處，謝謝！


本文名稱：MyBatis在Spring環(huán)境下的事務(wù)管理
地址分享：http://weahome.cn/article/ghpssi.html

在線咨詢

微信咨詢

電話咨詢

028-86922220（工作日）

18980820575（7×24）

提交需求

返回頂部