springboot+mybatisplus实现分页(springboot+mybatisplus多数据源)

java8

帖子摘要：在日常开发中多记录的列表查询可能会遇到分页处理的场景在springboot项目中传统是引入mybatis组件进行持久化然后通过pagehelper组件进行分页实现。下面体验一下在springboot项......

大家好，欢迎来到Java吧（www.java8.com），交流、学习Java技术、获取Java资源无任何套路，今天说一说：“springboot+mybatisplus实现分页”


7 G4 w1 E: ]- W6 b( e* J" Y        
               
- I7 n  }+ v7 Y+ K5 ~1 B6 Y                    
- e/ E' X6 b, ]                        
! a! }) f% c7 X                    
( T: T1 i; c' ^: v                    
在日常开发中多记录的列表查询可能会遇到分页处理的场景在springboot项目中传统是引入mybatis组件进行持久化然后通过pagehelper组件进行分页实现。下面体验一下在springboot项目中引入mybatisplus组件通过其自带分页插件实现分页功能。
' f$ R" _7 f0 U4 ~# Z# c
% m' z# k/ ?) A3 i) }: c% L) U
1、MyBatis Plus
& ?) F0 k% x3 C/ mMyBatis Plus是一个MyBatis的增强工具在 MyBatis 的基础上只做增强不做改变为简化开发、提高效率而生。
Mybatis Plus可以节省大量时间所有的CRUD代码都可以自动化完成。MyBatis Plus自带分页插件即BaseMapper接口中的selectPage()方法只要简单的配置即可实现分页功能。
, s7 C. h# X9 h8 w1 r; a5 P0 C
7 P/ X: f" o& n' \" m, C) H+ V/ X, R4 T

8a1cfc6978a948f69e7007bd9377965c.png (97.34 KB, 下载次数: 0, 售价: 4 金钱)

2023-1-19 14:29 上传

点击文件名下载附件
8a1cfc6978a948f69e7007bd9377965c.png

2、springboot+mybatisplus+mysql实例
# M, b( {" |8 |. s, o
pom.xml文件中引入依赖
7 z7 |/ F% M" T4 K# Q! l

1 h( \/ e* f3 X; z4 s

                
( N% m- B! \/ B
            com.baomidou
1 \. D* n! V9 @5 m6 }
            mybatis-plus-boot-starter
9 ~7 k+ W& X$ R+ D7 C; O- U# ]4 W
        
        
            com.baomidou
7 M! m$ u. |, }
            dynamic-datasource-spring-boot-starter
) y; V: o" w5 z) }7 l7 M
        
复制代码

添加分页配置类
3 E7 W$ b/ P  g/ W# c

6 _( w' A1 f. F: x3 r

@Configuration
public class MybatisPlusConfig {
9 q  G- K/ O7 n; H$ d
    /**
, m+ q) C+ x) W3 C: I9 {5 k: \
     * 分页插件官网最新
     */
) G# x' T6 f( I3 r( I- t$ h, a
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
# Q! l# [0 x6 y) Q+ t1 ?
        return interceptor;
    }
}
+ |. Q% p# G* v) E
复制代码

6 ]/ m9 d. L' f" ?+ p) u 添加service层代码分页的所有数据都在userPage对象中封装着所以可以调用userPage对象的一系列方法对分页数据进行操作。

3 n; @  u  I6 t2 F2 X

@Slf4j
% n- R2 g0 C5 s
@Service
/ p0 j; ~% m* ^
public class SysUserServiceImpl implements SysUserService {
' e( o& X9 \" A0 Z
    @Autowired
    private SysUserMapper userMapper;
    @Override
    public Page[U] listPage1(Page[U] page, QueryWrapper[U] queryWrapper) {
4 g. ], }: h- t# E. v6 `5 f9 w
        return userMapper.selectPage(page, queryWrapper);
    }
    @Override
    public PagerModel[U] listPage2(Page[U] page, QueryWrapper[U] queryWrapper) {
; m; P7 o& W7 j0 l& x. K
        Page[U] userIPage = userMapper.selectPage(page, queryWrapper);
        // 分页的所有数据都在userPage对象中封装着
, x4 B. A) o1 B/ P
        // 获取总页数
) c! a7 B" C6 @' o) k
        long pages = userIPage.getPages();
        //一页显示几条数据
+ G- S! u. J1 _* ?+ r7 e% x/ u
        long size = userIPage.getSize();
        // 获取当前页
        long current = userIPage.getCurrent();
6 t: J! ^  z% l9 c
        // 获取当前页数据集合
; e% J' f+ q0 v
        List[U] records = userIPage.getRecords();
        // 获取总记录数
2 k! q' _+ Z, f7 q4 m
        long total = userIPage.getTotal();
" |3 j/ k5 l* E0 `$ P% N
        // 当前页是否有下一页
: {0 j5 u$ \0 k% c
        boolean hasNext = userIPage.hasNext();
. l: p  g( {! D7 o8 {( }* F
        // 当前页是否有上一页
        boolean hasPrevious = userIPage.hasPrevious();
        System.out.println("总页数pages=" + pages);
. I7 ?' ~. F9 q- G) g7 O
        System.out.println("当前页current=" + current);
) g! M& r9 u9 N- x
        System.out.println("当前页显示几条数据size=" + size);
. G! f$ q* @9 Y9 O
        System.out.println("当前页数据集合records=" + records);
3 N2 o8 x) _+ ^- A
        System.out.println("总记录数total=" + total);
        System.out.println("是否有下一页hasNext=" + hasNext);
        System.out.println("是否有上一页hasPrevious=" + hasPrevious);
$ W2 ]  x3 g( d4 f; t1 c0 b: ^1 [
        return new PagerModel(userIPage.getTotal(), records);
    }
# B) X0 q! s1 p* ]$ x4 ~
}
复制代码

% g; y/ k" q2 I" T4 f7 r
添加controller层代码
  S7 d+ z  @( H5 a( [7 L+ l3 g" I
5 P& W" b0 C8 [. b% W( e/ }
( u) ]& X; {. y9 z0 \6 E

@RestController
6 D7 L; d+ g5 S, T
@RequestMapping("/user")
7 s/ ^+ z+ M% |6 n9 j9 z( a; L
public class UserController {
  b( u% A) M& U5 l7 Z/ n7 P
    @Autowired
    private SysUserService userService;
        /**
: u% ^! |# z3 C& ]
     * 分页列表
7 K, \0 T, s' X: B* }
     * @param keyword
2 X2 D9 e3 n! t8 ^8 k5 n: [1 I
     * @param pageNum
0 M* J$ o6 O) l8 ]6 c1 n
     * @param pageSize
" B0 ^5 g% J( k: O. d. D
     * @return
7 R* z* |: @  R) ?( j
     */
1 K2 W- m1 G4 M9 I1 V2 j2 X2 i
    @GetMapping("/listPage1")
# j, t( e$ ]  u- h8 Z4 g& U
    public Page[U] listPage1(@RequestParam(value = "keyword", defaultValue = "") String keyword,
                                  @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
; `2 D! f3 b. _/ e3 g
                                  @RequestParam(value = "pageSize", defaultValue = "5") Integer pageSize) {
( @1 J" |5 l/ R- P
        // 条件构造器
        QueryWrapper[U] queryWrapper = new QueryWrapper();
        // 模糊查询Like
        queryWrapper.like("nickname", keyword);
        // 分页插件
/ ~/ v1 d, }8 [- }' s: W
        Page[U] page = new Page(pageNum, pageSize);
: ?- D, @' L/ g% t% [
        // 查询数据
- W* l& g, V9 x0 k( h! I0 U
        return userService.listPage1(page, queryWrapper);
5 I6 |. V1 ^) u/ C; _, _7 X9 o
    }
2 y8 w, O5 U% T  S- Z* z; B
    /**
" V" [" E8 W( l! o" z8 t8 Q
     * 自定义分页对象分页列表
- ^4 e; ~  i$ V( L- `
     * @param keyword
6 R2 c- A( ?/ Q! d
     * @param pageNum
( t4 z1 m6 y3 l% d
     * @param pageSize
" o) u9 t5 {; Y
     * @return
2 x# k9 @( k' z+ R
     */
% u$ V' o) }1 {: Z
    @GetMapping("/listPage2")
* ?6 L4 S6 [& F6 O
    public PagerModel[U] listPage2(@RequestParam(value = "keyword", defaultValue = "") String keyword,
8 q# ~2 V) {4 g1 m% o
                                 @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
( p0 P4 K: F5 {$ H! P
                                 @RequestParam(value = "pageSize", defaultValue = "5") Integer pageSize) {
/ A5 V% _1 {: w) a) ?5 {* g/ s2 d! v
        // 条件构造器
        QueryWrapper[U] queryWrapper = new QueryWrapper();
7 t+ m( I: q# [  {  A8 Q
        // 模糊查询Like
        queryWrapper.like("nickname", keyword);
        // 分页插件
3 E4 p6 W6 P8 g- O4 C
        Page[U] page = new Page(pageNum, pageSize);
" Y* e8 p; \( Q- O( Q9 \/ G
        // 查询数据
        return userService.listPage2(page, queryWrapper);
* l' q9 B* r" M. d0 \6 R! L+ l  x
    }
    
2 L1 K; B0 O4 h: h
}
& X, b& b; v; E& R7 D; D; \
复制代码

/ i( p% d, c9 u( z7 u5 X
自定义列表返回对象
2 T: l& ]  K( K5 r) c) x' T, n

2 Z+ ~  B/ o# N! C

@Data
@Builder(toBuilder = true)
public class PagerModel implements Serializable {
: P- w5 ~- }- I5 ^) a2 U% C% H3 k: p
    private static final long serialVersionUID = 4804053559968742915L;
    /**
     * 总记录数
     */
    private long total;
- _: T2 b; x$ a7 c8 T
    /**
     * 每页的查询结果集
# w$ f  V1 I$ ?3 B" ]& u
     */
% M0 Q" N9 B% o
    private List rows = new ArrayList();
    /**
" T8 M% f5 S% U2 z! p( y, F. R
     * 获取总页数
     */
    private long pages;
    /**
- }4 s7 w8 P% W" C; j
     * 获取当前页
     */
1 Z0 I' N. t# I$ I0 c% t. @
    private long current;
5 w9 d/ D& M3 r( j  Q: c
    /**
     * 当前页显示几条数据
     */
9 a' T( n# p' @9 G7 h$ t  d. `
    private long size;
    /**
     * 当前页是否有下一页
     */
- q" o# f: M, @' L+ g
    private boolean hasNext;
    /**
/ H5 s6 J, D5 v2 K& Z! a( h
     * 当前页是否有上一页
8 ^4 y6 S/ _1 l
     */
    private boolean hasPrevious;
7 [/ \# N" v! u; R0 C
    public PagerModel() {
    }
    public PagerModel(long total, List rows) {
6 V* r3 S) ^: c$ z
        this.total = total;
        this.rows = rows;
% G/ ~5 f8 b4 B+ K  S) V- s
    }
+ \+ L$ _% ~) e, `
    public PagerModel(long total, List rows, long pages, long current) {
        this.total = total;
! r2 L' T" m' n, ?
        this.rows = rows;
2 C4 X' g7 F  E- \  U, P
        this.pages = pages;
5 `0 ~! n3 W, O7 w* z$ @0 q& z+ G
        this.current = current;
& ?. v* J7 B3 Q3 c
    }
    public PagerModel(long total, List rows, long pages, long current, long size) {
( z2 A4 M3 {) M
        this.total = total;
        this.rows = rows;
        this.pages = pages;
( x. i: i* I& c$ X! o$ v" B
        this.current = current;
        this.size = size;
    }
6 _; f, b  W' {9 B) y3 }5 i9 {) Y
    public PagerModel(long total, List rows, long pages, long current, boolean hasNext, boolean hasPrevious) {
8 @7 v; J5 {; x1 y
        this.total = total;
        this.rows = rows;
0 N  k; Z9 y' d& j
        this.pages = pages;
        this.current = current;
        this.hasNext = hasNext;
        this.hasPrevious = hasPrevious;
    }
    public PagerModel(long total, List rows, long pages, long current, long size, boolean hasNext, boolean hasPrevious) {
        this.total = total;
        this.rows = rows;
' N+ X8 c5 A9 p9 ?1 k/ D
        this.pages = pages;
) q- i) Q8 p$ }+ p
        this.current = current;
        this.size = size;
* }4 \8 ^' b* p0 u6 s& q
        this.hasNext = hasNext;
9 t/ z( A! A4 j" a* H" E* \
        this.hasPrevious = hasPrevious;
  y: c# }2 A0 k
    }
7 F& L! W" P6 r! T9 J' \
}
% @- t* J' P2 X
复制代码

3、测试
访问http://localhost:8805/first/user/listPage1结果如下
- m6 ^. M) K0 H- Q8 g

2d83bc5dee7440e38911ec068224b30d.png (68.04 KB, 下载次数: 0, 售价: 6 金钱)

2023-1-19 14:29 上传

点击文件名下载附件
2d83bc5dee7440e38911ec068224b30d.png

6 b: t6 V3 T& K, u 访问http://localhost:8805/first/user/listPage2结果如下

8 i! X) z5 b9 _9 w4 \2 P) y

61e3dcd3a890453e973ddf48a685e355.png (73.34 KB, 下载次数: 0, 售价: 1 金钱)

2023-1-19 14:29 上传

点击文件名下载附件
61e3dcd3a890453e973ddf48a685e355.png

日志打印如下

4 ^' m! |) E& Y! Q

57618b80d07e4e78ad30b6f514d6f266.png (64.37 KB, 下载次数: 0, 售价: 4 金钱)

2023-1-19 14:29 上传

点击文件名下载附件
57618b80d07e4e78ad30b6f514d6f266.png

- X2 d3 P% B- ^5 l  ~1 w' b
4、异常java.sql.SQLFeatureNotSupportedException
异常信息如下

Caused by: java.sql.SQLFeatureNotSupportedException: null
        at com.alibaba.druid.pool.DruidPooledResultSet.getObject(DruidPooledResultSet.java:1771)
8 V7 I: j( J2 f0 `
        at com.p6spy.engine.wrapper.ResultSetWrapper.getObject(ResultSetWrapper.java:1649)
. E2 c, W0 P  B% H( z# f. ]2 M) v
        at org.apache.ibatis.type.LocalDateTimeTypeHandler.getNullableResult(LocalDateTimeTypeHandler.java:38)
* I, [7 L$ X$ B4 X, f/ X
        at org.apache.ibatis.type.LocalDateTimeTypeHandler.getNullableResult(LocalDateTimeTypeHandler.java:28)
        at org.apache.ibatis.type.BaseTypeHandler.getResult(BaseTypeHandler.java:81)
        at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.applyAutomaticMappings(DefaultResultSetHandler.java:521)
        at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.getRowValue(DefaultResultSetHandler.java:402)
0 c- S1 o5 A, a+ V/ H7 {
        at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleRowValuesForSimpleResultMap(DefaultResultSetHandler.java:354)
. q. A: V5 l. }
        at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleRowValues(DefaultResultSetHandler.java:328)
1 I5 P! M; i5 l# o
        at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleResultSet(DefaultResultSetHandler.java:301)
        at org.apache.ibatis.executor.resultset.DefaultResultSetHandler.handleResultSets(DefaultResultSetHandler.java:194)
5 e  [  D! _: v$ N
        at org.apache.ibatis.executor.statement.PreparedStatementHandler.query(PreparedStatementHandler.java:65)
        at org.apache.ibatis.executor.statement.RoutingStatementHandler.query(RoutingStatementHandler.java:79)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.ibatis.plugin.Plugin.invoke(Plugin.java:63)
3 `7 f& A# w$ E
        at com.sun.proxy.$Proxy247.query(Unknown Source)
        at com.baomidou.mybatisplus.core.executor.MybatisSimpleExecutor.doQuery(MybatisSimpleExecutor.java:67)
        at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:324)
: _4 t4 E' ~4 i; K) A) _4 E" T1 Z
        at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:156)
        at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:136)
        at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:147)
        at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:140)
8 n- \8 e" @9 d- s& a3 i
        at org.apache.ibatis.session.defaults.DefaultSqlSession.selectOne(DefaultSqlSession.java:76)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
" b' [. O. u7 _
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
! _5 a  F, {! K; u4 B& G1 }- S7 w6 ]; L
        at java.lang.reflect.Method.invoke(Method.java:498)
: D4 _  d, l7 {) Y: P) k5 ]
        at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:426)
% S/ ^( x% U% z3 y. t; V$ l' M
        ... 106 common frames omitted
5 t" x* Q4 h) S2 {% ]
复制代码

出现上述异常是由于druid和Mybatis plus依赖版本的问题。
; Q& f' W1 X7 I# [* Z) f- q9 @/ k9 H druid版本在1.1.21之前是不支持LocalDateTime等新日期处理方式的但是Mybatis plus在3.3.1之后是支持的。因此在SQL查询过程中这两者就产生了冲突。
解决方法把druid版本提高到1.2.6(不建议降低Mybatis plus版本)改完之后异常解决。注确保项目中的依赖或隐藏依赖中的druid版本提高到1.1.21版本以上。
               
               
               
本文来源csdn，由Java吧转载发布，观点不代表Java吧的立场，转载请标明来源出处：https://www.java8.com