一，DefaultSqlSession的執行緒不安全性

在MyBatis的架構中的SqlSession是提供給外層呼叫的頂層介面，實現類有：DefaultSqlSession，SqlSessionManager以及MyBatis的彈簧提供的實現SqlSessionTemplate預設的實現類為DefaultSqlSession如類圖結構如下所示：。
 
對於MyBatis的提供的原生實現類來說，用的最多的就是DefaultSqlSession，但我們知道DefaultSqlSession這個類不是執行緒安全的如下！

二，SqlSessionTemplate是如何使用DefaultSqlSession的

而在我們開發的時候肯定會用到春天，也會用到MyBatis的彈簧框架，在使用的MyBatis與彈簧整合的時候我們會用到了SqlSessionTemplate這個類，例如下邊的配置，注入一個單例的SqlSessionTemplate物件：

<bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg ref="sqlSessionFactory" />
</bean>

• 1
• 2
• 3

SqlSessionTemplate的原始碼註釋如下：
 

如果是常規開發模式的話，我們每次在使用DefaultSqlSession的時候都從SqlSessionFactory物件當中獲取一個就可以了但是與彈簧整合以後，彈簧提供了一個全域性唯一的SqlSessionTemplate物件來完成DefaultSqlSession的功能，問題就是：無論是多個道使用一個SqlSessionTemplate，還是一個道使用一個SqlSessionTemplate，SqlSessionTemplate都是對應一個SQLSESSION物件，當多個網路執行緒呼叫同一個島時，它們使用的是同一個SqlSessionTemplate，也就是同一個SqlSession的，那麼它？是如何確保執行緒安全的呢讓我們一起來分析一下：

三，SqlSessionTemplate是如何保證DefaultSqlSession執行緒安全的

（1）首先，通過如下程式碼建立代理類，表示建立的SqlSessionFactory的代理類的例項，該代理類實現的SqlSession介面，定義了方法攔截器，如果呼叫代理類例項中實現的SqlSession介面定義的方法，該呼叫則被導向SqlSessionInterceptor的invoke方法（代理物件的InvocationHandler就是SqlSessionInterceptor，如果把它命名為SqlSessionInvocationHandler則更好理解！）核心
 
程式碼就在SqlSessionInterceptor的invoke方法當中。

private class SqlSessionInterceptor implements InvocationHandler {
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) 
            throws Throwable {
        //獲取SqlSession(這個SqlSession才是真正使用的，它不是執行緒安全的)
        //這個方法可以根據Spring的事物上下文來獲取事物範圍內的sqlSession
        SqlSession sqlSession = getSqlSession(
                SqlSessionTemplate.this.sqlSessionFactory,
                SqlSessionTemplate.this.executorType,
                SqlSessionTemplate.this.exceptionTranslator);
        try {
            //呼叫從Spring的事物上下文獲取事物範圍內的sqlSession物件
            Object result = method.invoke(sqlSession, args);
            //然後判斷一下當前的sqlSession是否被Spring託管 如果未被Spring託管則自動commit
            if (!isSqlSessionTransactional(sqlSession, 
                    SqlSessionTemplate.this.sqlSessionFactory)) {
                // force commit even on non-dirty sessions because some databases require
                // a commit/rollback before calling close()
                sqlSession.commit(true);
            }
            return result;
        } catch (Throwable t) {
            //如果出現異常則根據情況轉換後丟擲
            Throwable unwrapped = unwrapThrowable(t);
            if (SqlSessionTemplate.this.exceptionTranslator != null && 
                    unwrapped instanceof PersistenceException) {
                // release the connection to avoid a deadlock if the 
                // translator is no loaded. See issue #22
                closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
                sqlSession = null;
                Throwable translated = SqlSessionTemplate.this.exceptionTranslator.
                        translateExceptionIfPossible((PersistenceException) unwrapped);
                if (translated != null) {
                    unwrapped = translated;
                }
            }
            throw unwrapped;
        } finally {
            if (sqlSession != null) {
                //關閉sqlSession，它會根據當前的sqlSession是否在Spring的事物上下文當中來執行具體的關閉動作
                //如果sqlSession被Spring管理 則呼叫holder.released();
                //使計數器-1，否則才真正的關閉sqlSession
                closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
            }
        }
    }
}

• 1
• 2
• 3
• 4
• 五
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 三十
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47

在上面的呼叫方法當中使用了兩個工具方法分別是：

（1）SqlSessionUtils.getSqlSession(SqlSessionFactory sessionFactory, ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator)
（2）SqlSessionUtils.closeSqlSession(SqlSession session, SqlSessionFactory sessionFactory)

• 1
• 2

那麼這兩個方法又是如何與春天的事物進行關聯的呢？

1，getSqlSession方法如下：

public static SqlSession getSqlSession(SqlSessionFactory sessionFactory, 
        ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator) {

    notNull(sessionFactory, NO_SQL_SESSION_FACTORY_SPECIFIED);
    notNull(executorType, NO_EXECUTOR_TYPE_SPECIFIED);

    //根據sqlSessionFactory從當前執行緒對應的資源map中獲取SqlSessionHolder，
    // 當sqlSessionFactory建立了sqlSession，
    //就會在事務管理器中新增一對對映：key為sqlSessionFactory，value為SqlSessionHolder，
    // 該類儲存sqlSession及執行方式
    SqlSessionHolder holder = (SqlSessionHolder) TransactionSynchronizationManager.
            getResource(sessionFactory);

    //從SqlSessionHolder中提取SqlSession物件
    SqlSession session = sessionHolder(executorType, holder);
    if (session != null) {
        return session;
    }

    if (LOGGER.isDebugEnabled()) {
        LOGGER.debug("Creating a new SqlSession");
    }
    //如果當前事物管理器中獲取不到SqlSessionHolder物件就重新建立一個
    session = sessionFactory.openSession(executorType);

    //將新建立的SqlSessionHolder物件註冊到TransactionSynchronizationManager中
    registerSessionHolder(sessionFactory, executorType, exceptionTranslator, session);

    return session;
}

• 1
• 2
• 3
• 4
• 五
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 三十

2，closeSqlSession方法如下：

//刪除了部分日誌程式碼
public static void closeSqlSession(SqlSession session, SqlSessionFactory sessionFactory) {
        //其實下面就是判斷session是否被Spring事務管理，如果管理就會得到holder
        SqlSessionHolder holder = (SqlSessionHolder) 
        TransactionSynchronizationManager.getResource(sessionFactory);
        if ((holder != null) && (holder.getSqlSession() == session)) {
            //這裡釋放的作用，不是關閉，只是減少一下引用數，因為後面可能會被複用 
            holder.released();
        } else {
            //如果不是被spring管理，那麼就不會被Spring去關閉回收，就需要自己close 
            session.close();
        }
    }

• 1
• 2
• 3
• 4
• 五
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13

大致的分析到此為止，可能有些許不夠順暢，不過：紙上得來終覺淺，絕知此事要躬行還希望小夥伴開啟自己的編譯器，找到此處的程式碼，認真走一遍流程！

其實通過上面的程式碼我們可以看出的MyBatis在很多地方都用到了代理模式，代理模式可以說是一種經典模式，其實不緊緊在這個地方用到了代理模式，春天的事物，AOP，MyBatis的資料庫連線池技術，MyBatis的的核心原理（如何在只有介面沒有實現類的情況下完成資料庫的操作！）等技術都使用了代理技術。

四，SqlSessionManager又是什麼鬼？

上述說了一個SqlSession的實現還有一個SqlSessionManager，那麼SqlSessionManager到底是什麼個東西哪且看定義如下：？ 
 
？你可能會發現SqlSessionManager的構造方法竟然是私人的，那我們怎麼建立這個物件哪其實SqlSessionManager建立物件是通過的newInstance的方法建立物件的，但需要注意的是他雖然有私有的構造方法，並且提供給我們了一個公有的的newInstance方法，但它並不是一個單例模式！

newInstance有很多過載的方法，如下所示：
 
SqlSessionManager的openSession方法及其過載的方法是直接通過呼叫其中的底層封裝的SqlSessionFactory物件的openSession方法來建立SqlSession物件的，過載方法如下：
 
SqlSessionManager中實現了SqlSession的介面中的方法，例如：選擇，更新等，都是直接呼叫sqlSessionProxy代理物件中相應的方法在建立該代理對像的時候使用的InvocationHandler的物件是SqlSessionInterceptor，他是定義在SqlSessionManager的一個內部類，其定義如下：

五，總結

綜上所述，我們應該大致瞭解了DefaultSqlSession和SqlSessionManager之間的區別：

1，DefaultSqlSession的內部沒有提供像SqlSessionManager一樣通過ThreadLocal的的方式來保證執行緒的安全性;

2，SqlSessionManager是通過localSqlSession這個ThreadLocal的變數，記錄與當前執行緒繫結的SqlSession的物件，供當前執行緒迴圈使用，從而避免在同一個執行緒多次建立的SqlSession物件造成的效能損耗;

3，DefaultSqlSession不是執行緒安全的，我們在進行原生開發的時候，需要每次為一個操作都建立一個SqlSession的物件，其效能可想而知;

六，擴充套件面試題

那麼問題來了：

1，為什麼MyBatis的彈簧框架中不直接使用執行緒安全的SqlSessionManager（SqlSessionFactory中它是執行緒安全的）而是使用DefaultSqlSession這個執行緒不安全的類，並通過動態代理的方式來保證DefaultSqlSession操作的執行緒安全性哪？

2，DefaultSqlSession中是如何通過執行器來表現策略模式的或者DefaultSqlSession如何使用策略模式模式的？