美文网首页mybatis
mybatis源码分析-selectOne-04

mybatis源码分析-selectOne-04

作者: 愤怒的奶牛 | 来源:发表于2019-10-10 23:39 被阅读0次

    我们接着上篇文章来分析,上篇文章我们分析到doQuery()方法

    1.1 SimpleExecutor
    @Override
      public <E> List<E> doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException {
        Statement stmt = null;
        try {
          Configuration configuration = ms.getConfiguration();
          StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
          stmt = prepareStatement(handler, ms.getStatementLog());
          return handler.query(stmt, resultHandler);//查询
        } finally {
          closeStatement(stmt);
        }
      }
    

    上面这段代码是 SimpleExecutor 中负责查询的,我们可以看到 该方法调用的是 StatementHandler 接口的query(stmt, resultHandler); 方法来执行的查询,并返回的是一个List 集合。接下来我们就来看一下StatementHandler 的query 方法。

    1.2 StatementHandler
    /**
     * @author Clinton Begin
    接口定义
     */
    public interface StatementHandler {
    
      Statement prepare(Connection connection, Integer transactionTimeout)
          throws SQLException;
    
      void parameterize(Statement statement)
          throws SQLException;
    
      void batch(Statement statement)
          throws SQLException;
    
      int update(Statement statement)
          throws SQLException;
    
      <E> List<E> query(Statement statement, ResultHandler resultHandler)
          throws SQLException;
    
      <E> Cursor<E> queryCursor(Statement statement)
          throws SQLException;
    
      BoundSql getBoundSql();
    
      ParameterHandler getParameterHandler();
    
    }
    

    上面代码是 StatementHandler 接口的顶层定义,我们通过类图来看一下实现类:


    StatementHandler.png

    看到这个类图结构是否很熟悉,前面我们分析的 Executor 接口也是这样的类图结构,所以我们可以猜测 StatementHandler 在整个实现 query() 方法逻辑中也使用的 委派模式和模板方法。我们在这里 不需要知道这个类图上的每个类都是什么意思,我们不关注这个,我们关注的是 整个 结构体系,然后有目的的去 看具体方法干了什么事,比如我们当前是关注 查询语句的执行,那么我们就只看 有关查询的逻辑就可以了。

    1.3 StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
    // doQuery() 中创建 的StatementHandler 
     StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
    

    我们需要从这句代码入手,找到StatementHandler 具体的实现类是哪一个,这就是我们的目的,找到具体的实现类以后,才知道 handler.query(stmt, resultHandler);这句代码应该是怎么样的逻辑。接下来我们就来看看 newStatementHandler() 方法。

    1.4 configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
    //又回到了 configuration对象了
    configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
    
    // Configuration 
     public StatementHandler newStatementHandler(Executor executor, MappedStatement mappedStatement, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
    // RoutingStatementHandler
        StatementHandler statementHandler = new RoutingStatementHandler(executor, mappedStatement, parameterObject, rowBounds, resultHandler, boundSql);
        statementHandler = (StatementHandler) interceptorChain.pluginAll(statementHandler);
        return statementHandler;
      }
    

    上面这段代码就是 创建StatementHandler 对象的逻辑。逻辑简单 我们可以看出 是 StatementHandler -> RoutingStatementHandler 。所以我们接下来可以去看 RoutingStatementHandler 中的 query() 方法了。

    1.5 RoutingStatementHandler
    /**
     * @author Clinton Begin
     */
    public class RoutingStatementHandler implements StatementHandler {
    
      private final StatementHandler delegate;
    
      public RoutingStatementHandler(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
    
        switch (ms.getStatementType()) {// PREPARED,这里我是通过debug 得出的答案,
    //我们会在后面的文章中分析 原因,
    // 大致思路是 通过传入的 statement 如(User user = sqlSession.selectOne("com.example.bootmybatis.dao.UserMapper.selectByPrimaryKey", 1);)
    //statement=com.example.bootmybatis.dao.UserMapper.selectByPrimaryKey
    // 会去拿到 map 集合(从配置文件中初始化的)中对应的那个 MappedStatement  对象,该对象里就封装了statementType 。
          case STATEMENT:
            delegate = new SimpleStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
            break;
          case PREPARED:// 初始这里,这里也采用了策略模式来获取 StatementHandler  对象。通过 外部传入的 type 创建不同的对象。
            delegate = new PreparedStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
            break;
          case CALLABLE:
            delegate = new CallableStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
            break;
          default:
            throw new ExecutorException("Unknown statement type: " + ms.getStatementType());
        }
    
      }
    
      @Override
      public Statement prepare(Connection connection, Integer transactionTimeout) throws SQLException {
        return delegate.prepare(connection, transactionTimeout);
      }
    
      @Override
      public void parameterize(Statement statement) throws SQLException {
        delegate.parameterize(statement);
      }
    
      @Override
      public void batch(Statement statement) throws SQLException {
        delegate.batch(statement);
      }
    
      @Override
      public int update(Statement statement) throws SQLException {
        return delegate.update(statement);
      }
    // 执行 查询,这里我们就知道 delegate-> PreparedStatementHandler。
      @Override
      public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
        return delegate.query(statement, resultHandler);
      }
    
      @Override
      public <E> Cursor<E> queryCursor(Statement statement) throws SQLException {
        return delegate.queryCursor(statement);
      }
    
      @Override
      public BoundSql getBoundSql() {
        return delegate.getBoundSql();
      }
    
      @Override
      public ParameterHandler getParameterHandler() {
        return delegate.getParameterHandler();
      }
    }
    
    

    这里我们就知道 delegate-> PreparedStatementHandler。所以 query方法中的具体delegate.query(statement, resultHandler);我们应该是 去看 PreparedStatementHandler的对应的query方法。 后面我们会继续分析。到这里我们分析出 了PreparedStatementHandler,从名称上看我们就知道里面肯定有 PreparedStatement 对象。

    相关文章

      网友评论

        本文标题:mybatis源码分析-selectOne-04

        本文链接:https://www.haomeiwen.com/subject/xkgnpctx.html