MyBatis-Plus流式查詢的實現示例

更新時間：2024年12月13日 09:14:18 作者：咕德貓寧丶

MyBatis-Plus 從 3.5.4 版本開始支持流式查詢,通過ResultHandler接口實現結果集的流式查詢,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

使用示例

批量數據錄入

剛好順便學習下mybatisplus 批量數據錄入

數據準備 10萬條數據

@Autowired
	private MybatisUserService mybatisUserService;

	@Test
	void contextLoads() {
		List<MybatisUser> mybatisUsers = new ArrayList<>();
		for (int i = 0; i < 100000; i++) {
			MybatisUser mybatisUser = new MybatisUser();
			mybatisUser.setId(i);
			mybatisUser.setName("A"+i);
			mybatisUser.setSex(SexEnum.MAN);
			mybatisUsers.add(mybatisUser);
		}
		mybatisUserService.insertBatch(mybatisUsers);
	}

MybatisBatch方式

 // 記錄開始時間，用于計算執(zhí)行耗時
        long startTime = System.nanoTime(); // 使用 nanoTime 獲取更精確的時間

        // 創(chuàng)建 MybatisBatch 對象，用于執(zhí)行批量操作
        MybatisBatch<MybatisUser> mybatisBatch = new MybatisBatch<>(sqlSessionFactory, mybatisUser);
        // 創(chuàng)建 MybatisBatch.Method 對象，指定具體的操作方法
        MybatisBatch.Method<MybatisUser> method = new MybatisBatch.Method<>(MybatisUserDao.class);
        // 執(zhí)行插入操作
        mybatisBatch.execute(method.insert());

        // 記錄結束時間，用于計算執(zhí)行耗時
        long endTime = System.nanoTime(); // 獲取結束時間

        // 計算執(zhí)行時間并打印
        long executionTime = endTime - startTime;
        System.out.println("Execution time: " + executionTime + " nanoseconds");

SQL values方式

    @Insert("<script>" +
            "INSERT INTO `mybatis_user`(`id`, `name`, `sex`) " +
            "VALUES " +
            "<foreach collection= 'list' item= 'item' separator= ','> " +
            "(#{item.id},#{item.name},#{item.sex})" +
            "</foreach></script>")
    int insertBatchSql(@Param("list") List<MybatisUser> list);

雖然插入很快，但是不是特別推薦，當實體數據過多的時候，sql拼接可能會出問題。

推薦的話還是用多線程來分批插入。

流式查詢

/**
     * 選擇并處理數據庫中的所有用戶記錄
     * 此方法使用baseMapper從數據庫中選擇所有用戶記錄，并使用ResultHandler進行處理
     * 每處理一條記錄，都會在控制臺輸出當前記錄的信息
     */
    public void selectAll() {
        // 從數據庫獲取表所有記錄，做數據處理
        baseMapper.selectList(Wrappers.emptyWrapper(), new ResultHandler<MybatisUser>() {
            // 初始化計數器，用于記錄當前處理的記錄數
            int count = 0;
    
            /**
             * 處理查詢結果
             * 此方法在查詢到每條記錄時被調用，用于處理單個查詢結果
             * @param resultContext 包含查詢結果的上下文
             */
            @Override
            public void handleResult(ResultContext<? extends MybatisUser> resultContext) {
                // 獲取當前處理的用戶記錄
                MybatisUser mybatisUser = resultContext.getResultObject();
                // 在控制臺輸出當前處理的記錄信息
                System.out.println("當前處理第" + (++count) + "條記錄: " + mybatisUser);
            }
    
        });
    
    }