MyBatis实现物理分页的实例

 MyBatis使用RowBounds实现的分页是逻辑分页,也就是先把数据记录全部查询出来,然在再根据offset和limit截断记录返回

为了在数据库层面上实现物理分页,又不改变原来MyBatis的函数逻辑,可以编写plugin截获MyBatis Executor的statementhandler,重写SQL来执行查询

下面的插件代码只针对MySQL

plugin代码

package plugin;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

import org.apache.ibatis.executor.parameter.ParameterHandler;
import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.logging.Log;
import org.apache.ibatis.logging.LogFactory;
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.Plugin;
import org.apache.ibatis.plugin.Signature;
import org.apache.ibatis.reflection.MetaObject;
import org.apache.ibatis.reflection.factory.DefaultObjectFactory;
import org.apache.ibatis.reflection.factory.ObjectFactory;
import org.apache.ibatis.reflection.wrapper.DefaultObjectWrapperFactory;
import org.apache.ibatis.reflection.wrapper.ObjectWrapperFactory;
import org.apache.ibatis.scripting.defaults.DefaultParameterHandler;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.RowBounds;

/**
 * 通过拦截<code>StatementHandler</code>的<code>prepare</code>方法，重写sql语句实现物理分页。
 * 老规矩，签名里要拦截的类型只能是接口。
 *
 */
@Intercepts({@Signature(type = StatementHandler.class, method = "prepare", args = {Connection.class})})
public class PaginationInterceptor implements Interceptor {
  private static final Log logger = LogFactory.getLog(PaginationInterceptor.class);
  private static final ObjectFactory DEFAULT_OBJECT_FACTORY = new DefaultObjectFactory();
  private static final ObjectWrapperFactory DEFAULT_OBJECT_WRAPPER_FACTORY = new DefaultObjectWrapperFactory();
  private static String DEFAULT_PAGE_SQL_ID = ".*Page$"; // 需要拦截的ID(正则匹配)

  @Override
  public Object intercept(Invocation invocation) throws Throwable {
    StatementHandler statementHandler = (StatementHandler) invocation.getTarget();
    MetaObject metaStatementHandler = MetaObject.forObject(statementHandler, DEFAULT_OBJECT_FACTORY,
        DEFAULT_OBJECT_WRAPPER_FACTORY);
    RowBounds rowBounds = (RowBounds) metaStatementHandler.getValue("delegate.rowBounds");
    // 分离代理对象链(由于目标类可能被多个拦截器拦截，从而形成多次代理，通过下面的两次循环可以分离出最原始的的目标类)
    while (metaStatementHandler.hasGetter("h")) {
      Object object = metaStatementHandler.getValue("h");
      metaStatementHandler = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY);
    }
    // 分离最后一个代理对象的目标类
    while (metaStatementHandler.hasGetter("target")) {
      Object object = metaStatementHandler.getValue("target");
      metaStatementHandler = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY);
    }

    // property在mybatis settings文件内配置
    Configuration configuration = (Configuration) metaStatementHandler.getValue("delegate.configuration");

    // 设置pageSqlId
    String pageSqlId = configuration.getVariables().getProperty("pageSqlId");
    if (null == pageSqlId || "".equals(pageSqlId)) {
      logger.warn("Property pageSqlId is not setted,use default '.*Page$' ");
      pageSqlId = DEFAULT_PAGE_SQL_ID;
    }

    MappedStatement mappedStatement = (MappedStatement)
        metaStatementHandler.getValue("delegate.mappedStatement");
    // 只重写需要分页的sql语句。通过MappedStatement的ID匹配，默认重写以Page结尾的MappedStatement的sql
    if (mappedStatement.getId().matches(pageSqlId)) {
      BoundSql boundSql = (BoundSql) metaStatementHandler.getValue("delegate.boundSql");
      Object parameterObject = boundSql.getParameterObject();
      if (parameterObject == null) {
        throw new NullPointerException("parameterObject is null!");
      } else {
        String sql = boundSql.getSql();
        // 重写sql
        String pageSql = sql + " LIMIT " + rowBounds.getOffset() + "," + rowBounds.getLimit();
        metaStatementHandler.setValue("delegate.boundSql.sql", pageSql);
        // 采用物理分页后，就不需要mybatis的内存分页了，所以重置下面的两个参数
        metaStatementHandler.setValue("delegate.rowBounds.offset", RowBounds.NO_ROW_OFFSET);
        metaStatementHandler.setValue("delegate.rowBounds.limit", RowBounds.NO_ROW_LIMIT);
      }
    }
    // 将执行权交给下一个拦截器
    return invocation.proceed();
  }

  @Override
  public Object plugin(Object target) {
    // 当目标类是StatementHandler类型时，才包装目标类，否者直接返回目标本身,减少目标被代理的次数
    if (target instanceof StatementHandler) {
      return Plugin.wrap(target, this);
    } else {
      return target;
    }
  }

  @Override
  public void setProperties(Properties properties) {
    //To change body of implemented methods use File | Settings | File Templates.
  }

}

配置plugin

  <plugins>
    <plugin interceptor="plugin.PaginationInterceptor" />
  </plugins>

查询SQL

  <!-- 测试分页查询 -->
  <select id="selectUserByPage" resultMap="dao.base.userResultMap">
    <![CDATA[
    SELECT * FROM user
    ]]>
  </select>

调用示例

  @Override
  public List<User> selectUserByPage(int offset, int limit) {
    RowBounds rowBounds = new RowBounds(offset, limit);
    return getSqlSession().selectList("dao.userdao.selectUserByPage", new Object(), rowBounds);
  }

另外,结合Spring MVC,编写翻页和生成页码代码

页码类

package util;

/**
 * Created with IntelliJ IDEA.
 * User: zhenwei.liu
 * Date: 13-8-7
 * Time: 上午10:29
 * To change this template use File | Settings | File Templates.
 */
public class Pagination {
  private String url; // 页码url
  private int pageSize = 10; // 每页显示记录数
  private int currentPage = 1;  // 当前页码
  private int maxPage = Integer.MAX_VALUE;  // 最大页数

  // 获取offset
  public int getOffset() {
    return (currentPage - 1) * pageSize;
  }

  // 获取limit
  public int getLimit() {
    return getPageSize();
  }

  public String getUrl() {
    return url;
  }

  public void setUrl(String url) {
    this.url = url;
  }

  public int getPageSize() {
    return pageSize;
  }

  public void setPageSize(int pageSize) {
    this.pageSize = pageSize;
  }

  public int getCurrentPage() {
    return currentPage;
  }

  public void setCurrentPage(int currentPage) {
    if (currentPage < 1)
      currentPage = 1;
    if (currentPage > maxPage)
      currentPage = maxPage;
    this.currentPage = currentPage;
  }

  public int getMaxPage() {
    return maxPage;
  }

  public void setMaxPage(int maxPage) {
    this.maxPage = maxPage;
  }
}

为了计算最大页码,需要知道数据表的总记录数,查询SQL如下

  <!-- 记录总数 -->
  <select id="countUser" resultType="Integer">
    <![CDATA[
    SELECT COUNT(*) FROM user
    ]]>
  </select>

 @Override
  public Integer countTable() {
    return getSqlSession().selectOne("dao.userdao.countUser");
  }

Controller中的使用

  @RequestMapping("/getUserByPage")
  public String getUserByPage(@RequestParam
                  int page, Model model) {
    pagination.setCurrentPage(page);
    pagination.setUrl(getCurrentUrl());
    pagination.setMaxPage(userDao.countTable() / pagination.getPageSize() + 1);
    List<User> userList = userDao.selectUserByPage(
        pagination.getOffset(), pagination.getLimit());
    model.addAttribute(pagination);
    model.addAttribute(userList);
    return "index";
  }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# mybatis物理分页  # mybatis  # 分页  # Java简单实现SpringMVC+MyBatis分页插件  # Java的MyBatis框架中实现多表连接查询和查询结果分页  # Mybatis实现增删改查及分页查询的方法  # Mybatis分页插件PageHelper的使用详解  # Mybatis常用分页插件实现快速分页处理技巧  # 自己动手写的mybatis分页插件(极其简单好用)  # SpringMVC+MyBatis分页（最新）  # 详解Mybatis分页插件 - 示例代码  # SpringMvc+Mybatis+Pagehelper分页详解  # 详解Mybatis极其(最)简(好)单(用)的一个分页插件  # 重写  # 拦截器  # 多个  # 就不  # 两次  # 每页  # 又不  # 先把  # 翻页  # 大家多多  # 最原始  # 上午  # 层面上  # private  # static  # implements  # PaginationInterceptor  # public  # DEFAULT_OBJECT_FACTORY 

相关文章： 宠物网站制作html代码,有没有专门介绍宠物如何养的网站啊？  网站制作壁纸教程视频,电脑壁纸网站？  Swift中switch语句区间和元组模式匹配  怀化网站制作公司,怀化新生儿上户网上办理流程？  深圳网站制作公司好吗,在深圳找工作哪个网站最好啊？  大同网页,大同瑞慈医院官网？  已有域名和空间如何快速搭建网站？  如何通过VPS搭建网站快速盈利？  建站之星代理商如何保障技术支持与售后服务？  利用JavaScript实现拖拽改变元素大小  香港服务器如何优化才能显著提升网站加载速度？  Thinkphp 中 distinct 的用法解析  网站专业制作公司,网站编辑是做什么的？好做吗？工作前景如何？  javascript中对象的定义、使用以及对象和原型链操作小结  广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网？  如何在服务器上配置二级域名建站？  宝塔面板创建网站无法访问？如何快速排查修复？  北京制作网站的公司排名,北京三快科技有限公司是做什么？北京三快科技？  如何在腾讯云免费申请建站？  Android自定义listview布局实现上拉加载下拉刷新功能  ,柠檬视频怎样兑换vip？  寿县云建站：智能SEO优化与多行业模板快速上线指南  行程制作网站有哪些,第三方机票电子行程单怎么开？  如何在云主机上快速搭建网站？  网站网页制作电话怎么打,怎样安装和使用钉钉软件免费打电话？  网站建设制作需要多少钱费用,自己做一个网站要多少钱，模板一般多少钱？  北京的网站制作公司有哪些,哪个视频网站最好？  企业微网站怎么做,公司网站和公众号有什么区别？  打鱼网站制作软件,波克捕鱼官方号怎么注册？  子杰智能建站系统｜零代码开发与AI生成SEO优化指南  如何构建满足综合性能需求的优质建站方案？  单页制作网站有哪些,朋友给我发了一个单页网站，我应该怎么修改才能把他变成自己的呢，请求高手指点迷津？  如何在宝塔面板中修改默认建站目录？  ,如何利用word制作宣传手册？  电视网站制作tvbox接口,云海电视怎样自定义添加电视源？  C#怎么使用委托和事件 C# delegate与event编程方法  如何彻底删除建站之星生成的Banner？  如何在IIS中新建站点并解决端口绑定冲突？  建站OpenVZ教程与优化策略：配置指南与性能提升  如何快速搭建安全的FTP站点？  如何在企业微信快速生成手机电脑官网？  建站主机CVM配置优化、SEO策略与性能提升指南  如何通过虚拟主机快速搭建个人网站？  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  如何在阿里云服务器自主搭建网站？  网站制作企业,网站的banner和导航栏是指什么？  如何使用Golang table-driven基准测试_多组数据测量函数效率  广州美橙建站如何快速搭建多端合一网站？  活动邀请函制作网站有哪些,活动邀请函文案？  h5在线制作网站电脑版下载,h5网页制作软件？