首页
学习
活动
专区
圈层
工具
发布

Mybatis之获取Connection简析 原

注: Mybatis版本是3.5.0。

    Mybatis的DefaultSqlSession是怎么从DataSource获得Connection的呢?

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

List-1 DefaultSqlSessionFactory的openSessionFromDataSource方法

代码语言:javascript
复制
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的一个属性。

List-2 实例化一个Transaction

代码语言:javascript
复制
tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);

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

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

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

    一个SqlSession中,如果这个SqlSession含有了一个Connection,那么该SqlSession中后续对数据库的操作都使用这个Connection。

(adsbygoogle = window.adsbygoogle || []).push({});

下一篇
举报
领券