Mybatis之获取Connection简析

注: Mybatis版本是3.5.0。java

    Mybatis的DefaultSqlSession是怎么从DataSource得到Connection的呢?数据库

    先来看下openSessionFromDataSource方法,由于DefaultSqlSession的实例化就是从这个方法中开始的,如List-1所示。session

    List-1 DefaultSqlSessionFactory的openSessionFromDataSource方法fetch

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

    以下List-2所示,实例化一个Transaction,传入的是个dataSource。这个tx是Executor的一个属性,而Executor又是DefautSqlSession的一个属性。code

    List-2 实例化一个Transactionblog

tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);

    List-2中获取的Transaction是一个JdbcTransaction,下面咱们来看经过DefaultSqlSession来查询数据库的时序图,get

                

                                               图1 使用SimpleExecutor时,查询的时序图it

    从图1能够看出,DefaultSqlSession直到查询时才会从DataSource中取出Connection,步骤5。有点相似Lazy initialization的思想。io

    一个SqlSession中,若是这个SqlSession含有了一个Connection,那么该SqlSession中后续对数据库的操做都使用这个Connection。class

相关文章
相关标签/搜索