一.mybaties源码
- 1.加载mybatis-config.xml配置文件
- 2.通过配置文件创建SqlSessionFactory
解析 properties节点
<properties resource="db.properties"></properties>
解析我们的mybatis-config.xml中的settings节点
<settings> <setting name="mapUnderscoreToCamelCase" value="true"/> </settings>
解析我们的别名
解析我们的插件(比如分页插件)<plugins> <plugin interceptor="com.hehe.plugins.ExamplePlugin" ></plugin> </plugins>
解析我们的mybatis环境
解析数据库厂商
解析我们的类型处理器节点
解析我们的mapper<mappers> <!--1.必须保证接口名(例如IUserDao)和xml名(IUserDao.xml)相同,还必须在同一个包中--> <package name="com.hehe.mapper"/> <!--2.不用保证同接口同包同名 <mapper resource="com/mybatis/mappers/EmployeeMapper.xml"/> 3.保证接口名(例如IUserDao)和xml名(IUserDao.xml)相同,还必须在同一个包中 <mapper class="com.mybatis.dao.EmployeeMapper"/> 4.不推荐:引用网路路径或者磁盘路径下的sql映射文件 file:///var/mappers/AuthorMapper.xml <mapper url="file:E:/Study/myeclipse/_03_Test/src/cn/sdut/pojo/PersonMapper.xml"/>--> </mappers>
3.通过sqlSessionFactory获取SqlSession(数据源执行器)
- 获取事务工厂
- 创建一个sql执行器对象
- 构造DefaultSqlSession
4.SqlSession进行CRUD或者动态代理创建mapper类 - 根据statement获取MappedStatement
- 参数和MappedStatement组装成sql
- 生成缓存key
-判断是否开启二级缓存,有就去二级缓存在,没有或者找不到就去查数据库(BaseExecutor的query方法) - 判断以及缓存是否有,没有就去查数据库,查到并放入一级缓存。
对象介绍
Executor
1.根据用户选择的执行器类型,构造出BatchExecutor、ReuseExecutor、SimpleExecutor
- BatchExecutor 批量插入的时候可以使用这个
- ReuseExecutor 可重复使用的连接
- SimpleExecutor 一次性连接,操作完后便销毁
2.如果全局配置开启缓存,则Executor进一步封装成CachingExecutor,每次查询会走缓存
3.如果使用了插件,则会调用动态代理和责任链,生成插件Executor
Cache
二级缓存
装饰器模式,如图:
public Cache build() {
// 默认PerpetualCache,最终的map缓存sql结果
// 如果没有设置淘汰策略,默认使用LRU
setDefaultImplementations();
// 反射获取PerpetualCache
Cache cache = newBaseCacheInstance(implementation, id);
setCacheProperties(cache);
// issue #352, do not apply decorators to custom caches 不将装饰器应用到自定义缓存
if (PerpetualCache.class.equals(cache.getClass())) {
for (Class<? extends Cache> decorator : decorators) {
// 获取默认的LruCache
cache = newCacheDecoratorInstance(decorator, cache);
setCacheProperties(cache);
}
// 如果设置了clearInterval,则会使用ScheduledCache:调度缓存,负责定时清空缓存
// SerializedCache.默认使用,序列化和反序列化存储
// LoggingCache 默认使用,记录缓存命中
// SynchronizedCache 默认开启,并发控制
// BlockingCache 默认不开启,使用ReentrantLock,锁的粒度更细
cache = setStandardDecorators(cache);
} else if (!LoggingCache.class.isAssignableFrom(cache.getClass())) {
cache = new LoggingCache(cache);
}
return cache;
}
TransactionalCache:每个事物都有一个缓存区,称之为暂存区,如果AutoCommit设置为true,则二级缓存是不生效的,只有执行commit的时候,才会清理暂存区和更新二级缓存,这样就不会脏读了。
一级缓存
每个查询(一个事物)都会把查询缓存起来,当同事物同一个sql就会使用到一级缓存,所以当你整合到spring使用spring的事物的时候,那么一级缓存就失效了。
BaseBuilder相关类
- XMLConfigBuilder
解析全局配置文件,内部的mapper使用XMLMapperBuilder解析 - XMLMapperBuilder
解析所有的mapper.xml,内部的的节点使用XMLStatementBuilder解析 - XMLStatementBuilder
解析xml的各个节点(select、update等),内部使用XMLScriptBuilder处理sql部分 - XMLScriptBuilder
解析xml中各个节点sql部分的Builder。
MyBatissql语句的解析过程
- SqlNode
xml中一个个标签,比如上述sql的update,trim,if标签。 - SqlSource
由SqlNode构成,用于获取BoundSql - BoundSql
最终产生sql的类,包括sql语句,参数,参数源数据等参数
设计模式
Builder模式,例如SqlSessionFactoryBuilder、XMLConfigBuilder、XMLMapperBuilder、XMLStatementBuilder、CacheBuilder;
工厂模式,例如SqlSessionFactory、ObjectFactory、MapperProxyFactory;
单例模式,例如ErrorContext和LogFactory;
代理模式,Mybatis实现的核心,比如MapperProxy、ConnectionLogger,用的jdk的动态代理;还有executor.loader包使用了cglib或者javassist达到延迟加载的效果;
组合模式,例如SqlNode和各个子类ChooseSqlNode等;
模板方法模式,例如BaseExecutor和SimpleExecutor,还有BaseTypeHandler和所有的子类例如IntegerTypeHandler;
适配器模式,例如Log的Mybatis接口和它对jdbc、log4j等各种日志框架的适配实现;
装饰者模式,例如Cache包中的cache.decorators子包中等各个装饰者的实现;
二.SpringBoot整合(spring整合过程差不多,只不过是springboot自动的默认值变手动)
AutoConfiguration
1.spring.factory文件指定EnableAutoConfiguration为MybatisLanguageDriverAutoConfiguration(sql加载)和MybatisAutoConfiguration(这个是我们现在关注的)
2.MybatisAutoConfiguration类中定义了默认的SqlSessionFactory的bean和SqlSessionTemplate
3.这个类中会加载用户配置和xml
MapperScan
1.@MapperScan注解导入MapperScannerRegistrar类,而MapperScannerRegistrar实现ImportBeanDefinitionRegistrar,在加载配置类的时候就会调用到registerBeanDefinitions方法
2.registerBeanDefinitions方法注册MapperScannerConfigurer的bean定义,而且MapperScannerConfigurer实现BeanDefinitionRegistryPostProcessor的postProcessBeanDefinitionRegistry方法,在扫描配置类时会被调用
3.构造ClassPathMapperScanner,扫描配置的basePackage
4.ClassPathMapperScanner实现了ClassPathBeanDefinitionScanner,重写isCandidateComponent,去判断扫描的类是不是component(逻辑就是是不是接口)。
5.调用父类的(spring的)doScan方法,得到beanDefinitions
6.遍历beanDefinitions,将BeanDefinition进行修改,beanclass修改为MapperFactoryBean,AutowireMode修改为byType
7.调用MapperFactoryBean的getObject方法(懒加载的),getSqlSession()去得到一个sqlSession对象,然后调用sqlSession的getMapper,生成一个代理对象(jdk动态代理),这样就成为spring管理的bean了。