Springboot如何使用mybatis实现拦截SQL分页

Springboot如何使用如何使用mybatis实现拦截实现拦截SQL分页分页

主要介绍了Springboot使用mybatis实现拦截SQL分页,文中通过示例代码介绍的非常详细，对大家的学习或者工

作具有一定的参考学习价值,需要的朋友可以参考下

新建一个类MyPageInterceptor.java（注意在springboot中要添加注解@Component）

package com.grand.p1upgrade.mapper.test;

import java.sql.Connection;

import java.util.Map;

import java.util.Properties;

import org.apache.ibatis.plugin.Plugin;

import org.apache.ibatis.plugin.Signature;

import org.apache.ibatis.reflection.MetaObject;

import org.apache.ibatis.reflection.SystemMetaObject;

import org.springframework.stereotype.Component;

@Component

@Intercepts({@Signature(type=StatementHandler.class,method="prepare",args={Connection.class,Integer.class})})

public class MyPageInterceptor implements Interceptor {

private int page;

public Object intercept(Invocation invocation) throws Throwable {

System.out.println("plugin is running...");

StatementHandler statementHandler = (StatementHandler)invocation.getTarget();

MetaObject metaObject = SystemMetaObject.forObject(statementHandler);

while(metaObject.hasGetter("h")){

Object object = metaObject.getValue("h");

metaObject = SystemMetaObject.forObject(object);

}

while(metaObject.hasGetter("target")){

Object object = metaObject.getValue("target");

Map<String, Object> params = (Map<String, Object>)parameterHandler.getParameterObject();

page = (int)params.get("page");

size = (int)params.get("size");

String sql = (String) metaObject.getValue("delegate.boundSql.sql");

sql += " limit "+(page-1)*size +","+size;

metaObject.setValue("delegate.boundSql.sql", sql);

}

return invocation.proceed();

}

public void setProperties(Properties properties) {

String limit = properties.getProperty("limit","10");

this.page = Integer.parseInt(limit);

this.dbType = properties.getProperty("dbType", "mysql");

}

}

添加测试TestMapper.java

package com.grand.p1upgrade.mapper.test;