Mybatis執行SQL的流程

學習自拉鈎教育java高薪訓練營

前篇：Mybatis初始化過程

SqlSession ：

SqlSession是一個接口，它有兩個實現類：DefaultSqlSession (默認)和

SqlSessionManager (棄用，不做介紹)

SqlSession是MyBatis中用於和數據庫交互的頂層類，通常將它與ThreadLocal綁定，一個會話使用一 個

SqlSession,並且在使用完畢后需要close （SqlSession是線程不安全的，因此我們使用完后要記得close）

public class DefaultSqlSession implements SqlSession {
    private final Configuration configuration; 
    private final Executor executor;
    //SqlSession中的兩個最重要的參數，configuration與初始化時的相同，Executor為執行器
	//......
}

Executor ：

Executor也是一個接口，他有三個常用的實現類：

BatchExecutor (重用語句並執行批量更新)

ReuseExecutor (重用預處理語句 prepared statements)

SimpleExecutor (普通的執行器，默認)

源碼分析：

1. SqlSession sqlSession = sqlSessionFactory.openSession();

// 1. 讀取配置文件，讀成字節輸入流，注意：現在還沒解析
InputStream resourceAsStream = Resources.getResourceAsStream("sqlMapConfig.xml");
// 2. 解析配置文件，封裝Configuration對象   創建DefaultSqlSessionFactory對象
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);

// 3. 生產了DefaultSqlsession實例對象   設置了事務不自動提交  完成了executor對象的創建
SqlSession sqlSession = sqlSessionFactory.openSession();

//進入openSession方法
@Override
public SqlSession openSession() {
    //getDefaultExecutorType()傳遞的是SimpleExecutor
    //第一個參數：當前默認執行器的類型
    //第二個參數：數據庫的隔離級別
    //第三個參數：是否自動提交事務
    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
}

//configuration.getDefaultExecutorType() --- 當前默認執行器的類型
public ExecutorType getDefaultExecutorType() {
    return defaultExecutorType;
}

protected ExecutorType defaultExecutorType = ExecutorType.SIMPLE;

//進入openSessionFromDataSource。
//ExecutorType 為Executor的類型，TransactionIsolationLevel為事務隔離級別，autoCommit是否開啟事務
//openSession的多個重載方法可以指定獲得的SeqSession的Executor類型和事務的處理
private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
    Transaction tx = null;
    try {
        // 獲得 Environment (運行環境)對象 
        final Environment environment = configuration.getEnvironment();
        // 創建 Transaction （事務）對象
        final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
        tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
        // 創建 Executor 對象
        final Executor executor = configuration.newExecutor(tx, execType);
        // 創建 DefaultSqlSession 對象
        return new DefaultSqlSession(configuration, executor, autoCommit);
    } catch (Exception e) {
        // 如果發生異常，則關閉 Transaction 對象
        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對象的創建

2. List