mybatis框架下物理分页的实现（整个工程采用的是springmvc、spring、mybatis框架，数据库是mysql数据库）

2024-06-21 12:08
文章标签 java 实现 mysql spring 数据库 springmvc 框架 分页 工程 mybatis 采用 物理 database 整个

本文主要是介绍mybatis框架下物理分页的实现（整个工程采用的是springmvc、spring、mybatis框架，数据库是mysql数据库），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

   整个工程采用的是springmvc、spring、mybatis框架，数据库是mysql数据库，本工程采用的是拦截器机制实现物理分页。

    因为文章最后会有完整的工程资源文件，这里就不把详细代码贴出来了，只是把拦截器和相关的配置文件的代码跟大家详细探讨下。

    (一）关于分页拦截器的简单理解

    首先，要开发MyBatis的插件需要实现org.apache.ibatis.plugin.Interceptor接口，这个接口将会要求实现几个方法：intercept（）、plugin（）及setProperties（），intercept方法是开发人员所要执行的操作，plugin是将你插件放入到MyBatis的插件集合中去，而setProperties这是在你配置你插件的时候将plugins/plugin/properties的值设置到该插件中。
    该方法的第一句话就是获得Intercepts注解，接下来将获得在Intercepts里面的参数@Signature注解内容，在该注解中包含三个参数，分别是type，method，args。Type指定要拦截的类对象，method是指明要拦截该类的哪个方法，第三个是指明要拦截的方法参数集合。在Intercepts中可以配置多个@Signature。那么便对这写值进行遍历，已获得对应的type、method以及args。最终是获得一个HashMap对象，这些对象里面的键是类对象，而值是指定的类中方法对象。执行该端程序之后，更具target的classLoader和接口，来创建一个代理，并且，InvocationHandler是创建一个新的Plugin对象，同时将target，interceptor以及signatureMap传递给Plugin对象，当然，这里的Plugin也实现了Invocation接口。那么target对象所有的方法调用都会触发Plugin中的invoke方法，那么这里将执行开发者所有插入的操作。

    另外对拦截器类里面几个关键的类做出解释：

（1）BoundSql类 ，封装mybatis最终产生sql的类，包括sql语句，参数，参数源数据等。
（2）MappedStatement类，MappedStatement类在Mybatis框架中用于表示XML文件中一个sql语句节点，即一个<select />、<update />或者<insert />标签。Mybatis框架在初始化阶段会对XML配置文件进行读取，将其中的sql语句节点对象化为一个个MappedStatement对象。

   总结，本拦截器实现的目标就是在进行数据库查询操作之前，从配置文件读出相应的sql语句，将相应的参数拼接到其中，然后再进行查询。当然在拼接sql语句之前，先查询了一下数据库中相应记录的总数。

（二）拦截器类PageIntercepter.java：

package cn.zyy.paging.intercepter;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Properties;import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.mapping.ParameterMapping;
import org.apache.ibatis.mapping.ParameterMode;
import org.apache.ibatis.mapping.SqlSource;
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.reflection.MetaObject;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.RowBounds;
import org.apache.ibatis.type.TypeHandler;
import org.apache.ibatis.type.TypeHandlerRegistry;import cn.zyy.paging.vo.PageObject;@Intercepts({@org.apache.ibatis.plugin.Signature(method="query", type=org.apache.ibatis.executor.Executor.class, args={MappedStatement.class, Object.class, RowBounds.class, org.apache.ibatis.session.ResultHandler.class})})
public class PageIntercepter implements Interceptor{@Overridepublic Object intercept(Invocation invocation) throws Throwable {MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];Object object = invocation.getArgs()[1];if(object instanceof PageObject){PageObject pageObject = (PageObject) object;BoundSql boundSql = mappedStatement.getBoundSql(object);String sql = boundSql.getSql();int count = getCount(mappedStatement,boundSql);pageObject.setCount(count);int pages = (pageObject.getCount()+pageObject.getNumber()-1)/pageObject.getNumber();pageObject.setPages(pages>0?pages:1);int offset = (pageObject.getPage() - 1) * pageObject.getNumber();int limit = pageObject.getNumber();String pageSql = pageSql(sql, offset, limit);BoundSql pageBoundSql = new BoundSql(mappedStatement.getConfiguration(), pageSql, boundSql.getParameterMappings(), boundSql.getParameterObject());MappedStatement pageMappedStatement = pageMappedStatement(mappedStatement, new PageSqlSource(pageBoundSql));invocation.getArgs()[0] = pageMappedStatement;invocation.getArgs()[2] = RowBounds.DEFAULT;}return invocation.proceed();}@Overridepublic Object plugin(Object object) {// TODO Auto-generated method stubreturn Plugin.wrap(object, this);}@Overridepublic void setProperties(Properties properties) {// TODO Auto-generated method stub}private int getCount(MappedStatement mappedStatement, BoundSql boundSql) throws SQLException {Connection connection = null;PreparedStatement ps = null;ResultSet rs = null;try {String countSql = countSql(boundSql.getSql());connection = mappedStatement.getConfiguration().getEnvironment().getDataSource().getConnection();ps = connection.prepareStatement(countSql);BoundSql countBoundSql = new BoundSql(mappedStatement.getConfiguration(), countSql, boundSql.getParameterMappings(), boundSql.getParameterObject());setCountParameters(ps, mappedStatement, countBoundSql);rs = ps.executeQuery();int count = 0;if (rs.next()){count = rs.getInt(1);}return count;} catch (Exception e) {return 1000;}finally{try {rs.close();} catch (Exception localException4) {}try {ps.close();} catch (Exception localException5) {}try {connection.close();}catch (Exception localException6) {}}}private static String countSql(String sql){sql = sql.toUpperCase();StringBuffer countSql = new StringBuffer();countSql.append("SELECT COUNT(1) FROM (");countSql.append(sql.substring(0, sql.indexOf("ORDER BY")==-1?sql.length():sql.indexOf("ORDER BY")-1));countSql.append(") PAY_PAGE_T");return countSql.toString();}private static void setCountParameters(PreparedStatement ps, MappedStatement mappedStatement, BoundSql boundSql) throws SQLException {List<ParameterMapping> parameterMappingList = boundSql.getParameterMappings();if (parameterMappingList != null){Configuration configuration = mappedStatement.getConfiguration();TypeHandlerRegistry typeHandlerRegistry = configuration.getTypeHandlerRegistry();Object parameterObject = boundSql.getParameterObject();MetaObject metaObject = parameterObject == null ? null : configuration.newMetaObject(parameterObject);int n = 1;for (ParameterMapping parameterMapping : parameterMappingList){if ((parameterMapping.getMode() == ParameterMode.IN) || (parameterMapping.getMode() == ParameterMode.INOUT)){String property = parameterMapping.getProperty();Object value = null;if (parameterObject != null){if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())){value = parameterObject;}else{value = metaObject == null ? null : metaObject.getValue(property);}}TypeHandler typeHandler = parameterMapping.getTypeHandler();typeHandler.setParameter(ps, n, value, parameterMapping.getJdbcType());}n++;}}}private String pageSql(String sql, int offset, int limit) {sql = sql.toUpperCase();StringBuffer pageSql = new StringBuffer();pageSql.append(sql);pageSql.append(" LIMIT ");pageSql.append(offset);pageSql.append(", ");pageSql.append(limit);return pageSql.toString();}private MappedStatement pageMappedStatement(MappedStatement mappedStatement, SqlSource sqlSource){MappedStatement.Builder builder = new MappedStatement.Builder(mappedStatement.getConfiguration(), mappedStatement.getId(), sqlSource, mappedStatement.getSqlCommandType());builder.resource(mappedStatement.getResource());builder.fetchSize(mappedStatement.getFetchSize());builder.statementType(mappedStatement.getStatementType());builder.keyGenerator(mappedStatement.getKeyGenerator());builder.timeout(mappedStatement.getTimeout());builder.parameterMap(mappedStatement.getParameterMap());builder.resultMaps(mappedStatement.getResultMaps());builder.cache(mappedStatement.getCache());builder.resultSetType(mappedStatement.getResultSetType());builder.flushCacheRequired(mappedStatement.isFlushCacheRequired());builder.useCache(mappedStatement.isUseCache());builder.resultOrdered(mappedStatement.isResultOrdered());builder.databaseId(mappedStatement.getDatabaseId());builder.lang(mappedStatement.getLang());if (mappedStatement.getKeyProperties() != null){for (String keyProperty : mappedStatement.getKeyProperties()){builder.keyProperty(keyProperty);}}if (mappedStatement.getKeyColumns() != null){for (String keyColumn : mappedStatement.getKeyColumns()){builder.keyColumn(keyColumn);}}return builder.build();}public static class PageSqlSource implements SqlSource {private BoundSql boundSql;public PageSqlSource(BoundSql boundSql) {this.boundSql = boundSql;}public BoundSql getBoundSql(Object parameterObject){return this.boundSql;}}}

（三）spring配置文件和mybatis配置文件

mybatis配置文件中主要是配置相关的vo类和拦截器

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"><configuration><typeAliases><typeAlias alias="page" type="cn.zyy.paging.vo.PageObject"/></typeAliases><plugins><plugin interceptor="cn.zyy.paging.intercepter.PageIntercepter"/></plugins>
</configuration>
spring的配置文件中主要就是实现mybatis和spring框架的整合 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:mvc="http://www.springframework.org/schema/mvc"xmlns:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsdhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"><!-- 读取属性文件 --><bean class = "org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name = "location" value = "classpath:db.properties"></property></bean><!-- 配置数据源 --><bean id = "dataSource" class = "org.springframework.jdbc.datasource.DriverManagerDataSource"><property name = "driverClassName" value = "${driverClass}"></property><property name = "url" value = "${url}"></property><property name = "username" value = "${username}"></property><property name = "password" value = "${password}"></property></bean><!-- 配置 sqlSessionFactory，实现spring和mybatis框架的整合--><bean id = "sqlSessionFactory" class = "org.mybatis.spring.SqlSessionFactoryBean"><property name = "dataSource" ref = "dataSource"></property><property name = "configLocation" value = "classpath:mybatis-config.xml"></property><property name = "mapperLocations" value = "classpath:cn/zyy/paging/xml/*.xml"></property><property name = "typeAliasesPackage" value = "cn.zyy.paging.vo"></property></bean><!-- 配置 MapperScannerConfigurer：将Mapper接口生成代理注入到Spring --><bean class = "org.mybatis.spring.mapper.MapperScannerConfigurer"><property name = "sqlSessionFactoryBeanName" value = "sqlSessionFactory"></property><property name = "basePackage" value = "cn.zyy.paging.dao"></property></bean><!-- 配置事务管理器 --><bean id = "txManage" class = "org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name = "dataSource" ref = "dataSource"></property></bean><!-- 配置事务传播机制 --><tx:advice id = "txAdvice" transaction-manager="txManage"><tx:attributes><tx:method name="*" propagation="REQUIRED"/></tx:attributes></tx:advice><!-- 利用aop实现动态代理 --><aop:config><aop:pointcut expression="execution(* cn.zyy.paging.service.*.*(..))" id="pointcut"/><aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut"/></aop:config><!-- 扫描springmvc不能扫描的service类 --><context:component-scan base-package="cn.zyy.paging.service"></context:component-scan>
</beans>

整个工程的下载地址是：http://download.csdn.net/detail/u011991249/9689207。

注：使用的数据库表很简单，表名称是user，表字段是id（int）、name（varchar）、pwd（varchar）。


这篇关于mybatis框架下物理分页的实现（整个工程采用的是springmvc、spring、mybatis框架，数据库是mysql数据库）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1081183。

相关文章

Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya（不是本人，claude AI）在社交媒体上分享了他在OpenAI学习到的15个Prompt撰写技巧。 以下是详细的内容： 提示精确化:在编写提示时,力求表达清晰准确。清楚地阐述任务需求和概念定义至关重要。例:不用"分析文本",而用"判断这段话的情感倾向:积极、消极还是中性"。 快速迭代:善于快速连续调整提示。熟练的提示工程师能够灵活地进行多轮优化。例:从"总结文章"到"用
阅读更多...
JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
mybatis的整体架构

mybatis的整体架构

mybatis的整体架构分为三层： 1.基础支持层 该层包括：数据源模块、事务管理模块、缓存模块、Binding模块、反射模块、类型转换模块、日志模块、资源加载模块、解析器模块 2.核心处理层 该层包括：配置解析、参数映射、SQL解析、SQL执行、结果集映射、插件 3.接口层 该层包括：SqlSession 基础支持层 该层保护mybatis的基础模块，它们为核心处理层提供了良好的支撑。
阅读更多...
SQL中的外键约束

SQL中的外键约束

外键约束用于表示两张表中的指标连接关系。外键约束的作用主要有以下三点： 1.确保子表中的某个字段（外键）只能引用父表中的有效记录2.主表中的列被删除时，子表中的关联列也会被删除3.主表中的列更新时，子表中的关联元素也会被更新 子表中的元素指向主表 以下是一个外键约束的实例展示
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2