文档章节

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

粉丝 862
博文 935
码字总数 645914
作品 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

没有更多内容

加载失败,请刷新页面

加载更多

mysql在查询结果前加序号

在查询结果前加序号: set @rn=0; select @rn:=@rn+1 as 序号,你查询的结果集

lyle_luo
21分钟前
1
0
webpack 工作原理

暂无内容

agenyun
29分钟前
1
0
iOS返回指定控制器或者关闭自己当前控制器

RT。。。 这种情况其实很常见,比如,从A界面进入B界面在进入C界面,如果返回时,直接从C回到A,怎么做?或者说无限跳转进入BCDEF...XYZ。。。之后直接返回某一个界面,怎么做? 其实这种的有...

RainOrz
30分钟前
1
0
文章收藏

对接口或者方法进行性能测试的工具contiperf: http://www.ltesting.net/ceshi/ceshijishu/xncs/2012/1127/205747.html...

月下狼
35分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部