Mybatis执行流程的源码分析
今天就跟大家聊聊有关Mybatis执行流程的源码分析,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
创新互联建站是一家专业提供光山企业网站建设,专注与成都网站设计、网站建设、外贸网站建设、H5技术、小程序制作等业务。10年已为光山众多企业、政府机构等服务。创新互联专业网站建设公司优惠进行中。
一:Mybatis源码分析流程
public static void main(String[] args) { try { // 基本mybatis环境 // 1.定义mybatis_config文件地址 String resources = "mybatis_config.xml"; // 2.获取InputStreamReaderIo流 Reader reader = Resources.getResourceAsReader(resources); // 3.获取SqlSessionFactory SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader); // 4.获取Session SqlSession sqlSession = sqlSessionFactory.openSession(); // 5.操作Mapper接口 UserMapper mapper = sqlSession.getMapper(UserMapper.class); UserEntity user = mapper.getUser(2); System.out.println(user.getName()); } catch (Exception e) { e.printStackTrace(); } }
总结:
1、读取Mybatis配置文件信息
2、获取SqlSessionFactory
a.使用XMLMappperBuilder解析Mybatis配置文件,封装成Environment对象,再把Environment对象设置给Configuration对象;
b.调用ConfigurationElement函数,最终执行addMappedStatement方法,将mapper配置文件中的每一条SQL语句封装成mappedStatement对象,作为value保存在HashMap集合中;
c.进入addLoaderResource方法,使用HashSet集合存放mybatis的mapper.xml 映射文件路径地址;
d.进入bindMapperForNamespace()方法,通过namespace使用Java反射机制找到mapper接口,再调用addMapper()方法,判断是否是接口类型,是否注册过(注册过则抛出异常)其中mapperRegistry通过HashMap保存mapper接口,【key:接口;value:MapperProxyFactory】
3、获取session
a.进入openSession()方法,执行newExecutor()方法创建执行器;
b.先创建 SimpleExecutor简单执行器,再判断是否开启了二级缓存,默认是开启的,就会去创建CacheExecutor缓存执行器,
c.执行interceptorChain.pluginAll()方法,责任链设计模式,底层使用动态代理技术,使开发者可以自定义插件开发,只需要实现Interceptor接口,并指定想要拦截的方法签名即可,最后返回执行器;
4、操作mapper接口
a.调用getMapper()方法,最终执行mapperProxyFactory.newInstance(sqlSession)方法创建代理类MapperProxy;
b.当我们调用mapper,getUser()方法的时候,就会去执行MapperProxy代理类的invoke()方法;
c.判断mapper接口是否有实现类,显然我们没有实现类,则调用cacheMapperMethod()方法去缓存中获取要代理的方法method;
d.进入cacheMapperMethod()方法先去查找缓存中有没有,没有的话将mapper配置文件中配置的SQL语句和对应的mapper接口方法进行关联并放入map缓存中,后期直接走缓存了,最后执行execute()方法;
e.执行execute()方法,最终调用selectOne()方法;
f.进入selectOne()方法,底层还是查询所有的,但是取第一个,查询多个的话会抛出异常;
g.进入selectList()方法,调用getMapperStatement()方法获取对应的SQL语句;
h.执行query()方法进行查询,判断如果开启了二级缓存并且配置了二级缓存存储介质(redis,EhCache..)则先走二级缓存中查询数据,第一次查询是没有缓存数据的,则刷新缓存配置,清除缓存。
i.二级缓存(sessionFactory)中没有查询到数据,就回去执行BaseExecutor去查询 HashMap一级缓存中(sqlSession)是否有缓存数据,一级缓存(PerpetualCache)存放在内存中的,同理也是没有的,最后查询数据库DB。
j.将从数据库查询出来的数据缓存到一级缓存中,再把一级缓存中的数据同步到二级缓存,添加到二级缓存之前先添加到getTransactionalCache的entritiesToAddOnCommit的map集合中临时缓存起来;
k.调用executor.close()方法循环迭代TransactionCache,最后将临时map缓存数据提交到二级缓存中,如果事务回滚,则会将缓存数据清除掉。
看完上述内容,你们对Mybatis执行流程的源码分析有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。
分享文章:Mybatis执行流程的源码分析
新闻来源:http://myzitong.com/article/gdojes.html