MyBatis源码阅读(四) --- SqlSession的创建过程

终有救赎

发布于 2023-12-26 09:21:22

21000

代码可运行

文章被收录于专栏：多线程多线程

运行总次数：0

代码可运行

一、概述

前面一篇文章我们详细分析了SqlSessionFactory的创建过程，既然SqlSessionFactory有了，那么我们就可以通过sqlSessionFactory.openSession()来开启一个会话了，进而实现对数据库的操作，那么sqlSessionFactory.openSession()到底干了哪些事情呢？本篇文章就来详细了解一下。

SqlSession是Mybatis的高级接口，类似于JDBC操作的connection对象，它包装了数据库连接，通过这个接口我们可以实现增删改查，提交/回滚事务，关闭连接，获取代理类等操作。SqlSession是线程不安全的，每个线程都会有自己唯一的SqlSession，不同线程间调用同一个SqlSession会出现问题，因此在使用完后需要及时关闭。

SqlSession是个接口，其默认实现是DefaultSqlSession，另外一个子类是SqlSessionManager。

以下是SqlSession常见的方法：

public interface SqlSession extends Closeable {
 
  /**
  * 查询一个结果对象
  **/ 
  <T> T selectOne(String statement, Object parameter);
  
   /**
  * 查询一个结果集合
  **/ 
  <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds);
  
   /**
  * 查询一个map
  **/ 
  <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds);
 
   /**
  * 查询游标
  **/ 
  <T> Cursor<T> selectCursor(String statement, Object parameter, RowBounds rowBounds);
 
  void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler);
  
     /**
  * 插入
  **/ 
  int insert(String statement, Object parameter);
 
    /**
  * 修改
  **/ 
  int update(String statement, Object parameter);
 
  /**
  * 删除
  **/
  int delete(String statement, Object parameter);
 
   /**
  * 提交事物
  **/
  void commit(boolean force);
  
   /**
  * 回滚事物
  **/
  void rollback(boolean force);
 
  List<BatchResult> flushStatements();
 
  void close();
 
  void clearCache();
 
  Configuration getConfiguration();
 
   /**
  * 获取映射代理类
  **/
  <T> T getMapper(Class<T> type);
 
   /**
  * 获取数据库连接
  **/
  Connection getConnection();
}

可以看到，SqlSession可以实现增删改查，提交/回滚事务，关闭连接，获取代理类等操作，下面就来看下SqlSession详细的创建过程。

二、SqlSession的创建过程

SqlSession sqlSession = sqlSessionFactory.openSession()

通过sqlSessionFactory的openSession()开启一个会话。

DefaultSqlSessionFactory中有两种创建会话的方式：

openSessionFromDataSource：从数据源中获取SqlSession对象，SqlSession实际是对数据库连接的一层包装，数据库连接是个珍贵的资源，如果频繁的创建销毁将会影响吞吐量，这种方式就是从数据库连接池中获取一个连接，然后包装成一个SqlSession。
openSessionFromConnection：由已有连接获取SqlSession对象。

//默认使用的是DefaultSqlSessionFactory
//org.apache.ibatis.session.defaults.DefaultSqlSessionFactory#openSession()
@Override
public SqlSession openSession() {
  //configuration中有默认执行器类型，是SIMPLE简单类型执行器(SimpleExecutor)
  //从数据库连接池中获取一个连接，然后包装成一个SqlSession对像
  //可以复用数据库连接
  return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
}

这里我们以openSessionFromDataSource为例：从数据源连接池获取一个SqlSession会话

//org.apache.ibatis.session.defaults.DefaultSqlSessionFactory#openSessionFromDataSource
private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
  //事务对象
  Transaction tx = null;
  try {
    //从configuration对象中获取到我们之前解析的environment环境信息
    final Environment environment = configuration.getEnvironment();
    //事务工厂，这里是JbdcTransactionFactory工厂类
    final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
    //通过事务工厂创建JbdcTransaction事务，传入数据源等信息
    tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
    //创建Executor执行器
    final Executor executor = configuration.newExecutor(tx, execType);
    //创建DefaultSqlSession会话，传入Configuration、Executor对象
    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();
  }
}

我们看到，创建SqlSession主要需要下面几个东西：

【a】environment

环境对象，这是在mybatis-config.xml中配置的，主要用来生成TransactionFactory，而TransactionFactory是用来生成Transaction事务的。

【b】Transaction

事务对象，我们都知道sql执行时涉及到事务，需要提交或回滚什么的。创建Transaction事务对象，需要传入我们在mybatis-config.xml中配置的数据源信息（从environment获取，因为之前解析XML的时候保存进去了），通过这些参数，transactionFactory就可以生成Transaction。