-framework

一、SqlSessionFactory怎么注入SqlSessionFactoryBean

二、Mapper代理怎么注入MapperFactoryBeanSqlSessionTemplate

三、为什么要接管mybatis事务SpringManagedTransactionFactory

在mybatis-spring中定义了一个新的factoryBean——SqlSessionFactoryBean我们将其注入到spring容器即可。

其实也不难猜到这个factoryBean的getObject肯定返回了一个SqlSessionFactory这样spring容器中就有一个SqlSessionFactory

bean了。

后续就跟使用原生mybatis一样通过这个SqlSessionFactory去生成SqlSession进而生成Mapper的代理类去操作数据库。

所以getObject方法是如何生成SqlSessionFactory来到buildSqlSessionFactory

protected

targetConfiguration;XMLConfigBuilder

xmlConfigBuilder

(targetConfiguration.getVariables()

null)

{targetConfiguration.setVariables(this.configurationProperties);}

else

{targetConfiguration.getVariables().putAll(this.configurationProperties);}}

else

XMLConfigBuilder(this.configLocation.getInputStream(),

null,

this.configurationProperties);targetConfiguration

xmlConfigBuilder.getConfiguration();}

else

Configuration);targetConfiguration

new

Configuration();Optional.ofNullable(this.configurationProperties).ifPresent(targetConfiguration::setVariables);}Optional.ofNullable(this.objectFactory).ifPresent(targetConfiguration::setObjectFactory);Optional.ofNullable(this.objectWrapperFactory).ifPresent(targetConfiguration::setObjectWrapperFactory);Optional.ofNullable(this.vfs).ifPresent(targetConfiguration::setVfsImpl);if

(hasLength(this.typeAliasesPackage))

{scanClasses(this.typeAliasesPackage,

this.typeAliasesSuperType).stream().filter(clazz

!clazz.isAnonymousClass()).filter(clazz

!clazz.isInterface()).filter(clazz

!clazz.isMemberClass()).forEach(targetConfiguration.getTypeAliasRegistry()::registerAlias);}if

{Stream.of(this.typeAliases).forEach(typeAlias

{targetConfiguration.getTypeAliasRegistry().registerAlias(typeAlias);LOGGER.debug(()

Registered

{Stream.of(this.plugins).forEach(plugin

{targetConfiguration.addInterceptor(plugin);LOGGER.debug(()

Registered

(hasLength(this.typeHandlersPackage))

{scanClasses(this.typeHandlersPackage,

TypeHandler.class).stream().filter(clazz

!clazz.isAnonymousClass()).filter(clazz

!clazz.isInterface()).filter(clazz

!Modifier.isAbstract(clazz.getModifiers())).forEach(targetConfiguration.getTypeHandlerRegistry()::register);}if

{Stream.of(this.typeHandlers).forEach(typeHandler

{targetConfiguration.getTypeHandlerRegistry().register(typeHandler);LOGGER.debug(()

Registered

);});}targetConfiguration.setDefaultEnumTypeHandler(defaultEnumTypeHandler);if

(!isEmpty(this.scriptingLanguageDrivers))

{Stream.of(this.scriptingLanguageDrivers).forEach(languageDriver

{targetConfiguration.getLanguageRegistry().register(languageDriver);LOGGER.debug(()

Registered

);});}Optional.ofNullable(this.defaultScriptingLanguageDriver).ifPresent(targetConfiguration::setDefaultScriptingLanguage);if

null)

{targetConfiguration.setDatabaseId(this.databaseIdProvider.getDatabaseId(this.dataSource));}

catch

e);}}Optional.ofNullable(this.cache).ifPresent(targetConfiguration::addCache);if

(xmlConfigBuilder

{xmlConfigBuilder.parse();LOGGER.debug(()

Parsed

{ErrorContext.instance().reset();}}targetConfiguration.setEnvironment(new

Environment(this.environment,this.transactionFactory

null

SpringManagedTransactionFactory()

this.transactionFactory,this.dataSource));if

null)

XMLMapperBuilder(mapperLocation.getInputStream(),targetConfiguration,

targetConfiguration.getSqlFragments());xmlMapperBuilder.parse();}

catch

{ErrorContext.instance().reset();}LOGGER.debug(()

Parsed

this.sqlSessionFactoryBuilder.build(targetConfiguration);}跟原生mybatis一样构建一个Configuration对象然后使用SqlSessionFactoryBuilder去build一个SqlSessionFactory。

需要注意的是这个过程中就算外界传入的Configuration对象有环境、数据源、事务管理器的配置无论是xml配置还是代码都会被忽略取而代之的是SqlSessionFactoryBean对应的environment、dataSource、transactionFactory属性。

至此spring中就相当于有了SqlSessionFactory

bean后续spring就可以用这个SqlSessionFactory

二、Mapper代理怎么注入

跟使用原生mybatis一样对mapper接口生成一个个的代理对象。

即在整合过程中会生成一个个代理对象bean对应流程如下。

1、MapperScan注解import了MapperScannerRegistrar

2、MapperScannerRegistrar是一个ImportBeanDefinitionRegistrar会注册MapperScannerConfigurer

3、MapperScannerConfigurer是一个BeanFactoryPostProcessorBeanDefinitionRegistryPostProcessor对应的增强方法会扫描出指定路径下的Mapper并把class

4、MapperFactoryBean是一个FactoryBean其getObject方法跟原生mybatis一样通过SqlSession.getMapper生成一个mapper代理对象然后将其注入spring容器。

SqlSessionTemplate

所以是直接使用SqlSession来生成mapper的代理对象吗其实不然实际MapperFactoryBean的getObject中的getSqlSession()返回的是一个SqlSessionTemplate

SqlSessionTemplate中维护了一个SqlSession的代理对象后续有关数据库的操作都会经过这个代理对象。

代理SqlSession的逻辑大概就是如果是同一个事务就获取同一个SqlSession如果不是同一个事务就新建一个SqlSession然后再用这个SqlSession去做事情。

这么做是为了解决SqlSession线程不安全的问题正是因为如此导致不同事务用不同的SqlSession所以一级缓存也就失效了。

三、为什么要接管mybatis事务

SpringManagedTransactionFactory

在SqlSessionFactoryBean的buildSqlSessionFactory中我们默认会使用SpringManagedTransactionFactory作为我们的事务管理器来接管mybatis事务。

MyBatis

具体来说SpringManagedTransactionFactory

在创建事务时会获取

对象。

在事务提交或回滚时SpringManagedTransactionFactory

Spring