MyBatis源码分析-4 SqlSession源码分析

迈不过友情╰ 2022-11-19 09:39 408阅读 0赞

**                                                                                                                                                                                                                                                                  作者：田超凡**

**                                                                                                                                                                                                                                                                  版权所有，严禁复制转载**

**1 SqlSession****提供select/insert/update/delete方法，在旧版本中使用SqlSession接口的这些方法，新版本都使用Mapper映射器接口中自定义的SQL执行方法，统一基于JDK动态代理实现，调用对应Mapper映射器接口的代理实例MapperProxy的invoke方法**

**2** **每个线程都应该有它自己的 SqlSession 实例。**

**SqlSession** **的实例不是线程安全的，因此是不能被共享的。**

**每个SqlSession默认都会开启一级缓存，该设置无法更改也不需要手动配置**

**sqlSession.getMapper()****完整执行链路，该方法用来创建和获取目标Mapper映射器接口的代理实例,该方法完整执行链路如下：**

**(1) sqlSession.getMapper(Class<?> mapperClass)**

**(2) MapperRegistry Map<Class<?>, MapperProxyFactory<?>> knownMappers.get(mapperClass)**

**(3) MapperProxyFactory<?> -> createProxy -> MapperProxy<?> 返回创建好的代理实例**

**(4) 调用代理实例的SQL方法时，执行链路：MapperProxy invoke() -> MapperMethodInvoker -> PlainMethodInvoker -> MapperMethod -> MethodSignature -> ParamNameResolver -> MappedStatement -> BaseExecutor**

**-> 未开启一级缓存的情况：SimpleExecutor handler() -> doQuery / doUpdate**

**-> 开启了一级缓存的情况：CachingExecutor handler() -> TransactionCacheManagement获取一级缓存结果(EhCache -> Memcache -> Redis依次获取)，如果未取到，则再调用delegate(BaseExecutor)的query()方法去二级缓存(Perpurtual localCacheMap)查，如果能查到，则直接返回，如果不能查到，则调用SimpleExecutor的doQuery去数据库查，查到结果(DefaultResultSetHandler)后同步到二级缓存**

**(5) 调用JDBC执行数据库操作**

**RoutingStatementHandler -> PreparedStatementHandler -> BaseHandler -> DefaultResultSetHandler**

**源码分析：**

**1 调用DefaultSqlSession getMapper()方法创建和获取Mapper映射器接口代理实例**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70][]

2 调用MapperRegistry的 getMapper方法从knownMappers中获取映射器接口代理实例工厂MapperProxyFactory<?>

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 1][]

3 通过MapperProxyFactory<?> 创建代理实例MapperProxy<?>，基于JDK动态代理实现

![902b5bcc9f390f04ec563ae6da4dd4f4.png][]

![0c478b16664e834cf6b0510871484aee.png][]

4 执行SQL的源码分析

4.1 调用Mapper映射器接口的SQL方法进行持久化操作时，会执行MapperProxy<?> 的代理方法invoke

![da963e0982b35ade79f76822577a5746.png][]

4.2 获取MapperMethodInvoke执行器来执行目标方法，新版本默认创建的实现都是PlainMethodInvoker

![c02a7ebe9d7d4dd3792b0168932076d6.png][]

![5bdb5b593e424954a285a4b1c9b32b7c.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 2][]

4.3 调用PlainMethodInvoker的invoke方法

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 3][]

4.4 调用MapperMethod的execute方法封装需要执行的SQL和参数，封装SQL参数时会用到MethodSignature，最后交到SqlSession执行

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 4][]

4.5 调用SqlSession中定义的增删改方法，默认都在update方法里面执行

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 5][]

4.6 获取初始化阶段注册好的MappedStatement，一个MappedStatement对应一条SQL语句，全局唯一，通过Mapper映射文件的命名空间+sql id唯一定位

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 7][]

4.7 调用BaseExecutor execute() -> SimpleExecutor doUpdate()，进而调用PreparedStatementHandler执行SQL，这里先展示DML增删改语句的执行原理

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 9][]

4.8 调用CachingExecutor query() 执行DQL

SelectOne底层原理查询分析

1.   当查询单条数据的时候，最终还是调用selectList查询多个结果集包装程单个对象。

![20210121233619243.png][]

1.   从configuration中获取到MappedStatement（对应的sql语句配置），调用executor的query方法实现执行。

![2021012123364211.png][]

先查询二级缓存，是否有缓存，没有的话调用delegate.<E> query

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 10][]

如果一级缓存中没有该结果，会调用queryFromDatabase查询数据库得到数据让后在缓存到一级缓存中，下次查询的时候相同的sql语句直接走一级缓存不会查询数据库。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70]: /images/20221119/fdaaae9ab28349a7a5b6f17691ec73a5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 1]: /images/20221119/ff1266d7a06443a3a7a9487978eaf7e0.png
[902b5bcc9f390f04ec563ae6da4dd4f4.png]: /images/20221119/238d3b2df6ca44f6b76f6f10db8861af.png
[0c478b16664e834cf6b0510871484aee.png]: /images/20221119/b7c4c4168846490dae59b0717cb1053a.png
[da963e0982b35ade79f76822577a5746.png]: /images/20221119/191d4ff19d03435dac47b54b792321e9.png
[c02a7ebe9d7d4dd3792b0168932076d6.png]: /images/20221119/9b7511a63f2d4b27a29863b21e7e543a.png
[5bdb5b593e424954a285a4b1c9b32b7c.png]: /images/20221119/9744bddca054403c92486452ca7329bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 2]: /images/20221119/09e65e9fea7545d4966cd75f7a8c48ae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 3]: /images/20221119/d736b936c18849769ba93f70db73c341.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 4]: /images/20221119/82da2aaf91474d53bfaa7da4a56ea2e4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 5]: /images/20221119/7b380b4905ab42d3bc09be19f935499b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 6]: /images/20221119/a24afc85604a47cf8fbc40b33cbc49e4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 7]: /images/20221119/59937aededee400a92dabe69a37d84a1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 8]: /images/20221119/349bd9732c87474d82f19c382099862f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 9]: /images/20221119/d876fe11d18a4eefa78db30a1ff4df01.png
[20210121233619243.png]: /images/20221119/c055e3008ad54461b650d3c4a899f0de.png
[2021012123364211.png]: /images/20221119/4c582c4a0ed742a590344cedd04b62cc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwMDU2MzQx_size_16_color_FFFFFF_t_70 10]: /images/20221119/de99c51890b94a3ea73edd9d03a04f8e.png