基于SqlSessionFactory的openSession方法使用

目录
  • SqlSessionFactory的openSession方法
    • 创建Sqlsession的地方只有一个
    • 我们可以看到实际创建SqlSession的地方
    • Executor的创建
    • Mapper
    • MapperProxy的invoke
  • openSession()到底做了什么

SqlSessionFactory的openSession方法

正如其名,Sqlsession对应着一次数据库会话。

由于数据库回话不是永久的,因此Sqlsession的生命周期也不应该是永久的,相反,在你每次访问数据库时都需要创建它(当然并不是说在Sqlsession里只能执行一次sql,你可以执行多次,当一旦关闭了Sqlsession就需要重新创建它)。

创建Sqlsession的地方只有一个

那就是SqlsessionFactory的openSession方法

public SqlSessionopenSession() {
    returnopenSessionFromDataSource(configuration.getDefaultExecutorType(),null, false);
}

我们可以看到实际创建SqlSession的地方

是openSessionFromDataSource,如下:

private SqlSessionopenSessionFromDataSource(ExecutorType execType, TransactionIsolationLevellevel, boolean autoCommit) {
    Connectionconnection = null;
    try {  

        finalEnvironment environment = configuration.getEnvironment();
        final DataSourcedataSource = getDataSourceFromEnvironment(environment);
       TransactionFactory transactionFactory =getTransactionFactoryFromEnvironment(environment);
       connection = dataSource.getConnection();  

        if (level != null) {
           connection.setTransactionIsolation(level.getLevel());
        }  

       connection = wrapConnection(connection);
       Transaction tx = transactionFactory.newTransaction(connection,autoCommit);
        Executorexecutor = configuration.newExecutor(tx, execType);
        returnnewDefaultSqlSession(configuration, executor, autoCommit);  

    } catch (Exceptione) {
       closeConnection(connection);
        throwExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);  

    } finally {
       ErrorContext.instance().reset();
    }
}

可以看出,创建sqlsession经过了以下几个主要步骤:

1) 从配置中获取Environment;

2) 从Environment中取得DataSource;

3) 从Environment中取得TransactionFactory;

4) 从DataSource里获取数据库连接对象Connection;

5) 在取得的数据库连接上创建事务对象Transaction;

6) 创建Executor对象(该对象非常重要,事实上sqlsession的所有操作都是通过它完成的);

7) 创建sqlsession对象。

Executor的创建

Executor与Sqlsession的关系就像市长与书记,Sqlsession只是个门面,真正干事的是Executor,Sqlsession对数据库的操作都是通过Executor来完成的。与Sqlsession一样,Executor也是动态创建的:

  public ExecutornewExecutor(Transaction transaction, ExecutorType executorType) {
       executorType = executorType == null ? defaultExecutorType :executorType;
       executorType = executorType == null ?ExecutorType.SIMPLE : executorType;   

	Executor executor;
        if(ExecutorType.BATCH == executorType) {
           executor = new BatchExecutor(this,transaction);
        } elseif(ExecutorType.REUSE == executorType) {
           executor = new ReuseExecutor(this,transaction);
        } else {
            executor = newSimpleExecutor(this, transaction);
        }  

        if (cacheEnabled) {
           executor = new CachingExecutor(executor);
        }  

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

可以看出,如果不开启cache的话,创建的Executor只是3中基础类型之一,BatchExecutor专门用于执行批量sql操作,ReuseExecutor会重用statement执行sql操作,SimpleExecutor只是简单执行sql没有什么特别的。开启cache的话(默认是开启的并且没有任何理由去关闭它),就会创建CachingExecutor,它以前面创建的Executor作为唯一参数。CachingExecutor在查询数据库前先查找缓存,若没找到的话调用delegate(就是构造时传入的Executor对象)从数据库查询,并将查询结果存入缓存中。

Executor对象是可以被插件拦截的,如果定义了针对Executor类型的插件,最终生成的Executor对象是被各个插件插入后的代理对象

Mapper

Mybatis官方手册建议通过mapper对象访问mybatis,因为使用mapper看起来更优雅,就像下面这样:

session = sqlSessionFactory.openSession();
UserDao userDao= session.getMapper(UserDao.class);
UserDto user =new UserDto();
user.setUsername("iMbatis");
user.setPassword("iMbatis");
userDao.insertUser(user);

看起来没什么特别的,和其他代理类的创建一样,我们重点关注一下MapperProxy的invoke方法

MapperProxy的invoke

我们知道对被代理对象的方法的访问都会落实到代理者的invoke上来,MapperProxy的invoke如下:

public Objectinvoke(Object proxy, Method method, Object[] args) throws Throwable{
    if (method.getDeclaringClass()== Object.class) {
        return method.invoke(this, args);
    }  

    finalClass<?> declaringInterface = findDeclaringInterface(proxy, method);
    finalMapperMethod mapperMethod = newMapperMethod(declaringInterface, method, sqlSession);
    final Objectresult = mapperMethod.execute(args);  

    if (result ==null && method.getReturnType().isPrimitive()&& !method.getReturnType().equals(Void.TYPE)) {
        thrownewBindingException("Mapper method '" + method.getName() + "'(" + method.getDeclaringClass()
                + ") attempted toreturn null from a method with a primitive return type ("
               + method.getReturnType() + ").");
    }
    return result;
}

可以看到invoke把执行权转交给了MapperMethod,我们来看看MapperMethod里又是怎么运作的:

    public Objectexecute(Object[] args) {
        Objectresult = null;
        if(SqlCommandType.INSERT == type) {
            Objectparam = getParam(args);
            result= sqlSession.insert(commandName, param);
        } elseif(SqlCommandType.UPDATE == type) {
            Object param = getParam(args);
            result= sqlSession.update(commandName, param);
        } elseif(SqlCommandType.DELETE == type) {
            Objectparam = getParam(args);
            result= sqlSession.delete(commandName, param);
        } elseif(SqlCommandType.SELECT == type) {
            if (returnsVoid &&resultHandlerIndex != null) {
               executeWithResultHandler(args);
            } elseif (returnsList) {
               result = executeForList(args);
            } elseif (returnsMap) {
               result = executeForMap(args);
            } else {
               Object param = getParam(args);
               result = sqlSession.selectOne(commandName, param);
            }
        } else {
            thrownewBindingException("Unknown execution method for: " + commandName);
        }
        return result;
}  

可以看到, MapperMethod 就像是一个分发者,他根据参数和返回值类型选择不同的 sqlsession 方法来执行。这样 mapper 对象与 sqlsession 就真正的关联起来了

openSession()到底做了什么

从环境中获取事务的工厂,返回一个environment对象获取事务工厂

事务工厂创建事务

通过configuration拿到一个执行器传入事务(Transaction)和类型(execType(枚举))

最后返回一个DefaultSqlSession

openSession底层就是做各种成员变量的初始化

例如:configuration,executor,dirty(内存当中的数据与数据库中

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • 关于springboot中对sqlSessionFactoryBean的自定义

    目录 springboot sqlSessionFactoryBean自定义 代码如下 以上配置也可以通过properties文件配置 springboot启动报找不到sqlSessionFactory springboot sqlSessionFactoryBean自定义 1.新建一个配置类,加上configuration注解 2.定制化SqlSessionFactoryBean,然后交给容器管理 代码如下 @Configuration public class MybatisConfig {

  • Springboot 配置SqlSessionFactory方式

    目录 Springboot 配置SqlSessionFactory Springboot SqlSessionFactory错误 Springboot 配置SqlSessionFactory Spring官方提供了比较完善的数据库配置,但是某些情况下需要自己手动加载(如:配置多数据源) 以下是我搜集并整理出来的一个configuration,不足之处或错误请大家提出并指正 package cn.xt.config; import org.mybatis.spring.SqlSessionFact

  • mybatis初始化SqlSessionFactory失败的几个原因分析

    目录 mybatis初始化SqlSessionFactory失败 总结原因有几点 SqlSessionFactory异常 mybatis初始化SqlSessionFactory失败 总结原因有几点 1.resources中的xml配置文件放错位置或者是放的太深加载不到 比如 RoleDao因为放的比较包中包中所以扫描不到 2.xml文件里面有错文 比如mapper namespace的相对路径有问题 导致初始化错误 SqlSessionFactory异常 org.springframework.

  • MyBatis源码解析——获取SqlSessionFactory方式

    目录 MyBatis源码解析_获取SqlSessionFactory 首先从Resources.getResourceAsReader(path) 进入到SqlSessionFactoryBuilder.build(Reader)方法中 进入到mapperElement(XNode)方法后 如果子节点名字不是package 经过一系列的解析,终于完成了 用MyBatis的配置文件获取SqlSessionFactory MyBatis源码解析_获取SqlSessionFactory 我们都知道,在

  • 基于SqlSessionFactory的openSession方法使用

    目录 SqlSessionFactory的openSession方法 创建Sqlsession的地方只有一个 我们可以看到实际创建SqlSession的地方 Executor的创建 Mapper MapperProxy的invoke openSession()到底做了什么 SqlSessionFactory的openSession方法 正如其名,Sqlsession对应着一次数据库会话. 由于数据库回话不是永久的,因此Sqlsession的生命周期也不应该是永久的,相反,在你每次访问数据库时都需

  • 基于MyBatis XML配置方法(全面了解)

    MyBatis 的配置文件包含了影响 MyBatis 行为甚深的设置(settings)和属性(properties)信息. 文档的顶层结构如下: configuration 配置 properties 属性 settings 设置 typeAliases 类型命名 typeHandlers 类型处理器 objectFactory 对象工厂 plugins 插件 environments 环境 environment 环境变量 transactionManager 事务管理器 dataSourc

  • 基于Require.js使用方法(总结)

    一.为什么要使用require.js 首先一个页面如果在加载多个js文件的时候,浏览器会停止网页渲染,加载文件越多,网页失去响应的时间就会越长:其次,由于js文件之间存在依赖关系,因此必须严格保证加载顺序,当依赖关系很复杂的时候,代码的编写和维护都会变得困难. require.js,就是为了解决这两个问题: 1. 实现js文件的异步加载,避免网页失去响应: 2. 管理模块之间的依赖性,便于代码的编写和维护. 二.require.js的加载 第一步,去官网下载最新版本,直接放到页面进行加载 <sc

  • 基于JQuery的$.ajax方法进行异步请求导致页面闪烁的解决办法

    情景 目前有个需求是在文本框填入内容,自动触发keyup事件,下拉列表会自动过滤相应的选项,但是使用了$,ajax后发现,每次触发事件时,都导致整个网页闪烁,触发了全局ajax事件 代码片段 $.ajax({ type: "POST", url: root + "/xxx, data: requestData, dataType: "json", success: function(data){ // 清空列表 $("#formOpinion #

  • java实现基于SMTP发送邮件的方法

    本文实例讲述了java实现基于SMTP发送邮件的方法.分享给大家供大家参考.具体实现方法如下: import java.util.Date; import java.util.Properties; import javax.mail.Authenticator; import javax.mail.Message; import javax.mail.PasswordAuthentication; import javax.mail.Session; import javax.mail.Tra

  • 基于RestTemplate的使用方法(详解)

    1.postForObject :传入一个业务对象,返回是一个String 调用方: BaseUser baseUser=new BaseUser(); baseUser.setUserid(userid); baseUser.setPass(pass); String postForObject = restTemplate.postForObject(this.getURL()+"/user/login", baseUser, String.class); return postF

  • 基于python时间处理方法(详解)

    在处理数据和进行机器学习的时候,遇到了大量需要处理的时间序列.比如说:数据库读取的str和time的转化,还有time的差值计算.总结一下python的时间处理方面的内容. 一.字符串和时间序列的转化 time.strptime():字符串=>时间序列 time.strftime():时间序列=>字符串 import time start = "2017-01-01" end = "2017-8-12" startTime = time.strptime

  • 基于webpack 实用配置方法总结

    1.webpack.config.js配置文件为: //处理共用.通用的js var webpack = require('webpack'); //处理html模板 var htmlWebpackPlugin = require('html-webpack-plugin'); //css单独打包 var ExtractTextPlugin = require("extract-text-webpack-plugin"); // 获取html-webpack-plugin参数的方法 v

  • php实现基于pdo的事务处理方法示例

    本文实例讲述了php实现基于pdo的事务处理方法.分享给大家供大家参考,具体如下: 实例1: try {} catch () {} 形式 <?php $dsn = 'mysql:dbname=cheyun_cms;host=127.0.0.1'; $user = 'root'; $password = '111111'; //采用预处理+事务处理执行SQL操作 //1.连接数据库 try { $pdo = new PDO($dsn, $user, $password); $pdo->setAt

  • C#基于Extension Method(扩展方法)获得文件大小的方法

    本文实例讲述了C#基于Extension Method(扩展方法)获得文件大小的方法.分享给大家供大家参考.具体分析如下: 文件信息类的一个Extension Method,返回文件大小的格式化的版本. 比如:1 GB or 100 B and it at max it will have two decimals. 添加下面代码到同样的命名空间的公共静态类,创建新的FileInfo,调用GetFileSize. /// <summary> /// Gets a files formatted

随机推荐