困扰我很久,为什么在使用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这个流行的Java持久层框架时,如何在不修改MyBatis核心源码的情况下实现数据库的物理分页功能。物理分页是直接在数据库层面进行分页查询,通常更高效,...
总之,MyBatis拦截器为开发者提供了极大的灵活性,可以实现分页、动态SQL和参数值修改等多种功能。通过分析提供的代码文件,我们可以深入学习MyBatis的高级特性,并将其应用到实际项目中,提升开发效率和代码质量。
这两个类都是实现了`Interceptor`接口的自定义拦截器,它们在Mybatis的执行流程中插入,对SqlSession的执行过程进行拦截,从而实现分页功能。 首先,`MybatisSpringPageInterceptor`通常用于Spring Boot集成Mybatis...
项目使用的是mybatis分页拦截器实现的分页,该链接是一个单表分页,如果想联表分页请将mapping中返回值类型改为map,同时进行联表查询, 谢谢大家 有疑问的地方可以留言或者发我邮箱sl166199@163.com
MyBatis的分页功能通常通过PageHelper或MyBatis-Plus等插件实现,它们允许开发者在不修改原有SQL的基础上,轻松实现物理分页或逻辑分页。分页不仅可以提高应用的性能,避免一次性加载大量数据导致内存压力,还能提供...
总的来说,Spring_MyBatis物理分页提供了一种高效且灵活的方式来处理大量数据的展示,它通过拦截器和方言支持,降低了代码的侵入性,使得分页功能的实现更加简洁。在实际项目开发中,这种设计模式可以显著提高系统的...
最后,配置Mybatis拦截器。在`mybatis-config.xml`中,你需要添加一个`plugins`节点,里面包含你的分页插件配置: ```xml ... <!-- 可选的配置项,如分页参数的属性名 --> ... ``` 以上就是Mybatis3...
MyBatis作为一个轻量级的持久层框架,虽然本身并不直接提供完整的分页解决方案,但可以通过插件机制来扩展其功能,实现物理分页。 MyBatis插件机制允许开发者自定义拦截器,这些拦截器可以拦截SQL执行的各个阶段,...
3. 使用插件时,确保正确配置 MyBatis 的拦截器链,避免与其他插件冲突。 4. 为了防止 SQL 注入,修改 SQL 时应确保参数安全,最好使用预编译的 PreparedStatement。 总之,MyBatis 的物理分页可以通过自定义插件...
PageHelper插件的工作原理主要基于拦截器(Interceptor),它会拦截MyBatis的SqlSession对象,当执行查询时,PageHelper会解析传入的SQL语句,并在其基础上自动添加分页相关的SQL片段。这一过程得益于另一个重要的...
MyBatis分页插件PageHelper是MyBatis的一个插件,用于实现物理分页的功能。它可以简化SQL代码的写法,减少误差性,提高开发效率。下面是使用PageHelper实现分页的示例: 一、引入依赖 在Maven工程中,需要引入...
* 内置分页插件:基于 MyBatis 物理分页,开发者无需关心具体操作,配置好插件之后,写分页等同于普通 List 查询 * 分页插件支持多种数据库:支持 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、Postgre、SQL...
PageHelper 还支持物理分页和内存分页,可以有效地减少数据库压力。 在实际开发中,我们还需要关注 MyBatis 的事务管理。MyBatis 默认支持 JDBC 的事务管理,可以通过配置文件进行全局设置,也可以在 Service 层中...
1. **Interceptor**:MyBatis 分页插件的核心是拦截器(Interceptor),它实现了 `org.apache.ibatis.plugin.Interceptor` 接口。拦截器在 SQL 执行前和执行后插入逻辑,实现分页功能。主要关注 `intercept` 方法,...
然后在Spring的配置文件(如:mybatis-config.xml)中配置PageHelper的拦截器: ```xml ``` 这里配置了MySQL的方言,并开启了合理分页和方法参数支持。 **使用示例** PageHelper的使用非常简单,主要...
PageHelper 是一个 MyBatis 的第三方分页插件,它提供了更强大的分页功能,包括物理分页和逻辑分页。PageHelper 通过拦截器的方式,动态修改 SQL 语句,添加分页条件。在使用 PageHelper 进行分页时,需要在配置文件...
PageHelper通过拦截器的方式,自动拦截SQL,实现物理分页。使用PageHelper后,只需要在Mapper接口的方法上添加@Select、@Insert、@Update或@Delete注解,就可以自动实现分页功能,极大地提高了开发效率。 【BaseDao...
3. **物理分页**:PageHelper 实现了物理分页,确保了分页的准确性。 4. **统计功能**:提供总数的计算,方便在页面上显示总记录数。 5. **支持多数据库**:适应性强,无需针对不同数据库修改分页代码。 6. **...
- 分页插件可能会与某些自定义的MyBatis拦截器冲突,需要调整拦截器的顺序。 - 在使用PageHelper时,确保所有的查询操作都在PageHelper.startPage()之后进行。 - 对于大数据量的分页查询,物理分页更高效,但需要...