关注“Java后端技术全栈”

回复“面试”获取全套面试材料

老规矩,先上案例代码,咱们依照这个案例一步一步的搞定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是如何解析相干配置文件的,如果怕迷路,还是倡议先看前一篇文章:

Mybatis是如何解析配置文件的?看完终于明确了

因为很多小伙伴在催,说Mybatis源码系列如同何时才有下文了,为此老田熬夜写了这篇。

持续开撸~~

SqlSession sqlSession = sqlSessionFactory.openSession();

后面那篇文章曾经剖析了,这里的sqlSessionFactory其实就是DefaultSqlSessionFactory。

所以这里,咱们就从DefaultSqlSessionFactory里的openSession办法开始。

public class DefaultSqlSessionFactory implements SqlSessionFactory {  private final Configuration configuration;  public DefaultSqlSessionFactory(Configuration configuration) {    this.configuration = configuration;  }  //创立session,这个办法间接调用本类中的另外一个办法  @Override  public SqlSession openSession() {    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);  }  //其实是调用这个办法  private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {    Transaction tx = null;    try {      //对应xml标签<environments> ,这个在配置文件解析的时候就曾经寄存到configuration中了。      final Environment environment = configuration.getEnvironment();      final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);      tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);      //创立一个executor来执行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();  }

这个办法中的次要内容有:

上面咱们就来一一攻破。

创立事务Transaction

事务工厂类型能够配置为JDBC类型或者MANAGED类型。

JdbcTransactionFactory生产JdbcTransaction。

ManagedTransactionFactory生产ManagedTransaction。

如果配置的JDBC,则会应用Connection对象的commit()、rollback()、close()办法来治理事务。

如果咱们配置的是MANAGED,会把事务交给容器来治理,比方JBOSS,Weblogic。因为咱们是本地跑的程序,如果配置成MANAGED就会不有任何事务。

然而,如果咱们我的项目中是Spring集成Mybatis,则没有必要配置事务,因为咱们会间接在applicationContext.xml里配置数据源和事务管理器,从而笼罩Mybatis的配置。

创立执行器Executor

调用configuration的newExecutor办法创立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;  }

此办法分三个步骤。

第一步:创立执行器

Executor的根本类型有三种:

public enum ExecutorType {  SIMPLE, REUSE, BATCH}

SIMPLE为默认类型。

为什么要让抽象类BaseExecutor实现Executor接口,而后让具体实现类继承抽象类呢?

这就是模板办法模式的实现。

模板办法模式就是定义一个算法骨架,并容许子类为一个或者多个步骤提供实现。模板办法是得子类能够再不扭转算法构造的状况下,从新定义算法的某些步骤。

对于模板办法模式举荐浏览:

如何疾速把握模板办法模式

形象办法是在子类汇总实现的,每种执行器本人实现本人的逻辑,BaseExecutor最终会调用到具体的子类中。

形象办法
protected abstract int doUpdate(MappedStatement ms, Object parameter) throws SQLException;protected abstract List<BatchResult> doFlushStatements(boolean isRollback) throws SQLException;protected abstract <E> List<E> doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException;protected abstract <E> Cursor<E> doQueryCursor(MappedStatement ms, Object parameter, RowBounds rowBounds, BoundSql boundSql)  throws SQLException;

第二步:缓存装璜

在下面代码中的第二步

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

如果cacheEnabled=true,会用装璜器设计模式对Executor进行装璜。

第三步:插件代理

缓存装璜完后,就会执行

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

这里会对Executor植入插件逻辑。

比方:分页插件中就须要把插件植入的Executor

好了,到此,执行器创立的就搞定了。

创立DefaultSqlSession对象

把后面解析配置文件创立的Configuration对象和创立的执行器Executor赋给DefaultSqlSession中的属性。

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

到这里,SqlSession(DefaultSqlSession)对象就创立结束。

总结

本文咱们讲了如何创立SqlSession的几个步骤,最初咱们取得一个DefaultSqlSession对象,外面蕴含了执行器Executor和配置对象Configuration。Executor是SQL的理论执行对象。Configuration里保留着配置文件内容。

本文源码剖析的整个流程如下图:

码字不易,给个在看,点个赞呗

举荐浏览

面试官:Mybatis里的设计模式有哪些?我一口气答了8种

面试官问我:能说几个常见的Linux性能调优命令吗?