Mybatis四种分页方式

1.数组分页

查询出全部数据,然后再list中截取需要的部分。

mybatis接口

List<Student> queryStudentsByArray();

xml配置文件

 <select id="queryStudentsByArray"  resultMap="studentmapper">select * from student</select>

service

接口
List<Student> queryStudentsByArray(int currPage, int pageSize);
实现接口@Overridepublic List<Student> queryStudentsByArray(int currPage, int pageSize) {//查询全部数据List<Student> students = studentMapper.queryStudentsByArray();//从第几条数据开始int firstIndex = (currPage - 1) * pageSize;//到第几条数据结束int lastIndex = currPage * pageSize;return students.subList(firstIndex, lastIndex); //直接在list中截取}

controller

    @ResponseBody@RequestMapping("/student/array/{currPage}/{pageSize}")public List<Student> getStudentByArray(@PathVariable("currPage") int currPage, @PathVariable("pageSize") int pageSize) {List<Student> student = StuServiceIml.queryStudentsByArray(currPage, pageSize);return student;}

2.sql分页

mybatis接口

List<Student> queryStudentsBySql(Map<String,Object> data);

xml文件

<select id="queryStudentsBySql" parameterType="map" resultMap="studentmapper">select * from student limit #{currIndex} , #{pageSize}
</select>

service

接口
List<Student> queryStudentsBySql(int currPage, int pageSize);
实现类
public List<Student> queryStudentsBySql(int currPage, int pageSize) {Map<String, Object> data = new HashedMap();data.put("currIndex", (currPage-1)*pageSize);data.put("pageSize", pageSize);return studentMapper.queryStudentsBySql(data);}

3.拦截器分页

创建拦截器,拦截mybatis接口方法id以ByPage结束的语句

package com.autumn.interceptor;
​
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.executor.parameter.ParameterHandler;
import org.apache.ibatis.executor.resultset.ResultSetHandler;
import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.*;
import org.apache.ibatis.reflection.MetaObject;
import org.apache.ibatis.reflection.SystemMetaObject;
​
import java.sql.Connection;
import java.util.Map;
import java.util.Properties;
​
/*** @Intercepts 说明是一个拦截器* @Signature 拦截器的签名* type 拦截的类型 四大对象之一( Executor,ResultSetHandler,ParameterHandler,StatementHandler)* method 拦截的方法* args 参数,高版本需要加个Integer.class参数,不然会报错*/
@Intercepts({@Signature(type = StatementHandler.class, method = "prepare", args = {Connection.class})})
public class MyPageInterceptor implements Interceptor {
​//每页显示的条目数private int pageSize;//当前现实的页数private int currPage;//数据库类型private String dbType;
​
​@Overridepublic Object intercept(Invocation invocation) throws Throwable {//获取StatementHandler,默认是RoutingStatementHandlerStatementHandler statementHandler = (StatementHandler) invocation.getTarget();//获取statementHandler包装类MetaObject MetaObjectHandler = SystemMetaObject.forObject(statementHandler);
​//分离代理对象链while (MetaObjectHandler.hasGetter("h")) {Object obj = MetaObjectHandler.getValue("h");MetaObjectHandler = SystemMetaObject.forObject(obj);}
​while (MetaObjectHandler.hasGetter("target")) {Object obj = MetaObjectHandler.getValue("target");MetaObjectHandler = SystemMetaObject.forObject(obj);}
​//获取连接对象//Connection connection = (Connection) invocation.getArgs()[0];
​
​//object.getValue("delegate");  获取StatementHandler的实现类
​//获取查询接口映射的相关信息MappedStatement mappedStatement = (MappedStatement) MetaObjectHandler.getValue("delegate.mappedStatement");String mapId = mappedStatement.getId();
​//statementHandler.getBoundSql().getParameterObject();
​//拦截以.ByPage结尾的请求,分页功能的统一实现if (mapId.matches(".+ByPage$")) {//获取进行数据库操作时管理参数的handlerParameterHandler parameterHandler = (ParameterHandler) MetaObjectHandler.getValue("delegate.parameterHandler");//获取请求时的参数Map<String, Object> paraObject = (Map<String, Object>) parameterHandler.getParameterObject();//也可以这样获取//paraObject = (Map<String, Object>) statementHandler.getBoundSql().getParameterObject();
​//参数名称和在service中设置到map中的名称一致currPage = (int) paraObject.get("currPage");pageSize = (int) paraObject.get("pageSize");
​String sql = (String) MetaObjectHandler.getValue("delegate.boundSql.sql");//也可以通过statementHandler直接获取//sql = statementHandler.getBoundSql().getSql();
​//构建分页功能的sql语句String limitSql;sql = sql.trim();limitSql = sql + " limit " + (currPage - 1) * pageSize + "," + pageSize;
​//将构建完成的分页sql语句赋值个体'delegate.boundSql.sql',偷天换日MetaObjectHandler.setValue("delegate.boundSql.sql", limitSql);}//调用原对象的方法,进入责任链的下一级return invocation.proceed();}
​
​//获取代理对象@Overridepublic Object plugin(Object o) {//生成object对象的动态代理对象return Plugin.wrap(o, this);}
​//设置代理对象的参数@Overridepublic void setProperties(Properties properties) {//如果项目中分页的pageSize是统一的,也可以在这里统一配置和获取,这样就不用每次请求都传递pageSize参数了。参数是在配置拦截器时配置的。String limit1 = properties.getProperty("limit", "10");this.pageSize = Integer.valueOf(limit1);this.dbType = properties.getProperty("dbType", "mysql");}
}

配置文件SqlMapConfig.xml

<configuration><plugins><plugin interceptor="com.autumn.interceptor.MyPageInterceptor"><property name="limit" value="10"/><property name="dbType" value="mysql"/></plugin></plugins></configuration>

mybatis配置

<!--接口-->
List<AccountExt> getAllBookByPage(@Param("currPage")Integer pageNo,@Param("pageSize")Integer pageSize);
<!--xml配置文件--><sql id="getAllBooksql" >acc.id, acc.cateCode, cate_name, user_id,u.name as user_name, money, remark, time</sql><select id="getAllBook" resultType="com.autumn.pojo.AccountExt" >select<include refid="getAllBooksql" />from account as acc</select>

service

    public List<AccountExt> getAllBookByPage(String pageNo,String pageSize) {return accountMapper.getAllBookByPage(Integer.parseInt(pageNo),Integer.parseInt(pageSize));}

controller

 @RequestMapping("/getAllBook")@ResponseBodypublic Page getAllBook(String pageNo,String pageSize,HttpServletRequest request,HttpServletResponse response){pageNo=pageNo==null?"1":pageNo;   //当前页码pageSize=pageSize==null?"5":pageSize;   //页面大小//获取当前页数据List<AccountExt> list = bookService.getAllBookByPage(pageNo,pageSize);//获取总数据大小int totals = bookService.getAllBook();//封装返回结果Page page = new Page();page.setTotal(totals+"");page.setRows(list);return page;}

Page实体类

package com.autumn.pojo;import java.util.List;/*** Created by Autumn on 2018/6/21.*/
public class Page {private String pageNo = null;private String pageSize = null;private String total = null;private List rows = null;public String getTotal() {return total;}public void setTotal(String total) {this.total = total;}public List getRows() {return rows;}public void setRows(List rows) {this.rows = rows;}public String getPageNo() {return pageNo;}public void setPageNo(String pageNo) {this.pageNo = pageNo;}public String getPageSize() {return pageSize;}public void setPageSize(String pageSize) {this.pageSize = pageSize;}}

拦截器分页插件

使用pageHelper插件分页、主要是通过mybatis拦截器实现的

导入pageHelper包
 

  <!--分页插件--><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper</artifactId><version>5.3.0</version></dependency><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper-spring-boot-autoconfigure</artifactId><version>1.4.1</version></dependency><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper-spring-boot-starter</artifactId><version>1.4.1</version></dependency>

配置文件中配置对应的属性

spring:datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/emp_dep?useUnicode=true&characterEncoding=UTF-8&useSSL=true&serverTimezone=UTCusername: rootpassword: rootpagehelper:#指定数据库的方言helper-dialect: mysql#分页合理化参数,默认值为false。当该参数设置为 true 时,#pageNum<=0 时会查询第一页, pageNum>pages(超过总数时),会查询最后一页。reasonable: true#支持通过 Mapper 接口参数来传递分页参数,默认值false,#分页插件会从查询方法的参数值中,自动根据上面 params 配置的字段中取值,查找到合适的值时就会自动分页support-methods-arguments: true#为了支持startPage(Object params)方法,增加了该参数来配置参数映射,用于从对象中根据属性名取值params: =count=countSql

配置完成之后,只需要在需要分页的service层代码,查询数据集合的上一行加一代码
开启分页 PageHelper.startPage(pageNo,pageSize);

4.RowBounds分页

数据量小时,RowBounds不失为一种好办法。但是数据量大时,实现拦截器就很有必要了。

mybatis接口加入RowBounds参数

public List<UserBean> queryUsersByPage(String userName, RowBounds rowBounds);

service

  @Override@Transactional(isolation = Isolation.READ_COMMITTED, propagation = Propagation.SUPPORTS)public List<RoleBean> queryRolesByPage(String roleName, int start, int limit) {return roleDao.queryRolesByPage(roleName, new RowBounds(start, limit));}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/438247.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

第十节:利用async和await简化异步编程模式的几种写法

一. async和await简介 PS&#xff1a;简介 1. async和await这两个关键字是为了简化异步编程模型而诞生的&#xff0c;使的异步编程更简洁&#xff0c;它本身并不创建新线程&#xff0c;但在该方法内部开启多线程&#xff0c;则另算。 2. 这两个关键字适用于处理一些文件IO操作。…

第十一节:深究用户模式锁的使用场景(异变结构、互锁、旋转锁)

一. 锁机制的背景介绍 本章节&#xff0c;将结合多线程来介绍锁机制&#xff0c; 那么问题来了&#xff0c;什么是锁呢&#xff1f; 为什么需要锁&#xff1f; 为什么要结合多线程来介绍锁呢&#xff1f;锁的使用场景又是什么呢&#xff1f; DotNet中又有哪些锁呢&#xff1f; …

第十三节:实际开发中使用最多的监视锁Monitor、lock语法糖的扩展、混合锁的使用(ManualResetEvent、SemaphoreSlim、ReaderWriterLockSlim)

一. 监视锁(Monitor和lock) 1. Monitor类&#xff0c;限定线程个数的一把锁&#xff08;Synchronized lock是他的语法糖&#xff09;&#xff0c;两个核心方法&#xff1a; Enter&#xff1a;锁住某个资源。 Exit&#xff1a;退出某一个资源。 测试案例&#xff1a;开启5个线…

什么是Mybatis ?

使用JDBC连接数据库 半自动持久层的ORM框架(因为要自己手写sql) 可以使用xml配置,可以使用注解. 优点:1.低耦合,sql重用,编写灵活 2.减少冗余代码 3.兼容数据库 4.能很好的与spring集成 5.提供映射标签,支持对象与数据库的ORM字段映射 缺点:1.sql需要自己编写 2数据库移植性…

第十四节: 介绍四大并发集合类并结合单例模式下的队列来说明线程安全和非安全的场景及补充性能调优问题。

一. 四大并发集合类 背景&#xff1a;我们目前使用的所有集合都是线程不安全的 。 A. ConcurrentBag&#xff1a;就是利用线程槽来分摊Bag中的所有数据&#xff0c;链表的头插法,0代表移除最后一个插入的值. (等价于同步中的List) B. ConcurrentStack&#xff1a;线程安全的St…

#{} 跟${}的区别

#{}是预编译处理 ,可以防止sql注入 ,提高安全性 mybatis 会把sql中的#{}替换成? 调用PreparedStatement set方法赋值 ${}是字符串替换 mybatis会把${}直接替换成变量值

第十五节:深入理解async和await的作用及各种适用场景和用法

一. 同步VS异步 1. 同步 VS 异步 VS 多线程 同步方法&#xff1a;调用时需要等待返回结果&#xff0c;才可以继续往下执行业务 异步方法&#xff1a;调用时无须等待返回结果&#xff0c;可以继续往下执行业务 开启新线程&#xff1a;在主线程之外开启一个新的线程去执行业…

@PostConstruct注解

PostConstruct是Java自己的注解. PostConstruct该注解被用来修饰一个非静态的void()方法. PostConstruct修饰的方法会在服务器加载Servlet的时候运行,并且只会被服务器执行一次. PostConstruct在构造函数之后执行,init()方法之前执行. 执行顺序 Constructor >> Autow…

springCloud五大组件--Gateway

SpringCloud Gateway 是 Spring Cloud 的一个全新项目&#xff0c;该项目是基于 Spring 5.0&#xff0c;Spring Boot 2.0 和 Project Reactor 等技术开发的网关&#xff0c;它旨在为微服务架构提供一种简单有效的统一的 API 路由管理方式。 Spring Cloud Gateway 的目标&#…

多线程篇(被替换)

一. 背景 在刚接触开发的头几年里&#xff0c;说实话&#xff0c;根本不考虑多线程的这个问题&#xff0c;貌似那时候脑子里也有没有多线程的这个概念&#xff0c;所有的业务都是一个线程来处理&#xff0c;不考虑性能问题&#xff0c;当然也没有考虑多线程操作一条记录存在的并…

springCloud五大组件--Eureka

Spring Cloud 支持了 Zookeeper、Consul 和 Eureka&#xff0c;官方推荐 Eureka。 C(一致性)A(高可用)P(分区容错)理论&#xff0c;Eureka的选择就是放弃C&#xff0c;选择AP。 Eureka 采用纯 Java 实现&#xff0c;除实现了注册中心基本的服务注册和发现之外&#xff0c;极大…

.NET异步程序设计之任务并行库

目录 1.简介2.Parallel类 2.0 Parallel类简介2.1 Parallel.For()2.2 Parallel.ForEach()2.3 Parallel.Invoke()2.4 补充&#xff1a;线程安全集合3.Task类 3.0 Task类简介3.1 创建无返回值的Task任务3.2 创建有返回值的Task任务3.3 为Task添加延续任务3.4 Task.Delay3.5 Task对…

Mysql主从延时解决办法

1.忍受大法 第一种解决办法&#xff0c;很简单&#xff0c;无他&#xff0c;不管他&#xff0c;没有读到也没事。这时业务不需要任何改造&#xff0c;你好&#xff0c;我好&#xff0c;她也好~ 如果业务对于数据一致性要求不高&#xff0c;我们就可以采用这种方案。 2.数据同…

关于C#程序的单元测试

目录 1.单元测试概念2.单元测试的原则3.单元测试简单示例4.单元测试框架特性标签5.单元测试中的断言Assert6.单元测试中验证预期的异常7.单元测试中针对状态的间接测试8.单元测试在MVC模式中的实现8.单元测试相关参考9.示例源代码下载 志铭-2020年1月23日 11:49:41 1.单元测试…

MySql 、Oracle 获取表结构和字段信息

MySql获取表结构信息 SELECTTABLE_NAME,TABLE_COMMENT FROMinformation_schema.TABLES WHERETABLE_SCHEMA dm -- dm 是数据库名称&#xff0c;需替换 ORDER BYTABLE_NAME; MySql获取字段信息 SELECTTABLE_NAME AS tableName,COLUMN_NAME AS columnName,COLUMN_COMMENT AS c…

NuGet是什么?理解与使用(上)

如果你了解python&#xff0c;那么它类似pip。 如果你了解nodejs&#xff0c;那么它类似npm。 如果你了解ruby&#xff0c;那么它类似gem。 对&#xff0c;它就是一个包&#xff08;package&#xff09;管理平台&#xff0c;确切的说是 .net平台的包管理工具&#xff0c;它提…

NuGet是什么?理解与使用(下)

本篇将回答下面几个问题&#xff1a; 如何解读NuGet Gallery上的包信息&#xff1f;如何上传NuGet包到NuGet Gallery&#xff1f;如何安装本地NuGet包&#xff1f;NuGet包的内容文件与目录结构&#xff1f; 如果你没看过上篇那么它在这里&#xff1a; 6号咸鱼&#xff1a;NuG…

C#多线程之旅(1)——介绍和基本概念

阅读目录 一、多线程介绍二、Join 和Sleep三、线程怎样工作四、线程和进程五、线程的使用和误用一、多线程介绍 C#通过多线程支持并行执行的代码。一个线程是一个独立执行的路径&#xff0c;可以同时与其他线程一起运行。一个C#客户端程序(Console,WPF,Winows Forms)开始于一个…

C#多线程之旅(2)——详解线程的开始和创建

阅读目录 代码下载一、线程的创建和开始二、传递数据给一个线程三、命名线程四、前台线程和后台线程五、线程优先级六、异常处理代码下载 Thread_博客园_cnblogs_jackson0714.zip 第一篇~第三篇的代码示例&#xff1a; 源码地址&#xff1a;https://github.com/Jackson0714/T…

C#多线程之旅(3)——线程池

阅读目录 代码下载一、介绍二、通过TPL进入线程池三、不用TPL进入到线程池v博客前言 先交代下背景&#xff0c;写《C#多线程之旅》这个系列文章主要是因为以下几个原因&#xff1a;1.多线程在C/S和B/S架构中用得是非常多的;2.而且多线程的使用是非常复杂的&#xff0c;如果没有…