困扰我很久,为什么在使用mybatis的rowbounds不启作用了,以前做的项目都可以,后来发现原来是因为数据库换了,拦截器无法配置 导致的
定义抽象类
package com.odbpo.mybatis;
/**
* @Title: Dialect.java
*/
public abstract class Dialect
{
public static enum Type {
MYSQL, ORACLE
}
public abstract String getLimitString(String sql, int skipResults, int maxResults);
}
定义抽象类的实现类
package com.odbpo.mybatis;
import org.apache.log4j.Logger;
/**
* @Title: OracleDialect.java
* @Description:
*/
public class OracleDialect extends Dialect
{
protected static Logger log = Logger.getLogger(OracleDialect.class);
@Override
public String getLimitString(String sql, int offset, int limit)
{
sql = sql.trim();
StringBuffer pagingSelect = new StringBuffer(sql.length() + 100);
pagingSelect.append("select * from ( select row_.*, rownum rownum_ from ( ");
pagingSelect.append(sql);
pagingSelect.append(" ) row_ ) where rownum_ > ").append(offset).append(" and rownum_ <= ")
.append(offset + limit);
log.debug(pagingSelect.toString());
return pagingSelect.toString();
}
}
定义mybatis拦截器,--关键
package com.odbpo.mybatis;
/**
* @Title: PageInterceptor.java
* @Description: myBatis 分页工具
*/
import java.sql.Connection;
import java.util.Map;
import java.util.Properties;
import org.apache.ibatis.executor.parameter.DefaultParameterHandler;
import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.mapping.BoundSql;
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.session.Configuration;
import org.apache.ibatis.session.RowBounds;
import org.apache.log4j.Logger;
@Intercepts(
{ @Signature(type = StatementHandler.class, method = "prepare", args =
{ Connection.class }) })
public class PaginationInterceptor implements Interceptor
{
protected static Logger log = Logger.getLogger(PaginationInterceptor.class);
/* (non-Javadoc)
* @see org.apache.ibatis.plugin.Interceptor#intercept(org.apache.ibatis.plugin.Invocation)
*/
@SuppressWarnings("unchecked")
@Override
public Object intercept(Invocation invocation) throws Throwable
{
StatementHandler statementHandler = (StatementHandler) invocation.getTarget();
MetaObject metaStatementHandler = MetaObject.forObject(statementHandler);
RowBounds rowBounds = (RowBounds) metaStatementHandler.getValue("delegate.rowBounds");
if (rowBounds == null || rowBounds == RowBounds.DEFAULT)
{
return invocation.proceed();
}
DefaultParameterHandler defaultParameterHandler = (DefaultParameterHandler) metaStatementHandler
.getValue("delegate.parameterHandler");
Map parameterMap = (Map) defaultParameterHandler.getParameterObject();
Object sidx = parameterMap.get("_sidx");
Object sord = parameterMap.get("_sord");
String originalSql = (String) metaStatementHandler.getValue("delegate.boundSql.sql");
if (sidx != null && sord != null)
{
originalSql = originalSql + " order by " + sidx + " " + sord;
}
Configuration configuration = (Configuration) metaStatementHandler
.getValue("delegate.configuration");
Dialect.Type databaseType = null;
try
{
databaseType = Dialect.Type.valueOf(configuration.getVariables().getProperty("dialect")
.toUpperCase());
}
catch (Exception e)
{
log.error(e);
}
if (databaseType == null)
{
throw new RuntimeException(
"the value of the dialect property in configuration.xml is not defined : "
+ configuration.getVariables().getProperty("dialect"));
}
Dialect dialect = null;
switch (databaseType)
{
case ORACLE:
dialect = new OracleDialect();
break;
case MYSQL://需要实现MySQL的分页逻辑
break;
}
metaStatementHandler.setValue("delegate.boundSql.sql", dialect.getLimitString(originalSql,
rowBounds.getOffset(), rowBounds.getLimit()));
metaStatementHandler.setValue("delegate.rowBounds.offset", RowBounds.NO_ROW_OFFSET);
metaStatementHandler.setValue("delegate.rowBounds.limit", RowBounds.NO_ROW_LIMIT);
if (log.isDebugEnabled())
{
BoundSql boundSql = statementHandler.getBoundSql();
log.debug("生成分页SQL : " + boundSql.getSql());
}
return invocation.proceed();
}
/* (non-Javadoc)
* @see org.apache.ibatis.plugin.Interceptor#plugin(java.lang.Object)
*/
@Override
public Object plugin(Object target)
{
return Plugin.wrap(target, this);
}
/* (non-Javadoc)
* @see org.apache.ibatis.plugin.Interceptor#setProperties(java.util.Properties)
*/
@Override
public void setProperties(Properties arg0)
{
}
}
定义分页的BEAN
package com.odbpo.mybatis;
import java.util.Collections;
import java.util.List;
@SuppressWarnings("unchecked")
public class Page
{
private int page;
private int limit;
private int total;
private List rows = Collections.emptyList();
public int getPage()
{
return page;
}
public void setPage(int page)
{
this.page = page;
}
public int getLimit()
{
return limit;
}
public void setLimit(int limit)
{
this.limit = limit;
}
public int getTotal()
{
return total;
}
public void setTotal(int total)
{
this.total = total;
}
public List getRows()
{
return rows;
}
public void setRows(List rows)
{
this.rows = rows;
}
}
相关推荐
使用mybatis的拦截器功能实现分页操作,使分页代码在整个项目中通用,减少代码冗余。
mybatis分页拦截器(自动封装版)剖析.pdfmybatis分页拦截器(自动封装版)剖析.pdfmybatis分页拦截器(自动封装版)剖析.pdfmybatis分页拦截器(自动封装版)剖析.pdfmybatis分页拦截器(自动封装版)剖析.pdfmybatis分页拦截...
Mybatis分页拦截器,mybatis-3.1.1和mybatis-3.0.4版本下测试通过。
主要给大家介绍了关于mybatis拦截器实现通用权限字段添加的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用mybatis具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
使用maven和jdk1.8 项目导入直接更改数据库连接即可使用
mybatis mysql 分页拦截器,可以针对方法名称,或指定的参数进行拦截
MyBatis拦截器分页与动态修改SQL及其参数值 提取SQL Like 字段
利用Mybatis的动态SQL实现物理分页.pdf
Mybatis学习- 拦截器-实现分页
项目使用的是mybatis分页拦截器实现的分页,该链接是一个单表分页,如果想联表分页请将mapping中返回值类型改为map,同时进行联表查询, 谢谢大家 有疑问的地方可以留言或者发我邮箱sl166199@163.com
详细介绍了Mybatis拦截器的使用,并且展示了分页插件的参考实现
MyBatis拦截器分页代码,网上看到的,供大家一起共同分享学习。
特殊字符(\,_,%)转义工具类 MyQueryInterceptor.java: Mybatis自定义拦截器 注意:该拦截器只支持QueryWrapper的like方法,serviceImpl层传全角模糊查询(%%) mapper或xml层的全角模糊查询(%*%)和半角模糊查询(%*或*%)
代码包含: EscapeUtil.java:特殊字符(\,_,%)转义工具类 MyQueryInterceptor.java: Mybatis自定义拦截器 注意:该拦截器只支持QueryWrapper的like方法,serviceImpl层传全角模糊查询(%%) mapper或xml层的全角模糊查询(%...
NULL 博文链接:https://aqbbsxiao.iteye.com/blog/1356186
spring+mybatis实现了物理分页的