欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

mybatis源碼分析(3)——SqlSessionManager類

系統(tǒng) 1652 0

mybatis源碼分析(3)——SqlSessionManager類

從上圖可能看出,在?mybatis 中, SqlSession 的實(shí)現(xiàn)類有兩個,其中 SqlSessionManager 類不但實(shí)現(xiàn)了 SqlSession 接口,同時也實(shí)現(xiàn)了 SqlSessionFactory 接口。那么 SqlSessionManager 類究竟有何作用? ?? 由于源碼中缺少注釋,所以從 mybatis 目前的提供官方文檔來看,似乎該類已被棄用,其功能被 DefaultSqlSession 類和 DefaultSqlSessionFactory 類所代替。只是該類的部分代碼對我們理解 mybatis 的一些底層機(jī)制還具有一定的參考價值,例如:

SqlSessionManager的下面的構(gòu)造方法,會產(chǎn)生一個SqlSession 的一個代理對象:

?

      
        private
      
      
         SqlSessionManager(SqlSessionFactory sqlSessionFactory) {

    
      
      
        this
      
      .sqlSessionFactory =
      
         sqlSessionFactory;

    
      
      
        this
      
      .sqlSessionProxy =
      
         (SqlSession) Proxy.newProxyInstance(

        SqlSessionFactory.
      
      
        class
      
      
        .getClassLoader(),

        
      
      
        new
      
       Class[]{SqlSession.
      
        class
      
      
        },

        
      
      
        new
      
      
         SqlSessionInterceptor());

}
      
    

?

SqlSessionInterceptor類實(shí)現(xiàn)了InvocationHandler接口

      privaprivate 
      
        class
      
       SqlSessionInterceptor 
      
        implements
      
      
         InvocationHandler {

  
      
      
        public
      
       Object invoke(Object proxy, Method method, Object[] args) 
      
        throws
      
      
         Throwable   

  {

      
      
      
        final
      
       SqlSession sqlSession = SqlSessionManager.
      
        this
      
      
        .localSqlSession.get();

      
      
      
        if
      
       (sqlSession != 
      
        null
      
      
        ) {

        
      
      
        try
      
      
         {

          
      
      
        return
      
      
         method.invoke(sqlSession, args);

        } 
      
      
        catch
      
      
         (Throwable t) {

          
      
      
        throw
      
      
         ExceptionUtil.unwrapThrowable(t);

        }

      } 
      
      
        else
      
      
         {

        
      
      
        final
      
       SqlSession autoSqlSession =
      
         openSession();

        
      
      
        try
      
      
         {

          
      
      
        final
      
       Object result =
      
         method.invoke(autoSqlSession, args);

          autoSqlSession.commit();

          
      
      
        return
      
      
         result;

        } 
      
      
        catch
      
      
         (Throwable t) {

          autoSqlSession.rollback();

          
      
      
        throw
      
      
         ExceptionUtil.unwrapThrowable(t);

        } 
      
      
        finally
      
      
         {

          autoSqlSession.close();

        }

      }

    }

  }


      
      
        private
      
      
        class
      
       SqlSessionInterceptor 
      
        implements
      
      
         InvocationHandler {

  
      
      
        public
      
       Object invoke(Object proxy, Method method, Object[] args) 
      
        throws
      
      
         Throwable   

  {

      
      
      
        final
      
       SqlSession sqlSession = SqlSessionManager.
      
        this
      
      
        .localSqlSession.get();

      
      
      
        if
      
       (sqlSession != 
      
        null
      
      
        ) {

        
      
      
        try
      
      
         {

          
      
      
        return
      
      
         method.invoke(sqlSession, args);

        } 
      
      
        catch
      
      
         (Throwable t) {

          
      
      
        throw
      
      
         ExceptionUtil.unwrapThrowable(t);

        }

      } 
      
      
        else
      
      
         {

        
      
      
        final
      
       SqlSession autoSqlSession =
      
         openSession();

        
      
      
        try
      
      
         {

          
      
      
        final
      
       Object result =
      
         method.invoke(autoSqlSession, args);

          autoSqlSession.commit();

          
      
      
        return
      
      
         result;

        } 
      
      
        catch
      
      
         (Throwable t) {

          autoSqlSession.rollback();

          
      
      
        throw
      
      
         ExceptionUtil.unwrapThrowable(t);

        } 
      
      
        finally
      
      
         {

          autoSqlSession.close();

        }

      }

    }

  }
      
    

下面對這一段使用JAVA 動態(tài) 代理技術(shù)產(chǎn)生SqlSession 代理對象的代碼進(jìn)行分析:

this.sqlSessionProxy?=?(SqlSession)?Proxy.newProxyInstance(

????????SqlSessionFactory.class.getClassLoader(),

????????new?Class[]{SqlSession.class},

????????new?SqlSessionInterceptor())??這句是關(guān)鍵, JDK Proxy 類的 newProxyInstance 方法的方法原型如下:

public?static?Object?newProxyInstance(ClassLoader?loader,

??Class<?>[]?interfaces,

??InvocationHandler?h)

throws?IllegalArgumentException

在調(diào)這個方法中需要傳入三個參數(shù):

??一個 interfaces 的數(shù)組參數(shù)

??一個 InvocationHanler? 接口的實(shí)例對象

??一個類加載器,

則Proxy.newProxyInstance方法執(zhí)行后會返回 interfaces 中任一接口的實(shí)例對象(假設(shè)該對象為 proxyObject), 那么當(dāng)我們在調(diào)用這個對象 proxyObject 的相應(yīng)方法時,就會進(jìn)入到 InvocationHandler? 這個參數(shù)對象的 invoke(Object?proxy,?Method?method,?Object[]?args)方法中,或者換句話說,就會被h 這個對象的 invoke 方法攔截 ,? 對象 proxyObject 會作為

Invoke 中的 proxy 參數(shù), proxyObject 調(diào)用的方法的方法對象會作為 method 參數(shù) , 方法的參數(shù)會作為 args 參數(shù) ,這樣在 InvocationHandler? 對象的 invoke 方法中,就會通過 Method.invoke 方法來執(zhí)行具體的目標(biāo)對象的相應(yīng)方法,在 mybatis 的這個應(yīng)用場景上,這個目標(biāo)對象其實(shí)就是一個 SqlSession 的實(shí)例 , 通過 SqlSessionManager 類的成員變量 sqlSessionFactory的openSession()獲得或者從當(dāng)前線程中獲取。

?

以上的實(shí)現(xiàn)技術(shù)主要就是使用了 java 的動態(tài)代理技術(shù),看到網(wǎng)上不少人在問這個 InvocationHandler? 接口中的 invoke 方法的第一個參數(shù) proxy 究竟有何作用,這個 proxy 其實(shí)就是一個代理對象實(shí)例(通過 Proxy.newProxyInstance方法產(chǎn)生),下面就舉例說明一下它的作用:

可參照?java.rmi.server.RemoteObjectInvocationHandler類中的相應(yīng)方法invoke 方法,一個用法就是判斷 invoke method 參數(shù),看是否有必要調(diào)用 proxy 對象的其他方法,另一個用處就是作為參數(shù)把該對象提供給遠(yuǎn)程調(diào)用的方法使用。 ?

mybatis源碼分析(3)——SqlSessionManager類


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長非常感激您!手機(jī)微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 国产综合视频在线观看 | 美女福利视频国产免费观看 | 日韩在线观看视频网站 | 浮力影院最新地址 | 亚洲品质自拍视频网站 | 小明成人永久在线看 | 日本1区2区 | 韩漫重考生漫画画免费读漫画下拉式土豪漫 | 久草福利网| 天天色天天 | 欧美高清在线视频一区二区 | 业余护士毛茸茸 | 亚洲自偷自偷精品 | a天堂资源在线观看 | 久久久青草 | 人人人人人爽 | 午夜电影网 | 免费看一区二区三区 | 成人免费网站视频 | 国产区在线 | 日日骚 | 免费毛片在线播放 | 国产精品a在线观看香蕉 | 51国产视频| 国产 欧美 日韩 一区 | 久久狠狠一本精品综合网 | 欧美亚洲综合久久 | 国产 一区 | 精品在线一区二区 | 亚洲精品一区二区三区精华液 | 影音先锋中文字幕一区 | 无码免费一区二区三区免费播放 | 色婷婷激婷婷深爱五月小说 | 国产一区二区三区乱码 | 日本精品久久久一区二区三区 | 中文字幕在线精品 | 亚洲网站免费看 | 狠狠天天 | 色精品 | 色婷婷导航| 欧美高清不卡午夜精品免费视频 |