文档章节

MyBatis-3.4.2-源码分析16:XML解析之SqlSessionFactory|SqlSession

强子哥哥
 强子哥哥
发布于 2017/04/06 19:32
字数 608
阅读 23
收藏 2
点赞 0
评论 0

首先sqlSessionFactory的类为:

main[1] print sqlSessionFactory
 sqlSessionFactory = "org.apache.ibatis.session.defaults.DefaultSqlSessionFactory@3e2e18f2"
main[1] 

得知,常规情况下,生成了DefaultSqlSessionFactory类实例。

接下来,打开session

sqlSession = sqlSessionFactory.openSession();

我们来看看,发生了什么

@Override
	public SqlSession openSession() {
		//开始
		return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
	}

---

configuration.getDefaultExecutorType()默认返回simple类型,

Step completed: "thread=main", org.apache.ibatis.session.Configuration.getDefaultExecutorType(), line=408 bci=0
408    		return defaultExecutorType;

main[1] print defaultExecutorType
 defaultExecutorType = "SIMPLE"

---继续执行openSessionFromDataSource函数

private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level,
			boolean autoCommit) {
		// 看到这里了
		// 初始化为nul
		Transaction tx = null;
		try {
			// 开始执行
			// 这里返回一个封装对象,里面有事务工厂句柄 & 连接池句柄
			final Environment environment = configuration.getEnvironment();
			// 取出事务工厂句柄
			// org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory
			final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
			// 继续执行
			tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
			final Executor executor = configuration.newExecutor(tx, execType);
			return new DefaultSqlSession(configuration, executor, autoCommit);
		} catch (Exception e) {
			closeTransaction(tx); // may have fetched a connection so lets call
									// close()
			throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);
		} finally {
			ErrorContext.instance().reset();
		}
	}

解读:上面这段代码,是找到environment对象,取出事务工厂实例,

然后执行了一行很重要的代码:

tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);

下面,我们开始来仔细研究这行代码。

--------------------------------------------------------------------------------分割线

这里的dataSource我已经设置成了阿里的druid类型,打印如下:

main[1] print dataSource.getClass()
 dataSource.getClass() = "class com.alibaba.druid.pool.DruidDataSource"
main[1] 

继续执行newTransaction函数,代码如下,很简单

  @Override
  public Transaction newTransaction(DataSource ds, TransactionIsolationLevel level, boolean autoCommit) {
    return new JdbcTransaction(ds, level, autoCommit);
  }

先记住1个断点

stop in org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory.newTransaction

返回的事务对象为

org.apache.ibatis.transaction.jdbc.JdbcTransaction

接下来,是执行

final Executor executor = configuration.newExecutor(tx, execType);

---继续处理

public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
		// 从这里开始看
		executorType = executorType == null ? defaultExecutorType : executorType;
		executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
		// 在这里,还是simple模式
		Executor executor;
		if (ExecutorType.BATCH == executorType) {
			executor = new BatchExecutor(this, transaction);
		} else if (ExecutorType.REUSE == executorType) {
			executor = new ReuseExecutor(this, transaction);
		} else {
			// 执行到这里
			executor = new SimpleExecutor(this, transaction);
		}
		// 生成了SimpleExecutor变量
		//我觉得这里不应该用cacheEnabled,所以我在settings里把它屏蔽掉了
		//接下来就不执行
		if (cacheEnabled) {
			executor = new CachingExecutor(executor);
		}
		executor = (Executor) interceptorChain.pluginAll(executor);
		return executor;
	}

然后,就是执行

executor = (Executor) interceptorChain.pluginAll(executor);

看字面,是interceptorChain添加这个plugin.我们看具体实现吧

public Object pluginAll(Object target) {
	  //从这里开始执行
	  //这里是插件机制了
    for (Interceptor interceptor : interceptors) {
      target = interceptor.plugin(target);
    }
    return target;
    //返回自己
  }

如果后面有需求,就应该在这定制插件plugin.

---------------------------------------------------继续执行

return new DefaultSqlSession(configuration, executor, autoCommit);

这个没啥好说的,总结一下:

生成了一个DefaultSqlSession对象,这个对象包含executor,

executor包含transaction对象,transaction对象包含dataSource对象。

 

© 著作权归作者所有

共有 人打赏支持
强子哥哥

强子哥哥

粉丝 856
博文 551
码字总数 647493
作品 8
南京
架构师
Mybatis源码概览(一)

一般拿到源码会无从下手,我的基本思路一般就是根据一个基本的helloWorld Debug下去,把主线先大概理一遍,然后再具体分析细节,没有必要一个类一个类细看,看了也会忘掉。自己理源码的时候看...

robin-yao ⋅ 2016/03/22 ⋅ 0

【深入浅出MyBatis系列一】MyBatis入门

深入浅出MyBatis系列 【深入浅出MyBatis系列一】MyBatis入门 【深入浅出MyBatis系列二】配置简介(MyBatis源码篇) 【深入浅出MyBatis系列三】Mapper映射文件配置 【深入浅出MyBatis系列四】...

陶邦仁 ⋅ 2015/12/22 ⋅ 0

Mybatis执行流程(一)

搭建一个简单的Mybatis+Maven项目 Maven依赖 代码 配置文件 通过SqlSessionFactory获取SqlSession 执行流程图 源码走读 获取reader 获取SqlSessionFactory build()方法 解析配置返回configu...

wjk_snail ⋅ 2016/06/22 ⋅ 0

Mybatis源码概览(二) ---Plugin扩展与Spring结合原理

本文主要介绍Mybatis通过动态代理避免对sqlSession直接调用,而是通过MapperProxy代理技术生成了具体dao接口的Mapper实例,里面封装了对sqlSession的调用;Mybatis预留了Interceptor接口,用...

robin-yao ⋅ 2016/03/23 ⋅ 0

ORM框架 hibernate和mybatis 连接数据详解

工作中,需要学习一下MyBatis sqlSession的产生过程,翻看了mybatis-spring的源码,阅读了一些mybatis的相关doc,对mybatis sqlSession有了一些认知和理解,这里简单的总结和整理一下。 首先...

LYQ1990 ⋅ 2016/04/28 ⋅ 0

《深入理解mybatis原理》 Mybatis初始化机制详解

对于任何框架而言,在使用前都要进行一系列的初始化,MyBatis也不例外。本章将通过以下几点详细介绍MyBatis的初始化过程。 1.MyBatis的初始化做了什么 2. MyBatis基于XML配置文件创建Configu...

jason_wu_2 ⋅ 2016/12/01 ⋅ 0

MyBatis 基本使用

一、数据库表SQL,参见 http://my.oschina.net/u/1757476/blog/497420 文章中的建表SQL语句。 二、下面以程序实例介绍MyBatis的使用 第一步:创建Java工程 使用eclipse创建一个Java工程,jdk...

pradosoul ⋅ 2015/08/31 ⋅ 1

Mybatis3.3.x技术内幕(一):SqlSession和SqlSessionFactory列传

前言:我长大了,成年了,有需求,但我单身,所以我要讨个媳妇,要求是:漂亮、高挑、身材好、笑容甜美…… 和A相亲:漂亮,不够高挑。 和B相亲:高挑,身材不够好。 和C相亲:身材好,笑容不...

祖大俊 ⋅ 2016/04/25 ⋅ 2

关于MyBatis sqlSession的一点整理

原文地址:关于MyBatis sqlSession的一点整理 工作中,需要学习一下MyBatis sqlSession的产生过程,翻看了mybatis-spring的源码,阅读了一些mybatis的相关doc,对mybatis sqlSession有了一些...

Realfighter ⋅ 2015/01/04 ⋅ 1

【深入浅出MyBatis系列十】与Spring集成

深入浅出MyBatis系列 【深入浅出MyBatis系列一】MyBatis入门 【深入浅出MyBatis系列二】配置简介(MyBatis源码篇) 【深入浅出MyBatis系列三】Mapper映射文件配置 【深入浅出MyBatis系列四】...

陶邦仁 ⋅ 2015/12/25 ⋅ 2

没有更多内容

加载失败,请刷新页面

加载更多

下一页

浅谈springboot Web模式下的线程安全问题

我们在@RestController下,一般都是@AutoWired一些Service,由于这些Service都是单例,所以并不存在线程安全问题。 由于Controller本身是单例模式 (非线程安全的), 这意味着每个request过来,...

算法之名 ⋅ 今天 ⋅ 0

知乎Java数据结构

作者:匿名用户 链接:https://www.zhihu.com/question/35947829/answer/66113038 来源:知乎 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。 感觉知乎上嘲讽题主简...

颖伙虫 ⋅ 今天 ⋅ 0

Confluence 6 恢复一个站点有关使用站点导出为备份的说明

推荐使用生产备份策略。我们推荐你针对你的生产环境中使用的 Confluence 参考 Production Backup Strategy 页面中的内容进行备份和恢复(这个需要你备份你的数据库和 home 目录)。XML 导出备...

honeymose ⋅ 今天 ⋅ 0

JavaScript零基础入门——(九)JavaScript的函数

JavaScript零基础入门——(九)JavaScript的函数 欢迎回到我们的JavaScript零基础入门,上一节课我们了解了有关JS中数组的相关知识点,不知道大家有没有自己去敲一敲,消化一下?这一节课,...

JandenMa ⋅ 今天 ⋅ 0

火狐浏览器各版本下载及插件httprequest

各版本下载地址:http://ftp.mozilla.org/pub/mozilla.org//firefox/releases/ httprequest插件截至57版本可用

xiaoge2016 ⋅ 今天 ⋅ 0

Docker系列教程28-实战:使用Docker Compose运行ELK

原文:http://www.itmuch.com/docker/28-docker-compose-in-action-elk/,转载请说明出处。 ElasticSearch【存储】 Logtash【日志聚合器】 Kibana【界面】 答案: version: '2'services: ...

周立_ITMuch ⋅ 今天 ⋅ 0

使用快嘉sdkg极速搭建接口模拟系统

在具体项目研发过程中,一旦前后端双方约定好接口,前端和app同事就会希望后台同事可以尽快提供可供对接的接口方便调试,而对后台同事来说定好接口还仅是个开始、设计流程,实现业务逻辑,编...

fastjrun ⋅ 今天 ⋅ 0

PXE/KickStart 无人值守安装

导言 作为中小公司的运维,经常会遇到一些机械式的重复工作,例如:有时公司同时上线几十甚至上百台服务器,而且需要我们在短时间内完成系统安装。 常规的办法有什么? 光盘安装系统 ===> 一...

kangvcar ⋅ 昨天 ⋅ 0

使用Puppeteer撸一个爬虫

Puppeteer是什么 puppeteer是谷歌chrome团队官方开发的一个无界面(Headless)chrome工具。Chrome Headless将成为web应用自动化测试的行业标杆。所以我们很有必要来了解一下它。所谓的无头浏...

小草先森 ⋅ 昨天 ⋅ 0

Java Done Right

* 表示难度较大或理论性较强。 ** 表示难度更大或理论性更强。 【Java语言本身】 基础语法,面向对象,顺序编程,并发编程,网络编程,泛型,注解,lambda(Java8),module(Java9),var(...

风华神使 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部