詳解mybatis流式查詢與分頁插件
1、流式查詢
1、實體類
package com.wanqi.pojo; import java.util.Date; /** * @Description TODO * @Version 1.0.0 * @Date 2022/9/12 * @Author wandaren */ public class VoteRecord { private int id; private String userId; private int voteNum; private int groupId; private boolean status; private Date createTime; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUserId() { return userId; } public void setUserId(String userId) { this.userId = userId; } public int getVoteNum() { return voteNum; } public void setVoteNum(int voteNum) { this.voteNum = voteNum; } public int getGroupId() { return groupId; } public void setGroupId(int groupId) { this.groupId = groupId; } public boolean isStatus() { return status; } public void setStatus(boolean status) { this.status = status; } public Date getCreateTime() { return createTime; } public void setCreateTime(Date createTime) { this.createTime = createTime; } @Override public String toString() { return "VoteRecord{" + "id=" + id + ", userId='" + userId + '\'' + ", voteNum=" + voteNum + ", groupId=" + groupId + ", status=" + status + ", createTime=" + createTime + '}'; } }
2、mapper
package com.wanqi.mapper; import com.wanqi.pojo.VoteRecord; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Options; import org.apache.ibatis.annotations.ResultType; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.cursor.Cursor; import org.apache.ibatis.mapping.ResultSetType; import org.apache.ibatis.session.ResultHandler; import java.util.List; /** * @Description TODO * @Version 1.0.0 * @Date 2022/9/12 * @Author wandaren */ @Mapper public interface VoteRecordMapper { // @Select("select id, user_id as userId, vote_num as voteNum, group_id as groupId, status, create_time as createTime from vote_record") // @Options(resultSetType = ResultSetType.FORWARD_ONLY, fetchSize = Integer.MIN_VALUE) // @ResultType(VoteRecord.class) void all(ResultHandler<VoteRecord> resultHandler); }
3、mapper配置
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.wanqi.mapper.VoteRecordMapper"> <select id="all" resultType="com.wanqi.pojo.VoteRecord" resultSetType="FORWARD_ONLY" fetchSize="-2147483648"> select id, user_id as userId, vote_num as voteNum, group_id as groupId, status, create_time as createTime from vote_record </select> </mapper>
:::info
this.query.getResultType() == Type.FORWARD_ONLY
this.query.getResultFetchSize() == Integer.MIN_VALUE?
:::
fetchSize必須設(shè)置成-2147483648
4、自定義處理結(jié)果集
package com.wanqi.handler; import com.wanqi.pojo.VoteRecord; import org.apache.ibatis.session.ResultContext; import org.apache.ibatis.session.ResultHandler; import org.springframework.util.ObjectUtils; import java.util.ArrayList; import java.util.List; /** * @Description TODO * @Version 1.0.0 * @Date 2022/9/12 * @Author wandaren */ public class VoteRecordHandler implements ResultHandler<VoteRecord> { // 這是每批處理的大小 private final static int BATCH_SIZE = 1000; private int size; private final List<VoteRecord> list = new ArrayList<>(); @Override public void handleResult(ResultContext<? extends VoteRecord> resultContext) { VoteRecord voteRecord = resultContext.getResultObject(); list.add(voteRecord); size++; if (size == BATCH_SIZE) { handle(); } } private void handle() { try { if (ObjectUtils.isEmpty(list)) { return; } // 在這里可以對你獲取到的批量結(jié)果數(shù)據(jù)進行需要的業(yè)務(wù)處理 // list.parallelStream().forEach(s -> System.out.println(s.getId())); } finally { // 處理完每批數(shù)據(jù)后后將臨時清空 size = 0; list.clear(); } } // 這個方法給外面調(diào)用,用來完成最后一批數(shù)據(jù)處理 public void end(){ handle();// 處理最后一批不到BATCH_SIZE的數(shù)據(jù) } }
5、service層
package com.wanqi.service; import com.github.pagehelper.PageHelper; import com.wanqi.handler.VoteRecordHandler; import com.wanqi.mapper.VoteRecordMapper; import com.wanqi.pojo.VoteRecord; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; /** * @Description TODO * @Version 1.0.0 * @Date 2022/9/12 * @Author wandaren */ @Service public class VoteRecordService { @Autowired private VoteRecordMapper voteRecordMapper; public String allVoteRecord(){ VoteRecordHandler voteRecordHandler = new VoteRecordHandler(); voteRecordMapper.all(voteRecordHandler); System.out.println("--------------------------------------------------------"); voteRecordHandler.end(); return "處理結(jié)束?。?!"; } }
2、分頁插件
1、引入依賴
<dependency> <groupId>com.github.pagehelper</groupId> <artifactId>pagehelper-spring-boot-starter</artifactId> <version>1.4.3</version> </dependency>
2、配置文件
spring: redis: host: 172.16.156.139 password: qifeng database: 2 port: 6379 datasource: type: com.alibaba.druid.pool.DruidDataSource url: jdbc:mysql://172.16.156.139:3306/test?allowPublicKeyRetrieval=true username: wq password: qifeng driver-class-name: com.mysql.cj.jdbc.Driver mybatis: type-aliases-package: com.wanqi.pojo mapper-locations: classpath:mapper/*.xml #分頁插件的配置 pagehelper: #配置四項 hprs helper-dialect: mysql #分頁助手方言:mysql params: count=countSql #為了支持 startPage(Object params) 方法 support-methods-arguments: true #支持通過 Mapper 接口參數(shù)來傳遞分頁參數(shù),默認值 false reasonable: true #分頁合理化參數(shù),默認值為 false,頁碼不為負,不超總頁碼
3、mapper接口
package com.wanqi.mapper; import com.wanqi.pojo.VoteRecord; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.session.ResultHandler; import java.util.List; /** * @Description TODO * @Version 1.0.0 * @Date 2022/9/12 * @Author wandaren */ @Mapper public interface VoteRecordMapper { List<VoteRecord> one(); }
4、mapper配置
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.wanqi.mapper.VoteRecordMapper"> <select id="one" resultType="com.wanqi.pojo.VoteRecord"> select id, user_id as userId, vote_num as voteNum, group_id as groupId, status, create_time as createTime from vote_record </select> </mapper>
5、servlce層
package com.wanqi.service; import com.github.pagehelper.PageHelper; import com.wanqi.handler.VoteRecordHandler; import com.wanqi.mapper.VoteRecordMapper; import com.wanqi.pojo.VoteRecord; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; /** * @Description TODO * @Version 1.0.0 * @Date 2022/9/12 * @Author wandaren */ @Service public class VoteRecordService { @Autowired private VoteRecordMapper voteRecordMapper; public void one(){ PageHelper.startPage(1, 50000); List<VoteRecord> list = voteRecordMapper.one(); PageInfo<VoteRecord> pageInfo = new PageInfo<>(list); System.out.println("getTotal: "+pageInfo.getTotal()); System.out.println("getPages: "+pageInfo.getPages()); System.out.println("getPageNum: "+pageInfo.getPageNum()); System.out.println("getPageSize: "+pageInfo.getPageSize()); System.out.println("getEndRow: "+pageInfo.getEndRow()); } }
到此這篇關(guān)于mybatis流式查詢與分頁插件的文章就介紹到這了,更多相關(guān)mybatis分頁插件內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
springboot項目配置logback-spring.xml實現(xiàn)按日期歸檔日志的方法
本文主要介紹了springboot項目配置logback-spring.xml實現(xiàn)按日期歸檔日志的方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2024-08-08mybatis中@Param注解總是報取不到參數(shù)問題及解決
這篇文章主要介紹了mybatis中@Param注解總是報取不到參數(shù)問題及解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-07-07springBoot不同module之間互相依賴的實現(xiàn)
本文主要介紹了springBoot不同module之間互相依賴的實現(xiàn),不同模塊之間的依賴通常是通過Maven或Gradle來管理的,下面就來介紹一下如何實現(xiàn),感興趣的可以了解一下2024-08-08通過Spring Boot配置動態(tài)數(shù)據(jù)源訪問多個數(shù)據(jù)庫的實現(xiàn)代碼
這篇文章主要介紹了通過Spring Boot配置動態(tài)數(shù)據(jù)源訪問多個數(shù)據(jù)庫的實現(xiàn)代碼,需要的朋友可以參考下2018-03-03SpringBoot實現(xiàn)定時發(fā)送郵件的三種方法案例詳解
這篇文章主要介紹了SpringBoot三種方法實現(xiàn)定時發(fā)送郵件的案例,Spring框架的定時任務(wù)調(diào)度功能支持配置和注解兩種方式Spring?Boot在Spring框架的基礎(chǔ)上實現(xiàn)了繼承,并對其中基于注解方式的定時任務(wù)實現(xiàn)了非常好的支持,本文給大家詳細講解,需要的朋友可以參考下2023-03-03