文档章节

mybatis源码跟踪 - openSession

_Code_Monkey_
 _Code_Monkey_
发布于 2017/05/10 17:44
字数 997
阅读 16
收藏 0

接上文: mybatis - 初始化

接上文,既然拿到了SqlSessionFactory,下一步就是在方法中用来获取SqlSession了:

// 获取SqlSession,线程不可全
        SqlSession sqlSession = initAndReturnSqlSessionFactory().openSession();
// 通过SqlSession获取Mapper
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);

那么就看看这个关键的openSession()方法,上文已知SqlSessionFactory的唯一默认实现是DefaultSqlSessionFactory,那么,就看看 这个过程中做了些什么,用代码加注释说话:

@Override
  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);
      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();
    }
  }

创建执行器:

public Executor newExecutor(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);
    } else if (ExecutorType.REUSE == executorType) {
      executor = new ReuseExecutor(this, transaction);
    } else {
      executor = new SimpleExecutor(this, transaction);
    }
    if (cacheEnabled) {
      executor = new CachingExecutor(executor);
    }
    executor = (Executor) interceptorChain.pluginAll(executor);
    return executor;
  }

加入代理链(这个设计很good,逻辑有点绕,我这简单的头脑需要花些时间才明白做了些什么): 实际,每个代理对象都代理着前一个代理对象,前一个代理对象做为target加入到新的代理实现中

// 依次创建代理对象,返回一个包含前一个代理对象的代理对象,这样把target和所以拦截器串起来一个调用链
public Object pluginAll(Object target) {
    for (Interceptor interceptor : interceptors) {
      target = interceptor.plugin(target);
    }
    return target;
  }

重新梳理下:

<p> 创建 </p>

// 传入上一个代理对象,生成并返回新的代理对象
@Override
    public Object plugin(Object target) {
        return Plugin.wrap(target, this);
    }

插件包装方法


public static Object wrap(Object target, Interceptor interceptor) {
    // 要拦截的类与其方法的映射集合
    Map<Class<?>, Set<Method>> signatureMap = getSignatureMap(interceptor);
    // 拦截器的类型
    Class<?> type = target.getClass();
    // 该拦截器实现的所有接口
    Class<?>[] interfaces = getAllInterfaces(type, signatureMap);
    // 生成代理对象,原有的对象target将被做为旧的实现被新的代理对象调用
    if (interfaces.length > 0) {
      return Proxy.newProxyInstance(
          type.getClassLoader(),
          interfaces,
          new Plugin(target, interceptor, signatureMap));
    }
    return target;
  }
/**
 * 这个方法解析拦截器的注解,生成要拦截的类与其方法的映射集合
 */
private static Map<Class<?>, Set<Method>> getSignatureMap(Interceptor interceptor) {
    // 获取拦截器的@Intercepts注解
    Intercepts interceptsAnnotation = interceptor.getClass().getAnnotation(Intercepts.class);
    // issue #251
    if (interceptsAnnotation == null) {
      throw new PluginException("No @Intercepts annotation was found in interceptor " + interceptor.getClass().getName());      
    }
    // 注解的value,返回Signature(签名)数组
    Signature[] sigs = interceptsAnnotation.value();

    // 定义类及方法集合的映射表
    Map<Class<?>, Set<Method>> signatureMap = new HashMap<Class<?>, Set<Method>>();
    for (Signature sig : sigs) {
       // 先从映射表中获取方法集合,以类为Key, 若为空则填充
      Set<Method> methods = signatureMap.get(sig.type());
      if (methods == null) {
        methods = new HashSet<Method>();
        signatureMap.put(sig.type(), methods);
      }
      try {
        // 反射包中的方法,从Class对象中获取Method对象,传入方法名和参数类型
        Method method = sig.type().getMethod(sig.method(), sig.args());
        // 添加到方法集合中(方法集合已加入到映射表)
        methods.add(method);
      } catch (NoSuchMethodException e) {
        throw new PluginException("Could not find method on " + sig.type() + " named " + sig.method() + ". Cause: " + e, e);
      }
    }
    return signatureMap;
  }
// 对type及期层层遍历所有接口,如果有包含在拦截列表中的,就加入到接口列表最后返回,返回的是该类型所实现的所有被拦截的接口(特么的不就是找Interceptor接口吗?哦,其实还有Executor、ResultHandler、ParameterHandler、StatementHandler,这些都创建时都调用了InterceptorChain的pluginAll方法)
private static Class<?>[] getAllInterfaces(Class<?> type, Map<Class<?>, Set<Method>> signatureMap) {
    Set<Class<?>> interfaces = new HashSet<Class<?>>();
    while (type != null) {
      for (Class<?> c : type.getInterfaces()) {
        if (signatureMap.containsKey(c)) {
          interfaces.add(c);
        }
      }
      type = type.getSuperclass();
    }
    return interfaces.toArray(new Class<?>[interfaces.size()]);
  }

呼,好多,总结下:

  • 用TransactionFactory 创建一个Transaction ;
  • 创建一个执行器Executor;
  • 创建一个默认的SqlSession: new DefaultSqlSession(configuration, executor, autoCommit);

创建 执行器的过程中又发生了神马:

  • 确认执行器类型;
  • 按类型new一个相应的执行器实现,传入事务对象;
  • 判断是否开启缓存(),如果开启,使用刚创建的执行器再创建一个缓存执行器;
  • 最后,调用interceptorChain.pluginAll(executor)生成新的执行器代理实现,该实现层层代理了所有拦截器;

© 著作权归作者所有

_Code_Monkey_
粉丝 1
博文 20
码字总数 23642
作品 0
昌平
程序员
私信 提问
mybatis源码(1) -- 如何在Spring中驰骋的

mybatis作为持久层流行框架已经被很多产品使用,当然为了接入Spring这个业内的另一个流行框架,mybatis还是做了些事,通过分析除了明白支持Spring的机制原理还了解Spring对持久层接入留了那些...

alexqdjay
2016/10/10
132
0
MyBatis源码解读之SqlSession

目的 通过源码分析SqlSession功能实现、如何创建以及在Spring中是如何集成的。 2. SqlSession 功能介绍 MyBatis工作的主要Java接口,通过这些接口你可以执行命令,获取mapper和管理事务 --代...

无忌
2018/03/08
0
0
【深入浅出MyBatis系列一】MyBatis入门

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

陶邦仁
2015/12/22
4.1K
0
SSM框架之MyBatis3专题1:MyBatis入门

1 框架 百度百科介绍:框架(Framework)是整个或者部分系统的可重用设计,表现为一组抽象构件以及构件实例间交互的方法;另一种定义认为,框架是可被应用功能开发者制定的应用骨架。可以说,...

糖醋白糖
2018/06/26
0
0
Mybatis配置insert时,插入数据失败

错误代码如下: @Test public void testInsertOne(){ SqlSession sqlSession = MyBatisUtils.getSession(); UserInfo userInfo = new UserInfo(); userInfo.setNickname("sunny"); userInfo.s......

sun2shadows
2018/06/26
0
0

没有更多内容

加载失败,请刷新页面

加载更多

android6.0源码分析之Camera API2.0下的Preview(预览)流程分析

本文将基于android6.0的源码,对Camera API2.0下Camera的preview的流程进行分析。在文章android6.0源码分析之Camera API2.0下的初始化流程分析中,已经对Camera2内置应用的Open即初始化流程进...

天王盖地虎626
6分钟前
0
0
java 序列化和反序列化

1. 概述 序列恢复为Java对象的过程。 对象的序列化主要有两 首先我们介绍下序列化和反序列化的概念: 序列化:把Java对象转换为字节序列的过程。 反序列化:把字节序列恢复为Java对象的过程。...

edison_kwok
18分钟前
0
0
分布式数据一致性

狼王黄师傅
59分钟前
1
0
经验

相信每位开发者在自己开发的过程中,都会反思一些问题,比如怎样提高编程能力、如何保持心态不砍产品经理、996 之后怎样恢复精力……最近开发者 Tomasz Łakomy 将他 7 年的开发生涯中学习到...

WinkJie
今天
4
0
从源码的角度来看SpringMVC

SpringMVC核心流程图 简单总结 首先请求进入DispatcherServlet 由DispatcherServlet 从HandlerMappings中提取对应的Handler 此时只是获取到了对应的Handle,然后得去寻找对应的适配器,即:H...

骚年锦时
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部