MyBatis-Plus流式查询的实现示例

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

 // 记录开始时间，用于计算执行耗时
        long startTime = System.nanoTime(); // 使用 nanoTime 获取更精确的时间

        // 创建 MybatisBatch 对象，用于执行批量操作
        MybatisBatch<MybatisUser> mybatisBatch = new MybatisBatch<>(sqlSessionFactory, mybatisUser);
        // 创建 MybatisBatch.Method 对象，指定具体的操作方法
        MybatisBatch.Method<MybatisUser> method = new MybatisBatch.Method<>(MybatisUserDao.class);
        // 执行插入操作
        mybatisBatch.execute(method.insert());

        // 记录结束时间，用于计算执行耗时
        long endTime = System.nanoTime(); // 获取结束时间

        // 计算执行时间并打印
        long executionTime = endTime - startTime;
        System.out.println("Execution time: " + executionTime + " nanoseconds");

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

/**
     * 选择并处理数据库中的所有用户记录
     * 此方法使用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);
            }
    
        });
    
    }