关于mybaitis

mybatis启动流程

1、首先来看看最简单的mybatis项目启动过程

public static void mybatisTest() throws IOException {
    String resource = "mybatis/mybatis-config.xml";
    //配置文件
    InputStream inputStream = Resources.getResourceAsStream(resource);
    //SqlSessionFactory
    SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    SqlSession sqlSession = null;
    try {
        //开启一个session
        sqlSession = sqlSessionFactory.openSession();
        //获取mapper
        JobConfigDao jobConfigDao = sqlSession.getMapper(JobConfigDao.class);
        //查询数据
        List<JobConfig> jobConfigList = jobConfigDao.listConfig();
        System.out.println(jobConfigList);
    } finally {
        if (sqlSession != null)
            sqlSession.close();
    }
}

这个过程主要是SqlSessionFactory 的创建，先获取配置信息，然后通过SqlSessionFactoryBuilder来创建SqlSessionFactory 。
build方法的核心代码是：

XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties); 
var5 = this.build(parser.parse());

可以看到mybatis是通过XMLConfigBuilder来解析配置文件的。来看看XMLConfigBuilder的parse方法：

public Configuration parse() {
    //XMLConfigBuilder中有一个boolean类型parsed，来标记是否解析过配置文件，解析过之后就设置为true，防止同样的配置被重复解析
    if (this.parsed) {
        throw new BuilderException("Each XMLConfigBuilder can only be used once.");
    } else {
        this.parsed = true;
        // 解析configuration节点下的配置
        this.parseConfiguration(this.parser.evalNode("/configuration"));
        return this.configuration;
    }
}

private void parseConfiguration(XNode root) {
    try {
        this.propertiesElement(root.evalNode("properties"));
        Properties settings = this.settingsAsProperties(root.evalNode("settings"));
        this.loadCustomVfs(settings);
        this.typeAliasesElement(root.evalNode("typeAliases"));
        this.pluginElement(root.evalNode("plugins"));
        this.objectFactoryElement(root.evalNode("objectFactory"));
        this.objectWrapperFactoryElement(root.evalNode("objectWrapperFactory"));
        this.reflectorFactoryElement(root.evalNode("reflectorFactory"));
        this.settingsElement(settings);
        this.environmentsElement(root.evalNode("environments"));
        this.databaseIdProviderElement(root.evalNode("databaseIdProvider"));
        this.typeHandlerElement(root.evalNode("typeHandlers"));
        // 解析mapper
        this.mapperElement(root.evalNode("mappers"));
    } catch (Exception var3) {
        throw new BuilderException("Error parsing SQL Mapper Configuration. Cause: " + var3, var3);
    }
}

可以看到，在parseConfiguration方法中会将mybatis-config.xml配置下的各种属性获取出来一一解析，并映射到相关的属性上面去。

mybatis定义的接口，怎么找到实现的？

通过上面的启动过程，已经知道mybatis是通过XMLConfigBuilder来解析配置文件的，具体解析是在parseConfiguration方法的中，获取到mappers配置节点，最后一行this.mapperElement(root.evalNode("mappers"))将节点信息转交给XMLMapperBuilder来完成对mapper的解析。

来看看XMLMapperBuilder的parse方法：

public void parse() {
    if (!this.configuration.isResourceLoaded(this.resource)) {
        this.configurationElement(this.parser.evalNode("/mapper"));
        this.configuration.addLoadedResource(this.resource);
        //通过命名空间绑定mapper
        this.bindMapperForNamespace();
    }

    this.parsePendingResultMaps();
    this.parsePendingCacheRefs();
    this.parsePendingStatements();
}

因为这里的重点是想知道定义的接口是怎么实现的，所以直接来看看bindMapperForNamespace方法对如何来实现mapper的绑定：

private void bindMapperForNamespace() {
    String namespace = this.builderAssistant.getCurrentNamespace();
    if (namespace != null) {
        Class boundType = null;

        try {
            //通过反射获取类类型
            boundType = Resources.classForName(namespace);
        } catch (ClassNotFoundException var4) {
            ;
        }

        //如果当前类还没有绑定到配置的缓存中
        if (boundType != null && !this.configuration.hasMapper(boundType)) {
            this.configuration.addLoadedResource("namespace:" + namespace);
            //通过mybatis的Configuration将mapper注册到MapperRegistry
            this.configuration.addMapper(boundType);
        }
    }
}

来看看MapperRegistry 的addMapper：

public <T> void addMapper(Class<T> type) {
    this.mapperRegistry.addMapper(type);
}

public <T> void addMapper(Class<T> type) {
    if (type.isInterface()) {//先判断是否为接口
        if (this.hasMapper(type)) {//如果已经注册，抛出异常
            throw new BindingException("Type " + type + " is already known to the MapperRegistry.");
        }
        boolean loadCompleted = false;
        try {
            //创建一个代理MapperProxyFactory 并将该mapper缓存到内存的Map中去
            this.knownMappers.put(type, new MapperProxyFactory(type));
            //绑定注解
            MapperAnnotationBuilder parser = new MapperAnnotationBuilder(this.config, type);
            parser.parse();
            loadCompleted = true;
        } finally {
            if (!loadCompleted) {
                this.knownMappers.remove(type);
            }

        }
    }
}

通过对上面源码的跟踪分析，终于知道，mybatis通过MapperProxyFactory为每个接口都提供了一个代理实现，然后通过MapperRegistry将mapper注册到容器中的。

那么在使用的时候又是如何来获取这个mapper的呢？

答案是：反射加上代理

首先通过SqlSession的getMapper方法，mybatis为SqlSession提供了一个默认的实现DefaultSqlSession，DefaultSqlSession的内部属性如下：

//Configuration配置
private final Configuration configuration;
private final Executor executor;
private final boolean autoCommit;
private boolean dirty;
private List<Cursor<?>> cursorList;

DefaultSqlSession获取配置，然后配置中获取MapperRegistry，从MapperRegistry中获取到mapper代理工厂，再通过MapperProxyFactory的newInstance来创建mapper代理类MapperProxy

总结：对于Mybatis，记住几个关键的处理类：SqlSessionFactoryBuilder创建SqlSessionFactory，SqlSessionFactory中开启一个SqlSession，通过sqlSession来执行用户操作；RegisterMapper将mapper注册到容器中，通过MapperProxyFactory来创建mapper代理，mapper代理最终是通过jdk反射包中Proxy代理类来创建的。

启动时创建的SqlSessionFactory是DefaultSqlSessionFactory，DefaultSqlSessionFactory中拥有属性Configuration，Configuration是通过XMLConfigBuilder从配置文件中解析出来的各种配置信息，Configuration中有MapperRegistry，MapperRegistry中用一个final类型的Map存储了用户定义Mapper代理实现工厂MapperProxyFactory，Mapper代理实现是MapperProxy。