文档章节

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

强子1985
 强子1985
发布于 2017/04/06 19:32
字数 608
阅读 25
收藏 2

首先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对象。

 

© 著作权归作者所有

共有 人打赏支持
强子1985

强子1985

粉丝 875
博文 1097
码字总数 803211
作品 8
南京
架构师
私信 提问
Mybatis源码概览(一)

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

robin-yao
2016/03/22
575
0
【深入浅出MyBatis系列一】MyBatis入门

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

陶邦仁
2015/12/22
4.1K
0
Mybatis执行流程(一)

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

wjk_snail
2016/06/22
57
0
Mybatis源码概览(二) ---Plugin扩展与Spring结合原理

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

robin-yao
2016/03/23
530
0
ORM框架 hibernate和mybatis 连接数据详解

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

LYQ1990
2016/04/28
37
0

没有更多内容

加载失败,请刷新页面

加载更多

20181213 上课截图

小丑鱼00
9分钟前
0
0
nginx+php-fpm配置后页面显示空白的解决方法以及用nginx和php-fpm解决“502 Bad Gateway”问题

https://stackoverflow.com/questions/15423500/nginx-showing-blank-php-pages For reference, I am attaching my location block for catching files with the .php extension: location ~......

Yao--靠自己
16分钟前
1
0
mac 没声音

somehow不时就会出现这种情况。之前都得重启。 其实可以直接在terminal里打以下命令: sudo kextunload /System/Library/Extensions/AppleHDA.kext sudo kextload /System/Library/Extension...

dubox
32分钟前
1
0
看完让你彻底搞懂Websocket原理

作者:Ovear 链接:https://www.zhihu.com/question/20215561/answer/40316953 来源:知乎 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。 额。。最高票答案没答到点...

时刻在奔跑
47分钟前
2
0
Spring Cloud Stream消费失败后的处理策略(一):自动重试

之前写了几篇关于Spring Cloud Stream使用中的常见问题,比如: 如何处理消息重复消费 如何消费自己生产的消息 下面几天就集中来详细聊聊,当消息消费失败之后该如何处理的几种方式。不过不论...

程序猿DD
49分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部