• java后端分页的多种操作你必须要知道

    为什么要使用分页？我们服务器的数据jvm内存有限制，数据不能全部返回，必须采用分页或者拆分的方式进行分页这样不仅仅提高搜索和查询的效率，也能够减少前后端的带宽传输。

    1，原生的jdbc分页

    原生的分页通过获取jdbc连接然后通过sql预处理传入分页参数获取分页参数，其实也是用了limit 函数分页

    2，集合分页。

    集合分页常用的几种方式：

    截取数据     

    List subList(int fromIndex, int toIndex);

    下标获取数据：list.get(i);获取起始位置下标去读取数据

                                    

    java8函数分页：

    1. list.stream().skip((i - 1) * sheetSize).limit(sheetSize).   collect(Collectors.toList());
    2. List     newList2 =   newList.stream().skip(( 1-1)* 2).limit(2).collect(Collectors.toList());
    3. List     newList3 =   newList.stream().skip(( 2 -1)*2).limit(2).collect(Collectors.toList());
    4. List     newList4=   newList.stream().skip(( 3 -1)*2).limit(2).collect(Collectors.toList());

    3，pagehelper分页

    第一种：springboot引入包的方式：


        com.github.pagehelper
        pagehelper-spring-boot-starter
        ${pagehelper.version}


    第二种：直接引入包的方式：

    
      com.github.pagehelper
      pagehelper
      5.2.0

    配置文件：

    1. #pagehelper分页助手
    2. pagehelper:
    3.   helperDialect: mysql
    4.   reasonable: false
    5.   supportMethodsArguments: true
    6.   params: count=countSql
    1.      PageHelper.startPage(pageNum,pageSize);
    2.         List list = studentService.findAllStudent();
    3.         PageInfo pageInfo = PageInfo.of(list);

     

    4，mybateisplus 内置分页。

    1.     @ApiOperation(value = "vin查询")
    2.     @PostMapping("/chagreVinSearch")
    3.     public ResultMsg chagreVinSearch(@RequestBody ChagerVinDto chagerVinDto) {
    4.         return  chagreVinService.chagreVinSearch(chagerVinDto);
    5.     }
    1.  
    2.  
    3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
    4. import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
    5. import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
    6. import com.baomidou.mybatisplus.core.metadata.IPage;
    7. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
    8. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
    9.  
    10.  
    11. import lombok.extern.slf4j.Slf4j;
    12. import org.apache.commons.lang3.StringUtils;
    13. import org.springframework.beans.factory.annotation.Autowired;
    14. import org.springframework.stereotype.Service;
    15. import org.springframework.web.multipart.MultipartFile;
    16.  
    17. import java.sql.SQLException;
    18. import java.sql.Wrapper;
    19. import java.time.LocalDateTime;
    20. import java.util.List;
    21. import java.util.stream.Collectors;
    22.  
    23. /**
    24.  * @author liuhan
    25.  * @version 1.0
    26.  * @description: TODO
    27.  * @date 2022/7/27 10:34
    28.  */
    29. @Service
    30. @Slf4j
    31. public class ChagreVinServiceImpl extends ServiceImpl implements ChagreVinService {
    32.  
    33.     @Autowired
    34.     TcChargerFilterMapper tcChargerFilterMapper;
    35.  
    36.     @Override
    37.     public ResultMsg chagreVinSearch(ChagerVinDto chagerVinDto) {
    38.  
    39.         //分页参数
    40.         Page page = Page.of(chagerVinDto.getPageNum(),chagerVinDto.getPageSize());
    41.         //queryWrapper组装查询where条件
    42.         LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
    43.         if(StringUtils.isNotBlank(chagerVinDto.getPlateNo())){
    44.             queryWrapper.like(TcChargerFilterVO::getPlateNo,chagerVinDto.getPlateNo());
    45.         }
    46.         if(StringUtils.isNotBlank(chagerVinDto.getVin())){
    47.             queryWrapper.eq(TcChargerFilterVO::getVin,chagerVinDto.getVin());
    48.         }
    49.         IPage  tcChargerFilterVOIPage = tcChargerFilterMapper.selectPage(page,queryWrapper);
    50.         ChagerVinDto resultDto = new ChagerVinDto();
    51.         resultDto.setResult(tcChargerFilterVOIPage.getRecords());
    52.         resultDto.setTotal(tcChargerFilterVOIPage.getTotal());
    53.         return  ResultMsg.ok(resultDto);
    54.     }
    55.  
    56.  
    57. }
    1.  
    2. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    3.  
    4. import org.apache.ibatis.annotations.Mapper;
    5.  
    6. import java.util.List;
    7.  
    8. @Mapper
    9. public interface TcChargerFilterMapper extends BaseMapper {
    10.  
    11.  
    12.  
    13.  
    14. }
    1.  
    2. import java.io.Serializable;
    3. import java.time.LocalDateTime;
    4. import java.util.Date;
    5.  
    6. import com.alibaba.excel.annotation.ExcelProperty;
    7. import com.baomidou.mybatisplus.annotation.TableName;
    8. import lombok.Data;
    9.  
    10. /**
    11.  * tc_charger_filter
    12.  * @author
    13.  */
    14. @Data
    15. @TableName("tc_charger_filter")
    16. public class TcChargerFilterVO extends BaseEntity implements Serializable {
    17.     /**
    18.      * 主键id
    19.      */
    20.     private Integer id;
    21.  
    22.     /**
    23.      * vin码
    24.      */
    25.     @ExcelProperty(value = {"vin"},order = 1)
    26.     private String vin;
    27.  
    28.     /**
    29.      * 车牌号
    30.      */
    31.     @ExcelProperty(value = {"车牌号"},order = 2)
    32.     private String plateNo;
    33.  
    34.  
    35.  
    36.  
    37.     /**
    38.      * 创建人
    39.      */
    40.     private String createBy;
    41.  
    42.     /**
    43.      * 创建时间
    44.      */
    45.     private LocalDateTime createTime;
    46.  
    47.     /**
    48.      * 更新人
    49.      */
    50.     private String updateBy;
    51.  
    52.     /**
    53.      * 更新时间
    54.      */
    55.     private LocalDateTime updateTime;
    56.  
    57.  
    58.  
    59.  
    60. }

    1.  
    2. import org.springframework.web.multipart.MultipartFile;
    3.  
    4. /**
    5.  * 
    6.  *
    7.  * @author yangchang
    8.  * @since 2022-09-05
    9.  */
    10. public interface ChagreVinService {
    11.  
    12.     ResultMsg chagreVinSearch(ChagerVinDto chagerVinDto);
    13.  
    14. }

    5，SpringDataJPA 分页

    1.         resultPage = template.queryForPage(searchQuery, ManualEngDirEntity.class, searchResultMapper);
    2.             // 获取集合数据
    3.          content = resultPage.getContent();
    4.         
    5.         MapperFactory mapperFactory = new DefaultMapperFactory.Builder().build();
    6.         List directoryDtoList = mapperFactory.getMapperFacade().mapAsList(content, DirectoryDto.class);
    1. @Query("select u from User u")
    2. Page findALL(Pageable pageable);

    6，Spring JdbcTemplate 分页

    1.  public Result getTrafficEventinfoList(RafficEventinfoDto rafficEventinfoDto) {
    2.         Object[] args = new Object[1];
    3.         Integer page = rafficEventinfoDto.getPageNum();
    4.         Integer pageSize = rafficEventinfoDto.getPageSize();
    5.         StringBuffer sbdata = new StringBuffer();
    6.         StringBuffer sbCount = new StringBuffer();
    7.         String sqlCount = "select count(1) from TRAFFIC_EVENTINFO where";
    8.         sbdata.append("select ee.* from (select e.*,rownum rowno from (select * from TRAFFIC_EVENTINFO  where ");
    9.         sbCount.append(sqlCount);
    10.         if (rafficEventinfoDto.getPlateNo() != null) {
    11.             sbdata.append(" PLATENO=?  ");
    12.             sbCount.append(" PLATENO=?  ");
    13.             args[0] = rafficEventinfoDto.getPlateNo();
    14.         }
    15.  
    16.         sbdata.append(" ) e ) ee where ee.rowno >=" + (((page <= 0 ? 1 : page) - 1) * pageSize + 1) + " and ee.rowno <=" + (page <= 0 ? 1 : page) * pageSize);
    17.         Integer total = (Integer)this.jdbc.queryForObject(sbCount.toString(), args, Integer.class);
    18.         if (total == 0) {
    19.             return Result.ok((Object)null);
    20.         } else {
    21.             List list = this.jdbc.query(sbdata.toString(), args, new TrafficEventinfoResultRowMapper());
    22.             PageInfo pageInfo = new PageInfo(list);
    23.             RafficEventinfoDto resultDto = new RafficEventinfoDto();
    24.             resultDto.setTotal(total);
    25.             resultDto.setResultList(pageInfo.getList());
    26.             return Result.ok(resultDto);
    27.         }
    28.     }

    mapper层：

    1.  
    2. import org.slf4j.Logger;
    3. import org.slf4j.LoggerFactory;
    4. import org.springframework.jdbc.core.RowMapper;
    5.  
    6. import java.lang.reflect.Field;
    7. import java.lang.reflect.InvocationTargetException;
    8. import java.sql.ResultSet;
    9. import java.sql.SQLException;
    10.  
    11. /**
    12.  * @ClassName:  TrafficEventinfoResultRowMapper
    13.  * @Description: TrafficEventinfoResult
    14.  * @author:  yangchang
    15.  * @date:   2021/12/23
    16.  */
    17.  
    18. public class TrafficEventinfoResultRowMapper extends BaseSqlColumn implements RowMapper{
    19.  
    20. 	public TrafficEventinfoResult mapRow(ResultSet rs,int rowNum) throws SQLException {
    21. 		try {
    22. 			TrafficEventinfoResult suspicionResult = new TrafficEventinfoResult();
    23. 			TrafficEventinfoResult result =mapEntityProperties(rs,rowNum,suspicionResult);
    24. 			return result;
    25. 		}catch (Exception e){
    26. 			e.printStackTrace();
    27. 		}
    28. 		return null;
    29.  
    30. 	}
    31.  
    32.  
    33. }

    base转换：

    1.  
    2.  
    3. import org.slf4j.Logger;
    4. import org.slf4j.LoggerFactory;
    5.  
    6. import java.lang.reflect.Field;
    7. import java.lang.reflect.InvocationTargetException;
    8. import java.sql.ResultSet;
    9. import java.sql.SQLException;
    10.  
    11. /**
    12.  * 
    13.  *
    14.  * @author xpwi
    15.  * @since 2021-12-24
    16.  */
    17. public class BaseSqlColumn {
    18.     private static final Logger log = LoggerFactory.getLogger(BaseSqlColumn.class);
    19.  
    20.     /**
    21.      * 对象参数实现
    22.      * @param rs
    23.      * @param rowNum
    24.      * @param object
    25.      * @param 
    26.      * @return
    27.      * @throws SQLException
    28.      */
    29.     protected  T mapEntityProperties(ResultSet rs, int rowNum, T object) throws SQLException {
    30.         T t =  (T) object;
    31.         Field[]  fields= object.getClass().getDeclaredFields();
    32.         try {
    33.             for (int i = 0; i < fields.length; i++) {
    34.                 String name = fields[i].getName();//获取属性名
    35.                 Object o = null;
    36.                 // 通过字段名称获取该字段的值（实体字段名称必须与数据库字段名称一致才可以）
    37.                 if ("serialVersionUID".equals(name)) {
    38.                     continue;
    39.                 }
    40.                 if (isExistColumn(rs, name)) {
    41.                     o = rs.getObject(name);
    42.                 }
    43.                 if (o == null) {
    44.                     continue;
    45.                 }
    46.                 // 使用BeanUtils通过字段名将value设置到实体中  
    47.                 try {
    48.                     MyBeanUtils.setProperty(t, name, o);
    49.                 } catch (IllegalAccessException e) {
    50.                     e.printStackTrace();
    51.                     log.error("类型转换错误"+e);
    52.                 } catch (InvocationTargetException e) {
    53.                     e.printStackTrace();
    54.                   log.error("类型转换错误"+e);
    55.                 }
    56.  
    57.             }
    58.             return t;
    59.         } catch (Exception e) {
    60.             log.error("其他异常"+e);
    61.         }
    62.         return null;
    63.     }
    64.  
    65.  
    66.     /**
    67.      * 判断查询结果集中是否存在某列
    68.      *
    69.      * @param rs         查询结果集
    70.      * @param columnName 列名
    71.      * @return true 存在; false 不存在
    72.      */
    73.     protected boolean isExistColumn(ResultSet rs, String columnName) {
    74.         try {
    75.             if (rs.findColumn(columnName) > 0) {
    76.                 return true;
    77.             }
    78.         } catch (SQLException e) {
    79.             return false;
    80.         }
    81.  
    82.         return false;
    83.     }
    84. }

    当然还有很多种分页，第三方工具分页，其实底层都是走的是limit分页，比如我们的pagehepler,mybateisplus ,还有mybateis 分页，jpa都是一致的。

  • 相关阅读:
    Linux 部署Neo4j 并且创建自定义Service
    java实现幂等性校验
    搞透 IOC，Spring IOC 看这篇就够了！
    pytorch自定义图像分类项目的训练+OpenCV部署实战案例
    交通 | python网络爬虫：“多线程并行 + 多线程异步协程
    重新思考边缘负载均衡
    JAVA【设计模式】命令模式
    数据结构——二叉树
    用C语言随机读写二进制文件
    数据结构 | 单链表专题【详解】
  • 原文地址：https://blog.csdn.net/qq_39751120/article/details/126752950