這篇文章主要介紹“如何理解SqlSession技術(shù)”，在日常操作中，相信很多人在如何理解SqlSession技術(shù)問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”如何理解SqlSession技術(shù)”的疑惑有所幫助！接下來，請跟著小編一起來學(xué)習(xí)吧！

專注于為中小企業(yè)提供網(wǎng)站設(shè)計、網(wǎng)站制作服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)二連浩特免費做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動了上千余家企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

老規(guī)矩，先上案例代碼，我們按照這個案例一步一步的搞定Mybatis源碼。

public class MybatisApplication {     public static final String URL = "jdbc:MySQL://localhost:3306/mblog";     public static final String USER = "root";     public static final String PASSWORD = "123456";      public static void main(String[] args) {         String resource = "mybatis-config.xml";         InputStream inputStream = null;         SqlSession sqlSession = null;         try {             inputStream = Resources.getResourceAsStream(resource);             SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);             sqlSession = sqlSessionFactory.openSession();             UserMapper userMapper = sqlSession.getMapper(UserMapper.class);             System.out.println(userMapper.selectById(1));          } catch (Exception e) {             e.printStackTrace();         } finally {             try {                 inputStream.close();             } catch (IOException e) {                 e.printStackTrace();             }             sqlSession.close();         }     }

由于很多小伙伴在催，說Mybatis源碼系列好像何時才有下文了，為此老田熬夜寫了這篇。

繼續(xù)開擼~~

SqlSession sqlSession = sqlSessionFactory.openSession();

前面那篇文章已經(jīng)分析了，這里的sqlSessionFactory其實就是DefaultSqlSessionFactory。

所以這里，我們就從DefaultSqlSessionFactory里的openSession方法開始。

public class DefaultSqlSessionFactory implements SqlSessionFactory {    private final Configuration configuration;    public DefaultSqlSessionFactory(Configuration configuration) {     this.configuration = configuration;   }   //創(chuàng)建session，這個方法直接調(diào)用本類中的另外一個方法   @Override   public SqlSession openSession() {     return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);   }   //其實是調(diào)用這個方法   private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {     Transaction tx = null;     try {       //對應(yīng)xml標(biāo)簽 ,這個在配置文件解析的時候就已經(jīng)存放到configuration中了。       final Environment environment = configuration.getEnvironment();       final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);       tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);       //創(chuàng)建一個executor來執(zhí)行SQL         final Executor executor = configuration.newExecutor(tx, execType);       //這里也說明了，為什么我們代碼里的SqlSession是DefaultSqlSession       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();     }   }        private TransactionFactory getTransactionFactoryFromEnvironment(Environment environment) {     if (environment == null || environment.getTransactionFactory() == null) {       return new ManagedTransactionFactory();     }     return environment.getTransactionFactory();   }

這個方法中的主要內(nèi)容有：

下面我們就來逐個攻破。

創(chuàng)建事務(wù)Transaction

事務(wù)工廠類型可以配置為JDBC類型或者M(jìn)ANAGED類型。

JdbcTransactionFactory生產(chǎn)JdbcTransaction。

ManagedTransactionFactory生產(chǎn)ManagedTransaction。

如果配置的JDBC，則會使用Connection對象的commit()、rollback()、close()方法來管理事務(wù)。

如果我們配置的是MANAGED，會把事務(wù)交給容器來管理，比如JBOSS，Weblogic。因為我們是本地跑的程序，如果配置成MANAGED就會不有任何事務(wù)。

但是，如果我們項目中是Spring集成Mybatis，則沒有必要配置事務(wù)，因為我們會直接在applicationContext.xml里配置數(shù)據(jù)源和事務(wù)管理器，從而覆蓋Mybatis的配置。

創(chuàng)建執(zhí)行器Executor

調(diào)用configuration的newExecutor方法創(chuàng)建Executor。

final Executor executor = configuration.newExecutor(tx, execType); //Configuration中 public Executor newExecutor(Transaction transaction, ExecutorType executorType) {     executorType = executorType == null ? defaultExecutorType : executorType;     executorType = executorType == null ? ExecutorType.SIMPLE : executorType;     Executor executor;     //第一步     if (ExecutorType.BATCH == executorType) {       executor = new BatchExecutor(this, transaction);     } else if (ExecutorType.REUSE == executorType) {       executor = new ReuseExecutor(this, transaction);     } else {       executor = new SimpleExecutor(this, transaction);     }     //第二步     if (cacheEnabled) {       executor = new CachingExecutor(executor);     }     //第三步     executor = (Executor) interceptorChain.pluginAll(executor);     return executor;   }

此方法分三個步驟。

第一步：創(chuàng)建執(zhí)行器

Executor的基本類型有三種：

public enum ExecutorType {   SIMPLE, REUSE, BATCH }

SIMPLE為默認(rèn)類型。

為什么要讓抽象類BaseExecutor實現(xiàn)Executor接口，然后讓具體實現(xiàn)類繼承抽象類呢?

這就是模板方法模式的實現(xiàn)。

模板方法模式就是定義一個算法骨架，并允許子類為一個或者多個步驟提供實現(xiàn)。模板方法是得子類可以再不改變算法結(jié)構(gòu)的情況下，重新定義算法的某些步驟。

抽象方法是在子類匯總實現(xiàn)的，每種執(zhí)行器自己實現(xiàn)自己的邏輯，BaseExecutor最終會調(diào)用到具體的子類中。

抽象方法

protected abstract int doUpdate(MappedStatement ms, Object parameter) throws SQLException;  protected abstract List doFlushStatements(boolean isRollback) throws SQLException;  protected abstract  List doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException;  protected abstract  Cursor doQueryCursor(MappedStatement ms, Object parameter, RowBounds rowBounds, BoundSql boundSql)  throws SQLException;

第二步：緩存裝飾

在上面代碼中的第二步

if (cacheEnabled) {       executor = new CachingExecutor(executor); }

如果cacheEnabled=true，會用裝飾器設(shè)計模式對Executor進(jìn)行裝飾。

第三步：插件代理緩存裝飾完后，就會執(zhí)行

executor = (Executor) interceptorChain.pluginAll(executor);

這里會對Executor植入插件邏輯。

比如：分頁插件中就需要把插件植入的Executor

好了，到此，執(zhí)行器創(chuàng)建的就搞定了。

創(chuàng)建DefaultSqlSession對象

把前面解析配置文件創(chuàng)建的Configuration對象和創(chuàng)建的執(zhí)行器Executor賦給DefaultSqlSession中的屬性。

public DefaultSqlSession(Configuration configuration, Executor executor, boolean autoCommit) {   this.configuration = configuration;   this.executor = executor;   this.dirty = false;   this.autoCommit = autoCommit; }

到這里，SqlSession(DefaultSqlSession)對象就創(chuàng)建完畢。

到此，關(guān)于“如何理解SqlSession技術(shù)”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
文章標(biāo)題：如何理解SqlSession技術(shù)
分享URL：http://weahome.cn/article/jdpddj.html