欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

MyBatis源码解析系列(三)--从诞下SqlSession说起

程序员文章站 2022-04-15 10:49:25
...

上一篇MyBatis源码解析系列中,我们说完了SqlSessionFactory的诞生过程。这一篇中,我们要根据SqlSessionFactory工厂去得到SqlSession。那么,在这个过程中,究竟做了些什么?我们一一去解读。

一、SqlSession怎么来的

SqlSession是一个接口类,继承了Closeable(只有一个从AutoCloseable接口类继承来的方法close)。在SqlSession接口类中,提供了各种查询、删除、更新、提交、回滚等等方法。我们看类图:

MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
 

 既然是个接口类,那么总要有实现类去做这些事情,才能显示出接口类的价值。那么SqlSession是怎么来的?实现类是谁?

在篇二中,我们得到了SqlSessionFactory,它的默认实现类是DefaultSqlSessionFactory,既然是工厂实现类,那么DefaultSqlSessionFactory这里就是生产SqlSession的工厂车间。从这里,我们就可以找到SqlSession的来源。我们去看看。

MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
 从类图中我们可以看到,DefaultSqlSessionFactory提供了很多openSession方法,返回的对象类型就是SqlSession。

我们看下源码,源码中分为两种方式生产SqlSession,一种是使用方法private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit),一种是使用重载的private SqlSession openSessionFromConnection(ExecutorType execType, Connection connection)。

 

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

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

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

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

    public SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level) {
        return this.openSessionFromDataSource(execType, level, false);
    }

    public SqlSession openSession(ExecutorType execType, boolean autoCommit) {
        return this.openSessionFromDataSource(execType, (TransactionIsolationLevel)null, autoCommit);
    }

    public SqlSession openSession(Connection connection) {
        return this.openSessionFromConnection(this.configuration.getDefaultExecutorType(), connection);
    }

    public SqlSession openSession(ExecutorType execType, Connection connection) {
        return this.openSessionFromConnection(execType, connection);
    }

 那我们就分开来看下这两方法。

 

1、private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit):

源码如下:

 

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;
    }

 我们一行行来解释。结合我们的debug过程。

 

①在Environment environment = this.configuration.getEnvironment();中,根据我们在得到SqlSessionFactory过程中设置的对象configuration来获取在解析<element>元素时候设置的环境信息environment,设置后的信息如下:

MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
 

 

②在TransactionFactory transactionFactory = this.getTransactionFactoryFromEnvironment(environment);中,根据environment环境信息去获取environment对象中的TransactionFactory,这里是JdbcTransactionFactory,源码如下:

private TransactionFactory getTransactionFactoryFromEnvironment(Environment environment) {
        return (TransactionFactory)(environment != null && environment.getTransactionFactory() != null ? environment.getTransactionFactory() : new ManagedTransactionFactory());
    }

 ③在tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);中,使用transactionFactory工厂类去获取Transaction,这里传了三个参数,一是environment的数据源信息,一个是隔离级别,一个是是否自动提交的标识。我们看下这个newTransaction---构造Transaction的方法源码,这个方法的实现在JdbcTransactionFactory类中:

 

 

public Transaction newTransaction(DataSource ds, TransactionIsolationLevel level, boolean autoCommit) {
        return new JdbcTransaction(ds, level, autoCommit);
    }

 这里又使用了JdbcTransaction类的构造函数:

 

 

public JdbcTransaction(DataSource ds, TransactionIsolationLevel desiredLevel, boolean desiredAutoCommit) {
        this.dataSource = ds;
        this.level = desiredLevel;
        this.autoCommmit = desiredAutoCommit;
    }

 

这样,获取到的Transaction就是JdbcTransaction。设置的信息如下,来个图看的更明白些:

MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
 

④在 Executor executor = this.configuration.newExecutor(tx, execType);中,使用Transaction和execType来获取执行器,那这里的execType是啥玩意?这个就是在解析核心配置文件的<setting>标签时(方法在XMLConfigBuilder类中的settingsElement解析方法中),如<setting name="defaultExecutorType" value="SIMPLE"/>,会设置在configuration对象中,不同的execType标识不同的含义。它的取值有三个(SIMPLE, REUSE ,BATCH),含义分别如下:

SIMPLE 就是普通的执行器;REUSE 执行器会重用预处理语句(prepared statements); BATCH 执行器将重用语句并执行批量更新。不设置时候默认使用SIMPLE,就是普通的执行器。我们这里使用的默认。

newExecutor方法源码如下:

 

public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
        executorType = executorType == null ? this.defaultExecutorType : executorType;
        executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
        Object 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 (this.cacheEnabled) {
            executor = new CachingExecutor((Executor)executor);
        }

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

 那我们这里得到的Executor经过判断就是SimpleExecutor了。

 

⑤在 var8 = new DefaultSqlSession(this.configuration, executor, autoCommit);中,我们要去获取SqlSession的实现类了DefaultSqlSession,终于到了最后。源码如下:

 

public DefaultSqlSession(Configuration configuration, Executor executor, boolean autoCommit) {
        this.configuration = configuration;
        this.executor = executor;
        this.dirty = false;
        this.autoCommit = autoCommit;
    }

这样,SqlSession的实现类DefaultSqlSession就拥有了配置对象信息,拥有了执行器信息,那么它就知道怎么去处理sql语句了。看看,这个configuration对象贯穿始终,核心的核心,源码是不会骗人的。

 

2、在private SqlSession openSessionFromConnection(ExecutorType execType, Connection connection)方法中,它的源码如下:

private SqlSession openSessionFromConnection(ExecutorType execType, Connection connection) {
        DefaultSqlSession var8;
        try {
            boolean autoCommit;
            try {
                autoCommit = connection.getAutoCommit();
            } catch (SQLException var13) {
                autoCommit = true;
            }

            Environment environment = this.configuration.getEnvironment();
            TransactionFactory transactionFactory = this.getTransactionFactoryFromEnvironment(environment);
            Transaction tx = transactionFactory.newTransaction(connection);
            Executor executor = this.configuration.newExecutor(tx, execType);
            var8 = new DefaultSqlSession(this.configuration, executor, autoCommit);
        } catch (Exception var14) {
            throw ExceptionFactory.wrapException("Error opening session.  Cause: " + var14, var14);
        } finally {
            ErrorContext.instance().reset();
        }

        return var8;
    }

 与上一个方法唯一的不同点在于,它传递了Connection 类的对象,这个对象用来获取autoCommit属性的值,其他跟上一个方法一模一样,我们不再赘述。

 

二、综上所述

上面就是获取SqlSession的所有步骤,是不是很简单?这就是源码,理解了原理,以后谁问也不怕。

下一帖,我们就要通过SqlSession去执行getMapper方法了,很期待。

 

 

 

 

 

 

 

 

 

  • MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
  • 大小: 35.9 KB
  • MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
  • 大小: 23.7 KB
  • MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
  • 大小: 27.1 KB
  • MyBatis源码解析系列(三)--从诞下SqlSession说起
            
    
    博客分类: Mybatis Mybatis源码SqlSessionFactorySqlSession 
  • 大小: 11.8 KB