百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

【Java面试】MyBatis是如何进行分页的?

wptr33 2024-12-10 21:22 21 浏览

基于 SQL 语句的分页方式

使用数据库原生的 SQL 语句:不同的数据库有自己的分页查询语法。例如,在 MySQL 中,可以使用LIMIT关键字进行分页。假设我们有一个用户表users,要查询第pageNo页,每页显示pageSize条记录,查询语句可以写成SELECT * FROM users LIMIT (pageNo - 1) * pageSize, pageSize。在 MyBatis 的mapper.xml文件中,定义如下查询方法:

<select id="selectUsersByPage" resultMap="UserResultMap">
    SELECT * FROM users LIMIT #{offset}, #{limit}
</select>

其中#{offset}和#{limit}是传入的参数,分别代表偏移量((pageNo - 1) * pageSize)和每页显示的记录数。在对应的 Java 接口方法中,传入正确的参数值即可实现分页查询。这种方式简单直接,性能较好,但缺点是不同数据库的分页语法不同,当数据库切换时,需要修改 SQL 语句。

  • 使用数据库存储过程进行分页:对于一些复杂的分页场景,或者为了提高性能,可以使用存储过程来实现分页。以 Oracle 数据库为例,可以创建一个存储过程来接受页码和每页记录数作为参数,然后在存储过程内部进行分页查询。在 MyBatis 中,可以通过{call procedure_name(#{param1}, #{param2})}的方式调用存储过程进行分页。不过使用存储过程会增加数据库的维护成本,并且不同数据库的存储过程语法差异较大。

使用 MyBatis 插件实现分页

  • 原理:MyBatis 插件是一种拦截机制,可以在 MyBatis 执行 SQL 语句的过程中进行拦截和修改。对于分页插件,它通常会拦截Executor的query方法,在查询之前对 SQL 语句进行修改,添加分页相关的语法,然后再执行修改后的 SQL 语句。
  • 常见的分页插件(以 PageHelper 为例):
  • 配置插件:首先在项目的依赖中添加PageHelper的依赖,然后在 MyBatis 的配置文件(mybatis - config.xml)中进行插件配置,如下所示:
<plugins>
    <plugin interceptor="com.github.pagehelper.PageInterceptor">
        <property name="helperDialect" value="mysql"/>
        <property name="reasonable" value="true"/>
    </plugin>
</plugins>

这里配置了PageInterceptor作为分页插件,并且指定了数据库方言(如mysql)和一些其他属性(如reasonable表示是否开启合理化分页,当页码小于 1 或超过最大页码时进行修正)。

  • 使用插件进行分页:在业务代码中,使用非常方便。例如,在一个服务类中,查询用户列表并分页:
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class UserService {
    private UserMapper userMapper;
    public PageInfo<User> getUsersByPage(int pageNo, int pageSize) {
        // 开启分页
        PageHelper.startPage(pageNo, pageSize);
        List<User> userList = userMapper.selectUsers();
        return new PageInfo<>(userList);
    }
}

在这个例子中,通过PageHelper.startPage(pageNo, pageSize)开启分页,然后执行查询操作,PageHelper会自动拦截查询语句并添加分页语法,最后将查询结果封装到PageInfo对象中,PageInfo对象包含了分页相关的信息,如总记录数、总页数、当前页码等。

自定义拦截器实现分页

  • 拦截器实现步骤实现Interceptor接口:创建一个自定义的拦截器类,实现org.apache.ibatis.plugin.Interceptor接口。这个接口有三个方法需要实现,分别是intercept、plugin和setProperties。在intercept方法中,实现对 SQL 语句的拦截和修改逻辑,用于添加分页语法。
  • 示例代码
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Signature;
import org.apache.ibatis.session.ResultHandler;
import org.apache.ibatis.session.RowBounds;

import java.util.Properties;

@Intercepts({
        @Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class})
})
public class CustomPaginationInterceptor implements Interceptor {

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        // 获取原始的参数
        Object[] args = invocation.getArgs();
        MappedStatement mappedStatement = (MappedStatement) args[0];
        Object parameter = args[1];
        RowBounds rowBounds = (RowBounds) args[2];
        ResultHandler resultHandler = (ResultHandler) args[3];

        // 判断是否是查询操作并且有分页参数
        if (rowBounds!= RowBounds.DEFAULT &&!rowBounds.equals(RowBounds.NO_ROW_LIMIT)) {
            // 获取原始的 BoundSql
            BoundSql boundSql = mappedStatement.getBoundSql(parameter);
            String originalSql = boundSql.getSql();

            // 计算偏移量和每页条数
            int offset = rowBounds.getOffset();
            int limit = rowBounds.getLimit();

            // 根据数据库类型构造分页 SQL
            String databaseType = mappedStatement.getConfiguration().getDatabaseId();
            String paginatedSql;
            if ("mysql".equalsIgnoreCase(databaseType)) {
                paginatedSql = originalSql + " LIMIT " + offset + "," + limit;
            } else {
                // 其他数据库可以根据情况进行处理
                paginatedSql = originalSql;
            }

            // 创建新的 BoundSql 对象
            BoundSql newBoundSql = new BoundSql(mappedStatement.getConfiguration(), paginatedSql, boundSql.getParameterMappings(), parameter);

            // 创建新的 MappedStatement 对象
            MappedStatement newMappedStatement = new MappedStatement.Builder(mappedStatement.getConfiguration(), mappedStatement.getId(), newBoundSql, mappedStatement.getSqlCommandType()).build();

            // 修改参数中的 MappedStatement
            args[0] = newMappedStatement;
        }

        // 执行原始的查询方法
        return invocation.proceed();
    }

    @Override
    public Object plugin(Object target) {
        return Interceptor.super.plugin(target);
    }

    @Override
    public void setProperties(Properties properties) {
        Interceptor.super.setProperties(properties);
    }
}


上述代码中,CustomPaginationInterceptor实现了Interceptor接口,在intercept方法中,首先获取传入的参数,判断是否有分页参数,如果有,则根据数据库类型构造分页 SQL,然后创建新的BoundSql和MappedStatement对象,最后修改参数并执行原始的查询方法。

  • 配置拦截器:和配置分页插件类似,在 MyBatis 的配置文件(mybatis - config.xml)中添加自定义拦截器的配置,让 MyBatis 能够识别并加载拦截器。
<plugins>
    <plugin interceptor="com.yourpackage.CustomPaginationInterceptor"/>
</plugins>

使用 RowBounds 实现逻辑分页

  • RowBounds 原理:RowBounds是 MyBatis 提供的一种逻辑分页方式。它通过在查询时限制返回的结果集范围来实现分页效果。在底层,MyBatis 会根据RowBounds参数从数据库中查询所有符合条件的记录,然后在内存中对结果集进行截取,只返回指定范围内的记录。例如,设置RowBounds为从第 10 条记录开始,取 20 条记录,MyBatis 会先查询出所有符合条件的记录,然后在内存中选取第 10 到第 29 条记录返回。
  • 适用场景
  • 数据量较小的情况:当查询的数据量相对较小,且不会对内存造成较大压力时,RowBounds是一种简单有效的分页方式。例如,对于一些配置表或者小型数据集的查询,使用RowBounds可以快速实现分页功能,而不需要复杂的 SQL 语句修改或者插件配置。
  • 不依赖数据库特性的场景:如果应用需要在不同的数据库环境中运行,且不想使用数据库特定的分页语法,RowBounds是一个不错的选择。因为它是基于 MyBatis 内部的逻辑实现分页,不依赖于像 MySQL 的LIMIT或者 Oracle 的ROWNUM等数据库特有的分页功能,这样可以提高代码在不同数据库之间的移植性。
  • 快速原型开发和简单应用场景:在开发初期或者一些对分页功能要求不高的简单应用中,RowBounds可以快速实现分页效果。开发人员可以先使用RowBounds实现基本的分页功能,随着应用的发展和对性能要求的提高,再考虑切换到更高效的分页方式,如基于 SQL 语句或者分页插件的方式。
  • 使用示例:在 Java 代码中,可以在调用 MyBatis 的Mapper方法时传入RowBounds对象来实现分页。例如:
import org.apache.ibatis.session.RowBounds;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class UserService {
    private UserMapper userMapper;
    public List<User> getUsersByPage(int pageNo, int pageSize) {
        int offset = (pageNo - 1) * pageSize;
        RowBounds rowBounds = new RowBounds(offset, pageSize);
        return userMapper.selectUsers(rowBounds);
    }
}

在这个例子中,首先根据页码和每页记录数计算出偏移量,然后创建RowBounds对象并传入Mapper方法。在Mapper接口中,定义方法如下:

List<User> selectUsers(RowBounds rowBounds);

MyBatis 会在执行这个方法时,根据传入的RowBounds参数进行逻辑分页。这种方式的优点是简单易用,不需要修改 SQL 语句,也不需要依赖数据库的特定分页语法。但是,当查询的数据量非常大时,将所有符合条件的记录都查询出来再在内存中进行截取会消耗大量内存,性能可能会受到很大影响。

相关推荐

MySQL进阶五之自动读写分离mysql-proxy

自动读写分离目前,大量现网用户的业务场景中存在读多写少、业务负载无法预测等情况,在有大量读请求的应用场景下,单个实例可能无法承受读取压力,甚至会对业务产生影响。为了实现读取能力的弹性扩展,分担数据库压...

Postgres vs MySQL_vs2022连接mysql数据库

...

3分钟短文 | Laravel SQL筛选两个日期之间的记录,怎么写?

引言今天说一个细分的需求,在模型中,或者使用laravel提供的EloquentORM功能,构造查询语句时,返回位于两个指定的日期之间的条目。应该怎么写?本文通过几个例子,为大家梳理一下。学习时...

一文由浅入深带你完全掌握MySQL的锁机制原理与应用

本文将跟大家聊聊InnoDB的锁。本文比较长,包括一条SQL是如何加锁的,一些加锁规则、如何分析和解决死锁问题等内容,建议耐心读完,肯定对大家有帮助的。为什么需要加锁呢?...

验证Mysql中联合索引的最左匹配原则

后端面试中一定是必问mysql的,在以往的面试中好几个面试官都反馈我Mysql基础不行,今天来着重复习一下自己的弱点知识。在Mysql调优中索引优化又是非常重要的方法,不管公司的大小只要后端项目中用到...

MySQL索引解析(联合索引/最左前缀/覆盖索引/索引下推)

目录1.索引基础...

你会看 MySQL 的执行计划(EXPLAIN)吗?

SQL执行太慢怎么办?我们通常会使用EXPLAIN命令来查看SQL的执行计划,然后根据执行计划找出问题所在并进行优化。用法简介...

MySQL 从入门到精通(四)之索引结构

索引概述索引(index),是帮助MySQL高效获取数据的数据结构(有序),在数据之外,数据库系统还维护者满足特定查询算法的数据结构,这些数据结构以某种方式引用(指向)数据,这样就可以在这些数据结构...

mysql总结——面试中最常问到的知识点

mysql作为开源数据库中的榜一大哥,一直是面试官们考察的重中之重。今天,我们来总结一下mysql的知识点,供大家复习参照,看完这些知识点,再加上一些边角细节,基本上能够应付大多mysql相关面试了(...

mysql总结——面试中最常问到的知识点(2)

首先我们回顾一下上篇内容,主要复习了索引,事务,锁,以及SQL优化的工具。本篇文章接着写后面的内容。性能优化索引优化,SQL中索引的相关优化主要有以下几个方面:最好是全匹配。如果是联合索引的话,遵循最...

MySQL基础全知全解!超详细无废话!轻松上手~

本期内容提醒:全篇2300+字,篇幅较长,可搭配饭菜一同“食”用,全篇无废话(除了这句),干货满满,可收藏供后期反复观看。注:MySQL中语法不区分大小写,本篇中...

深入剖析 MySQL 中的锁机制原理_mysql 锁详解

在互联网软件开发领域,MySQL作为一款广泛应用的关系型数据库管理系统,其锁机制在保障数据一致性和实现并发控制方面扮演着举足轻重的角色。对于互联网软件开发人员而言,深入理解MySQL的锁机制原理...

Java 与 MySQL 性能优化:MySQL分区表设计与性能优化全解析

引言在数据库管理领域,随着数据量的不断增长,如何高效地管理和操作数据成为了一个关键问题。MySQL分区表作为一种有效的数据管理技术,能够将大型表划分为多个更小、更易管理的分区,从而提升数据库的性能和可...

MySQL基础篇:DQL数据查询操作_mysql 查

一、基础查询DQL基础查询语法SELECT字段列表FROM表名列表WHERE条件列表GROUPBY分组字段列表HAVING分组后条件列表ORDERBY排序字段列表LIMIT...

MySql:索引的基本使用_mysql索引的使用和原理

一、索引基础概念1.什么是索引?索引是数据库表的特殊数据结构(通常是B+树),用于...