mybatis小结四

Posted 2021-04-16 名人堂之路

对mybatis初始化SessionFactory过程做一个小结

1.调用 SqlSessionFactoryBuilder 对象的 build(inputStream) 方法；
2.SqlSessionFactoryBuilder 会根据输入流 inputStream 等信息创建XMLConfigBuilder 对象 ;
3.SqlSessionFactoryBuilder 调用 XMLConfigBuilder 对象的 parse() 方法；
4.XMLConfigBuilder 对象返回 Configuration 对象；
5.SqlSessionFactoryBuilder 根据 Configuration 对象创建一个DefaultSessionFactory 对象；
6.SqlSessionFactoryBuilder 返回 DefaultSessionFactory 对象给 Client ，供 Client使用。

结合上面的过程可以很清晰的理解下面的源码的内容。

sessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);
//build对应的源码
public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {
    SqlSessionFactory var5;
    try {
        XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
//这部分主要进行xml文件的解析
        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;
}
//this.build对应的源码
public SqlSessionFactory build(Configuration config) {
    return new DefaultSqlSessionFactory(config);
}
//获取session
public static SqlSession getSession(){
    //默认自动提交
    return sessionFactory.openSession();
}
//openSession()对应的源码
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;
}