快捷導航

MyBatis-Plus流式查詢的實現(xiàn)示例

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

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

使用示例

批量數(shù)據(jù)錄入

剛好順便學習下mybatisplus 批量數(shù)據(jù)錄入

數(shù)據(jù)準備 10萬條數(shù)據(jù)

@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());

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

        // 計算執(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);

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

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

流式查詢

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

下面是一下常用方法

getResultObject: 獲取數(shù)據(jù)庫中的每一條記錄。
getResultCount: 獲取當前處理的結(jié)果集條數(shù)，每處理一條記錄，該計數(shù)器會加1，計數(shù)從1開始。
stop: 停止繼續(xù)處理結(jié)果集，相當于在循環(huán)中使用 break 語句。

比如當我們需要導出大量數(shù)據(jù)的情況下，使用普通查詢導出是因為一次性把所有數(shù)據(jù)查詢出來放在集合中，這時候垃圾處理器釋放不了這一部分內(nèi)存，如果內(nèi)存不夠就會使程序掛掉。使用mybatis-plus的流式查詢, 一邊查詢一邊導出 ,這樣用過的數(shù)據(jù)寫入流之后垃圾處理器回收掉內(nèi)存空間,使內(nèi)存得到合理應(yīng)用。

到此這篇關(guān)于MyBatis-Plus流式查詢的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)MyBatis-Plus流式查詢內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: