华为云上面可以代做网站吗,新建网站如何被搜索,网站开发流程荆州,国外手机主题网站前言#xff1a;
前文我们从源码层面梳理了 SqlSessionFactory 的创建过程#xff0c;本篇我们继续分析一下 SqlSession 的获取过程。
初识 MyBatis 【MyBatis 核心概念】
案例代码#xff1a;
public class MyBatisTest {Testpublic void test() throws IOException {/…前言
前文我们从源码层面梳理了 SqlSessionFactory 的创建过程本篇我们继续分析一下 SqlSession 的获取过程。
初识 MyBatis 【MyBatis 核心概念】
案例代码
public class MyBatisTest {Testpublic void test() throws IOException {//读取配置文件InputStream is Resources.getResourceAsStream(mybatis-config.xml);//创建 SqlSessionFactoryBuilder 对象SqlSessionFactoryBuilder builder new SqlSessionFactoryBuilder();//通过 SqlSessionBuilder 对象 解析 mybatis-config.xml 文件 构建一个SqlSessionFactory SqlSessionFactory sqlSessionFactory builder.build(is);//通过SqlSessionFactory构建一个SqlSessionSqlSession session sqlSessionFactory.openSession();//通过SqlSession 获取 Mapper 实例UserMapper userMapper session.getMapper(UserMapper.class);//获取数据ListUser users userMapper.findAll();//打印输出for (User user : users) {System.out.println(user);}//关闭资源session.close();is.close();}
}本篇我们将主要对 sqlSessionFactory.openSession() 这句代码进行分析。
获取 SqlSession 源码分析
DefaultSqlSessionFactory#openSession 方法源码分析
DefaultSqlSessionFactory#openSession 方法只是调用了 DefaultSqlSessionFactory#openSessionFromDataSource 方法并传入了默认的执行器类型、隔离级别、是否自动提交参数。
//org.apache.ibatis.session.defaults.DefaultSqlSessionFactory#openSession()
public SqlSession openSession() {//使用默认的执行器类型(默认是SIMPLE) 默认隔离级别 非自动提交 委托给 openSessionFromDataSource 方法return this.openSessionFromDataSource(this.configuration.getDefaultExecutorType(), (TransactionIsolationLevel)null, false);
}执行器类型
SIMPLE简单执行器 SimpleExecutor每执行一条 SQL都会打开一个 Statement执行完成后会关闭。REUSE重用执行器 ReuseExecutor其内部会缓存一个 MapString, Statement 每次编译完成的 Statement 都会进行缓存不会关闭可以重复使用。BATCH批量执行器基于 JDBC 的 addBatch、executeBatch 功能只能作用于 insert、update、delete 语句。CachingExecutor缓存执行器使用了装饰器模式在开启缓存的时候会在上面三种执行器上包装一层 CachingExecutor。
package org.apache.ibatis.session;public enum ExecutorType {SIMPLE,REUSE,BATCH;private ExecutorType() {}
}DefaultSqlSessionFactory#openSessionFromDataSource 方法源码分析
DefaultSqlSessionFactory#openSessionFromDataSource 方法逻辑很简单先获取创建 SqlSession 的必要参数然后调用 DefaultSqlSession 的构造方法创建了 SqlSession 。
//org.apache.ibatis.session.defaults.DefaultSqlSessionFactory#openSessionFromDataSource
private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {//事务Transaction tx null;//SqlSessionDefaultSqlSession var8;try {//获取环境Environment environment this.configuration.getEnvironment();//获取事务工厂TransactionFactory transactionFactory this.getTransactionFactoryFromEnvironment(environment);//获取一个事务tx transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);//根据 事务 和 执行器类型创建一个执行器Executor executor this.configuration.newExecutor(tx, execType);//根据配置 执行器 事务提交方式创建一个默认的 SqlSessionvar8 new DefaultSqlSession(this.configuration, executor, autoCommit);} catch (Exception var12) {this.closeTransaction(tx);throw ExceptionFactory.wrapException(Error opening session. Cause: var12, var12);} finally {ErrorContext.instance().reset();}return var8;
}//org.apache.ibatis.session.defaults.DefaultSqlSession#DefaultSqlSession(org.apache.ibatis.session.Configuration, org.apache.ibatis.executor.Executor, boolean)
public DefaultSqlSession(Configuration configuration, Executor executor, boolean autoCommit) {this.configuration configuration;this.executor executor;this.dirty false;this.autoCommit autoCommit;
}Configuration#newExecutor 方法源码分析
Configuration#newExecutor 主要是对执行器类型进行判断然后生成执行器并通过动态代理得到代理对象并将执行器加入拦截器链。
//org.apache.ibatis.session.Configuration#newExecutor
public Executor newExecutor(Transaction transaction, ExecutorType executorType) {executorType executorType null ? this.defaultExecutorType : executorType;executorType executorType null ? ExecutorType.SIMPLE : executorType;Object 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);}//是否开启缓存if (this.cacheEnabled) {//开启缓存 创建缓存执行器executor new CachingExecutor((Executor)executor);}//责任链模式 将执行器加入拦截器链 使用JDK动态代理增强所有的拦截器 Executor executor (Executor)this.interceptorChain.pluginAll(executor);return executor;
}获取 SqlSession 的源码很简单希望可以帮助到有需要的小伙伴。
欢迎提出建议及对错误的地方指出纠正。
