快捷導(dǎo)航

mybatis-plus查詢?cè)创a詳解

更新時(shí)間：2022年03月02日 11:54:07 作者：這個(gè)世界太瘋狂了

這篇文章主要介紹了mybatis-plus查詢?cè)创a解讀,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

配置詳情

pom.xml

dependency>
     <groupId>com.baomidou</groupId>
     <artifactId>mybatis-plus-boot-starter</artifactId>
     <version>3.4.1</version>
 </dependency>

mapper

public interface GenTableMapper extends BaseMapper<GenTable> {
}

測(cè)試類

@RunWith(SpringRunner.class)
@SpringBootTest(classes = GendemoApplication.class)
public class BlockqueueTestDemo {
    @Autowired
    GenTableMapper genTableMapper;
    @Test
    public void test(){
        List<GenTable> genTables = 
        genTableMapper.selectList(new QueryWrapper<>());
    }
}

debug流程

1.發(fā)現(xiàn) genTableMapper 是一個(gè)代理對(duì)象類型。

在這里插入圖片描述

2.進(jìn)入代理對(duì)象MybatisMapperProxy , 調(diào)用其invoke 方法，方法的Class類型為BaseMapper.selectList()

在這里插入圖片描述

3.其中cachedInvoker()方法會(huì)返回一個(gè)PlainMethodInvoker ,它重寫了MapperMethodInvoker 接口的invoke()方法

在這里插入圖片描述

4.最終會(huì)調(diào)用MybatisMapperMethod的execute()方法

在這里插入圖片描述

public class MybatisMapperMethod {
    public Object execute(SqlSession sqlSession, Object[] args) {
        Object result;
        switch (command.getType()) {
            case INSERT: {
                Object param = method.convertArgsToSqlCommandParam(args);
                result = rowCountResult(sqlSession.insert(command.getName(), param));
                break;
            }
            case UPDATE: {
                Object param = method.convertArgsToSqlCommandParam(args);
                result = rowCountResult(sqlSession.update(command.getName(), param));
                break;
            }
            case DELETE: {
                Object param = method.convertArgsToSqlCommandParam(args);
                result = rowCountResult(sqlSession.delete(command.getName(), param));
                break;
            }
            case SELECT:
                if (method.returnsVoid() && method.hasResultHandler()) {
                    executeWithResultHandler(sqlSession, args);
                    result = null;
                } else if (method.returnsMany()) {
                    result = executeForMany(sqlSession, args);
                } else if (method.returnsMap()) {
                    result = executeForMap(sqlSession, args);
                } else if (method.returnsCursor()) {
                    result = executeForCursor(sqlSession, args);
                } else {
                    Object param = method.convertArgsToSqlCommandParam(args);
                    // TODO 這里下面改了
                    if (IPage.class.isAssignableFrom(method.getReturnType())) {
                        result = executeForIPage(sqlSession, args);
                        // TODO 這里上面改了
                    } else {
                        result = sqlSession.selectOne(command.getName(), param);
                        if (method.returnsOptional()
                            && (result == null || !method.getReturnType().equals(result.getClass()))) {
                            result = Optional.ofNullable(result);
                        }
                    }
                }
                break;
            case FLUSH:
                result = sqlSession.flushStatements();
                break;
            default:
                throw new BindingException("Unknown execution method for: " + command.getName());
        }
        if (result == null && method.getReturnType().isPrimitive() && !method.returnsVoid()) {
            throw new BindingException("Mapper method '" + command.getName()
                + " attempted to return null from a method with a primitive return type (" + method.getReturnType() + ").");
        }
        return result;
    }
}

5.這是經(jīng)過(guò)判斷會(huì)進(jìn)入executeForMany(sqlSession, args)方法，此時(shí)方法和參數(shù)都顯示出來(lái)了。sqlSession的類型是SqlSessionTemplate , 為什么要注意這個(gè) sqlSession的類型？因?yàn)?code>SqlSession是一個(gè)接口，有很多實(shí)現(xiàn)類，有時(shí)候我們并不知道到底調(diào)用了哪個(gè)實(shí)現(xiàn)類的selectList()方法，這個(gè)時(shí)候我們看類型就知道了，就可以進(jìn)入SqlSessionTemplate類，找到selectList()打上斷點(diǎn)，debug就過(guò)來(lái)了。

在這里插入圖片描述

6.利用同樣的方法，又調(diào)用了DefaultSqlSession的selectList()方法。

在這里插入圖片描述

7.來(lái)到DefaultSqlSession的selectList() 方法中，此時(shí)已經(jīng)進(jìn)入到mybatis的源碼范圍了。executor的類型是MybatisCachingExecutor

在這里插入圖片描述

8.此時(shí)要注意MybatisCachingExecutor 代理類的handler是一個(gè)Plugin

在這里插入圖片描述

9.因?yàn)槲沂褂玫搅朔猪?yè)插件，所以會(huì)來(lái)到com.github.pagehelperPageInterceptor中

在這里插入圖片描述

10.由MybatisCachingExecutor來(lái)執(zhí)行查詢

在這里插入圖片描述

11.MybatisCachingExecutor 委派 BaseExecutor 執(zhí)行查詢

在這里插入圖片描述

12.最終委派到PreparedStatementHandler來(lái)處理

在這里插入圖片描述

13.最后由DefaultResultSetHandler來(lái)封裝結(jié)果集

@Override
  public List<Object> handleResultSets(Statement stmt) throws SQLException {
    ErrorContext.instance().activity("handling results").object(mappedStatement.getId());

    final List<Object> multipleResults = new ArrayList<>();
    int resultSetCount = 0;
    ResultSetWrapper rsw = getFirstResultSet(stmt);
    List<ResultMap> resultMaps = mappedStatement.getResultMaps();
    int resultMapCount = resultMaps.size();
    validateResultMapsCount(rsw, resultMapCount);
    while (rsw != null && resultMapCount > resultSetCount) {
      ResultMap resultMap = resultMaps.get(resultSetCount);
      handleResultSet(rsw, resultMap, multipleResults, null);
      rsw = getNextResultSet(stmt);
      cleanUpAfterHandlingResultSet();
      resultSetCount++;
    }
    String[] resultSets = mappedStatement.getResultSets();
    if (resultSets != null) {
      while (rsw != null && resultSetCount < resultSets.length) {
        ResultMapping parentMapping = nextResultMaps.get(resultSets[resultSetCount]);
        if (parentMapping != null) {
          String nestedResultMapId = parentMapping.getNestedResultMapId();
          ResultMap resultMap = configuration.getResultMap(nestedResultMapId);
          handleResultSet(rsw, resultMap, null, parentMapping);
        }
        rsw = getNextResultSet(stmt);
        cleanUpAfterHandlingResultSet();
        resultSetCount++;
      }
    return collapseSingleResultList(multipleResults);
  }