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

//代碼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" />

//代碼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);
}

//代碼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);
}

 //代碼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);
 }

//代碼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) {
  //省略一些錯誤處理
  throw unwrapped;
 } finally {
  if (sqlSession != null) {
  closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
  }
 }
 }
 }

//代碼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();
 }
 }