[TOC]

我们使用sqlSession之前,需要去获取配置文件,获取InputStream输入流,通过SqlSessionFactoryBuilder获取sqlSessionFactory对象,从而获取sqlSession

InputStream is = Resources.getResourceAsStream("mybatis.xml");SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);SqlSession sqlSession = sqlSessionFactory.openSession();

1.Resources.getResourceAsStream("mybatis.xml")到底做了什么?

1.首先我们来看InputStream is = Resources.getResourceAsStream("mybatis.xml");这句话到底替我们干了什么,下面可以看出在里面调用了另一个内部方法,resource是全局配置的文件名:

public static InputStream getResourceAsStream(String resource) throws IOException {    // 从这里字面意思是传一个空的类加载器进去,还有全局配置文件名,从方法名的意思就是    // 将配置文件读取,转化成输入流    return getResourceAsStream((ClassLoader)null, resource);  }

2.跟进方法中,我们可以知道在里面调用ClassLoaderWrapper类的一个实例对象的getResourceAsStream()方法,这个classLoaderWrapper怎么来的呢?这个是Resources.class的一个成员属性,那么这个ClassLoaderWrapper是什么东西呢?

Resources.class中我们只是使用private static ClassLoaderWrapper classLoaderWrapper = new ClassLoaderWrapper();创建一个classLoaderWrapper对象。
ClassLoaderWrapper其实是一个ClassLoader(类加载器)的包装类,其中包含了几个ClassLoader对象,一个defaultClassLoader,一个systemClassLoader,通过内部控制,可以确保返回正确的类加载器给系统使用。我们可以当成一个mybatis自定义过的类加载器。

public static InputStream getResourceAsStream(ClassLoader loader, String resource) throws IOException {    InputStream in = classLoaderWrapper.getResourceAsStream(resource, loader);    if (in == null) {      throw new IOException("Could not find resource " + resource);    } else {      return in;    }  }

3.我们可以看出调用了下面这个内部方法,里面调用了封装的方法,一个是获取当前的类加载器,另一个是传进来的文件名:

  public InputStream getResourceAsStream(String resource, ClassLoader classLoader) {    return this.getResourceAsStream(resource, this.getClassLoaders(classLoader));  }

4.查看getClassLoaders()这个方法,可以看到里面初始化了一个类加载器的数组,里面有很多个类加载器,包括默认的类加载器,当前线程的上下文类加载器,系统类加载器等。

ClassLoader[] getClassLoaders(ClassLoader classLoader) {    return new ClassLoader[]{classLoader, this.defaultClassLoader, Thread.currentThread().getContextClassLoader(), this.getClass().getClassLoader(), this.systemClassLoader};  }

5.进入getResourceAsStream(String resource, ClassLoader[] classLoader)这个方法内部,我们可以看到里面遍历所有的类加载器,使用类加载器来加载获取InputStream对象,我们可以知道里面是选择第一个适合的类加载器,如果我们不传类加载器进去,那么第一个自己定义的类加载器就是null,那么就会默认选择第二个默认类加载器,而且我们可以知道如果文件名前面没有加“/”,获取到空对象的话,会自动加上“/”再访问一遍:

 InputStream getResourceAsStream(String resource, ClassLoader[] classLoader) {    ClassLoader[] arr$ = classLoader;    int len$ = classLoader.length;    for(int i$ = 0; i$ < len$; ++i$) {      ClassLoader cl = arr$[i$];      if (null != cl) {        InputStream returnValue = cl.getResourceAsStream(resource);        if (null == returnValue) {          returnValue = cl.getResourceAsStream("/" + resource);        }        if (null != returnValue) {          return returnValue;        }      }    }    return null;  }

6.我们进入类加载器加载资源文件的代码中,我们可以看到首先获取全路径的url,然后再调用openStream()

public InputStream getResourceAsStream(String name) {    URL url = getResource(name);    try {        return url != null ? url.openStream() : null;    } catch (IOException e) {        return null;    }}

6.1.我们跟进getResource(name)这个方法,我们可以看到里面都是调用parentgetResource()方法,如果已经是父加载器,那么就使用getBootstrapResource(name)获取,如果获取出来是空的,再根据getBootstrapResource(name)方法获取。

public URL getResource(String name) {        URL url;        if (parent != null) {            url = parent.getResource(name);        } else {            url = getBootstrapResource(name);        }        if (url == null) {            url = findResource(name);        }        return url;    }

6.1.1我们跟进去getBootstrapResource(name);

private static URL getBootstrapResource(String name) {        URLClassPath ucp = getBootstrapClassPath();        Resource res = ucp.getResource(name);        return res != null ? res.getURL() : null;    }

6.1.1.1我们看到getBootstrapClassPath()这个方法,这个方法的里面调用了引入的包,读取的是类加载器的加载路径,这个方法到此为止,再深入就回不去了:)。

static URLClassPath getBootstrapClassPath() {        return sun.misc.Launcher.getBootstrapClassPath();    }

6.1.1.2 我们看ucp.getResource(name)这个方法,我们可以看到在里面调用了这个方法,这个方法主要是查找缓存,然后遍历找到第一个符合条件的加载器来获取resource,到此我们不再深究下去,得往上一层回头看:

public Resource getResource(String var1, boolean var2) {    if (DEBUG) {      System.err.println("URLClassPath.getResource(\"" + var1 + "\")");    }    int[] var4 = this.getLookupCache(var1);    URLClassPath.Loader var3;    for(int var5 = 0; (var3 = this.getNextLoader(var4, var5)) != null; ++var5) {      Resource var6 = var3.getResource(var1, var2);      if (var6 != null) {        return var6;      }    }    return null;  }

我们知道getBootstrapResource(name)里面主要是url(文件资源的路径),然后使用url.openStream()去获取stream流:

public final InputStream openStream() throws java.io.IOException {        return openConnection().getInputStream();    }

我们来看openConnection()方法,里面调用的是一个抽象方法,获取的是一个URLConnection(url连接对象):

public URLConnection openConnection() throws java.io.IOException {        return handler.openConnection(this);    }

再看getInputStream()这个方法,我们可以看到这是一个接口方法,我们找到FileURLConnection的这个方法,这是一个单线程处理文件URL的inputstream的方法:

  public synchronized InputStream getInputStream() throws IOException {    this.connect();    if (this.is == null) {      if (!this.isDirectory) {        throw new FileNotFoundException(this.filename);      }      FileNameMap var3 = java.net.URLConnection.getFileNameMap();      StringBuffer var4 = new StringBuffer();      if (this.files == null) {        throw new FileNotFoundException(this.filename);      }      Collections.sort(this.files, Collator.getInstance());      for(int var5 = 0; var5 < this.files.size(); ++var5) {        String var6 = (String)this.files.get(var5);        var4.append(var6);        var4.append("\n");      }      this.is = new ByteArrayInputStream(var4.toString().getBytes());    }    return this.is;  }

到这里,整个获取inputstream的过程已经结束,只要把返回值往上一层返回就可以得到这个配置文件所需要的inputstream。

2. new SqlSessionFactoryBuilder().build(is)的运行原理

首先SqlSessionFactoryBuilder的无参数构造方法是没有任何操作的:

public SqlSessionFactoryBuilder() {  }

那么我们看build(is)这个方法,里面调用了一个封装方法,一个是inputstream,一个是string,一个是属性对象:

public SqlSessionFactory build(InputStream inputStream) {    return this.build((InputStream)inputStream, (String)null, (Properties)null);  }

跟进去,我们可以看到在里面使用了xmlconfigbuilder,也就是xml配置构造器,实例化一个xml配置对象,可想而知,也就是我们的mybatis.xml所对应的配置对象构造器,在里面调用了另一个build()方法:

  public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {    SqlSessionFactory var5;    try {      XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);      var5 = this.build(parser.parse());    } catch (Exception var14) {      throw ExceptionFactory.wrapException("Error building SqlSession.", var14);    } finally {      ErrorContext.instance().reset();      try {        inputStream.close();      } catch (IOException var13) {        ;      }    }    return var5;  }

我们可以看到调用的另一个build方法,也就是使用配置对象构建一个DefaultSqlSessionFactory对象,在上面返回这个对象,也就是我们的sqlsessionFactory。

  public SqlSessionFactory build(Configuration config) {    return new DefaultSqlSessionFactory(config);  }

3. sqlSessionFactory.openSession()获取sqlSession

我们可以看到其实这个是sqlSessionFactory的一个接口,其实现类是DefaultSqlSessionFactory,那么方法如下:

  public SqlSession openSession() {    return this.openSessionFromDataSource(this.configuration.getDefaultExecutorType(), (TransactionIsolationLevel)null, false);  }

我们查看openSessionFromDataSource()这个方法,从名字可以大概知道是从数据源加载Sqlsession,里面可以指定执行器类型,事物隔离级别,还有是否自动提交,如果不设定,那么默认是null以及false,在方法内主要做的是将配置文件对象的环境取出来构造事务工厂,配置执行器等,返回一个DefaultSqlSession的实例。

  private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {    Transaction tx = null;    DefaultSqlSession 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);      var8 = 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;  }

到此为止,一个sqlsession对象就根据配置文件创建出来了。

此文章仅代表自己(本菜鸟)学习积累记录,或者学习笔记,如有侵权,请联系作者删除。人无完人,文章也一样,文笔稚嫩,在下不才,勿喷,如果有错误之处,还望指出,感激不尽~

技术之路不在一时,山高水长,纵使缓慢,驰而不息。
公众号:秦怀杂货店

©著作权归作者所有:来自51CTO博客作者秦怀杂货店的原创作品,如需转载,请注明出处,否则将追究法律责任

每一份赞赏源于懂得

赞赏

0人进行了赞赏支持

更多相关文章

  1. MySQL修改root密码的多种方法+给远程登录赋权
  2. chrome查看网站字符集编码的方法(不需要安装charset)
  3. 问题排查 | 客户端突如其来的“白屏”等待
  4. Eclipse导入MyEclipse项目时,无法识别为web项目的解决方法
  5. Linux下查看进程线程数的方法
  6. 架构师和老运维必懂的 Nginx 的热部署、热加载、平滑升级!
  7. Apple M1芯片软件安装异常的解决方法
  8. 图片上传
  9. 【每天一题】PHP中常用的数组操作方法笔记整理

随机推荐

  1. Python网络编程:E-mail服务(三)MIME解析
  2. win10 x64 python3.6 pycharm 安装statsm
  3. 通过Excel / VBA运行Python脚本
  4. 高级程序员装逼指南
  5. 学习python的第二十一天
  6. Python廖雪峰实战web开发(day4-编写Model)
  7. python之内存概念
  8. python笔记7:接口实现方法
  9. 见证历史!Python或将取代VBA,成为Excel官方
  10. django的视图和URL配置