博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
mybatis中获取sqlSession的源码分析
阅读量:6171 次
发布时间:2019-06-21

本文共 2472 字,大约阅读时间需要 8 分钟。

hot3.png

 

 

0 SqlSessionFactoryBuilder类

SqlSessionFactoryBuilder sqlSessionFacotory=SqlSessionFactoryBuilder().build(reader)

public SqlSessionFactory build(Reader reader) {

return build(reader, null, null);

}

 

它使用了一个参照了XML文档或更特定的SqlMapConfig.xml文件的Reader实例。

//可选的参数是environment和properties。Environment决定加载哪种环境(开发环境/生产环境),包括数据源和事务管理器。

//如果使用properties,那么就会加载那些properties(属性配置文件),那些属性可以用${propName}语法形式多次用在配置文件中。和Spring很像,一个思想?

public SqlSessionFactory build(Reader reader, String environment, Properties properties) {

try {

//委托XMLConfigBuilder来解析xml文件,并构建

XMLConfigBuilder parser = new XMLConfigBuilder(reader, environment, properties);

return build(parser.parse());

} catch (Exception e) {

//这里是捕获异常,包装成自己的异常并抛出的idiom?,最后还要reset ErrorContext

throw ExceptionFactory.wrapException("Error building SqlSession.", e);

} finally {

ErrorContext.instance().reset();

try {

reader.close();

} catch (IOException e) {

// Intentionally ignore. Prefer previous error.

}

}

}

 

public SqlSessionFactory build(Configuration config) {

return new DefaultSqlSessionFactory(config);

}

1 DefaultSqlSessionFactory类

public SqlSession openSession() {

return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);

}

 

private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {

Transaction tx = null;

try {

final Environment environment = configuration.getEnvironment();

final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);

//通过事务工厂来产生一个事务

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

//生成一个执行器(事务包含在执行器里)

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

//然后产生一个DefaultSqlSession

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();

}

}

 

2.DefaultSqlSession类

public DefaultSqlSession(Configuration configuration, Executor executor, boolean autoCommit) {

this.configuration = configuration;

this.executor = executor;

this.dirty = false;

this.autoCommit = autoCommit;

}

 

获得DefaultSqlSession类其中包含执行器(事务相关),配置信息

public interface SqlSession extends Closeable {.....}

SqlSession session = sqlMapper.openSession();

转载于:https://my.oschina.net/iioschina/blog/1860183

你可能感兴趣的文章
【挨踢人物传】茶乡浪子:“传奇”职场路,一生感谢情(第12期)
查看>>
我的友情链接
查看>>
c#关于数据库连接操作的案例
查看>>
聊聊最近接触的媒体查询!
查看>>
HAproxy指南之haproxy重定向应用(案例篇)
查看>>
学习 HTTP协议挺不错的一个类
查看>>
深入字节码 -- ASM 关键接口 MethodVisitor
查看>>
linux 文件权限
查看>>
Linux常用命令集合
查看>>
Oracle DML
查看>>
Linux - FHS文件系统层次标准
查看>>
报错:Invalid bound statement (not found)
查看>>
Linux GPT分区格式磁盘的相关操作
查看>>
通过Docker进程pid获取容器id
查看>>
L15.2 zabbix基础(2)组件说明介绍
查看>>
impdp 常见问题 10g/11g/12c 问题解决 ERIKXUE
查看>>
2013年1月工作小结 -- 上线后的懈怠
查看>>
敏捷宣言
查看>>
php Yii: 出现undefined offset 或者 undefined index解决方案
查看>>
Bash编程入门
查看>>