位置：首页>> 软件编程>> java编程>> Spring集成MyBatis 及Aop分页的实现代码

Spring集成MyBatis 及Aop分页的实现代码

作者：LJT_1314520　　发布时间：2022-01-06 14:30:47　

标签：Spring,MyBatis,Aop,分页

一、首先我们先创建一个Maven项目

把我们需要的包先准备好

1.打开pom.xml文件引入依赖，以下是整个pom.xml文件

<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.zking</groupId>
<artifactId>untitled12</artifactId>
<packaging>war</packaging>
<version>1.0-SNAPSHOT</version>
<name>untitled12 Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>


<junit.version>4.12</junit.version>
<servlet.version>4.0.1</servlet.version>

<spring.version>5.3.18</spring.version>

<mybatis.version>3.4.5</mybatis.version>

<mysql.version>8.0.30</mysql.version>

<pagehelper.version>5.1.2</pagehelper.version>

<mybatis.spring.version>1.3.1</mybatis.spring.version>

<commons.dbcp2.version>2.1.1</commons.dbcp2.version>
<commons.pool2.version>2.4.3</commons.pool2.version>

<log4j2.version>2.9.1</log4j2.version>
<slf4j.version>1.7.7</slf4j.version>
<log4j2.disruptor.version>3.2.0</log4j2.disruptor.version>

<lombok.version>1.18.12</lombok.version>
</properties>
<dependencies>

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${junit.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>${servlet.version}</version>
</dependency>




<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>

<groupId>org.mybatis.generator</groupId>

<artifactId>mybatis-generator-core</artifactId>

<version>1.3.5</version>
</dependency>


<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.version}</version>
</dependency>


<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>${mybatis.version}</version>
</dependency>


<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>${pagehelper.version}</version>
</dependency>


<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>${mybatis.spring.version}</version>
</dependency>

<dependency>
<artifactId>druid</artifactId>
<groupId>com.alibaba</groupId>
<version>1.1.10</version>
</dependency>

<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-dbcp2</artifactId>
<version>${commons.dbcp2.version}</version>
<exclusions>
<exclusion>
<artifactId>commons-pool2</artifactId>
<groupId>org.apache.commons</groupId>
</exclusion>
</exclusions>
</dependency>

<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>${commons.pool2.version}</version>
</dependency>


<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>

<dependency>
<artifactId>slf4j-log4j12</artifactId>
<groupId>org.slf4j</groupId>
<version>1.7.25</version>
</dependency>

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lombok.version}</version>
<scope>provided</scope>
</dependency>
</dependencies>
<build>
<finalName>untitled12</finalName>
<plugins>
<plugin>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-maven-plugin</artifactId>
<version>1.3.2</version>
<dependencies>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.version}</version>
</dependency>
</dependencies>
<configuration>
<overwrite>true</overwrite>
</configuration>
</plugin>
</plugins>
</build>
</project>

2.引入依赖之后咱们导入需要的xml文件

1.generatorConfig.xml文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd" >
<generatorConfiguration>

<properties resource="jdbc.properties"/>


<classPathEntry location="D:\config\res\mysql\mysql-connector-java\8.0.30\mysql-connector-java-8.0.30.jar"/>


<context id="infoGuardian">

<commentGenerator>
<property name="suppressAllComments" value="true"/>
<property name="suppressDate" value="true"/> 
</commentGenerator>


<jdbcConnection driverClass="${jdbc.driver}"
connectionURL="${jdbc.url}" userId="${jdbc.username}" password="${jdbc.password}"/>


<javaTypeResolver>

<property name="forceBigDecimals" value="false"/>
</javaTypeResolver>




<javaModelGenerator targetPackage="com.zking.ssm.spring.model"
targetProject="src/main/java">

<property name="enableSubPackages" value="false"/>

<property name="constructorBased" value="true"/>

<property name="trimStrings" value="false"/>

<property name="immutable" value="false"/>
</javaModelGenerator>


<sqlMapGenerator targetPackage="com.zking.ssm.spring.mapper"
targetProject="src/main/resources">

<property name="enableSubPackages" value="false"/>
</sqlMapGenerator>





<javaClientGenerator targetPackage="com.zking.ssm.spring.mapper"
targetProject="src/main/java" type="XMLMAPPER">

<property name="enableSubPackages" value="false"/>
</javaClientGenerator>






<table schema="" tableName="t_student" domainObjectName="Student"
enableCountByExample="false" enableDeleteByExample="false"
enableSelectByExample="false" enableUpdateByExample="false">




</table>
</context>
</generatorConfiguration>

这是生成那些我们的实体类和mapper层还有对应mapper层的配置文件

2.jdbc.properties配置文件

jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/y1?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=UTC
jdbc.username=root
jdbc.password=root123

3.log4j.properties配置文件

log4j.rootLogger=DEBUG, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=％5p ％d ％C: ％m％n
log4j.logger.java.sql.ResultSet=INFO
log4j.logger.org.apache=INFO
log4j.logger.java.sql.Connection=DEBUG
log4j.logger.java.sql.Statement=DEBUG
log4j.logger.java.sql.PreparedStatement=DEBUG

把以上配置好就可以进行生成那些代码了

然后打开Maven这个控制器

然后点击mybatis-generator运行他就行了，然后就会自动给你生成这些代码了

二、开始Spring集成MyBatis

1、首先我们先创建一个MyBatis.xml

<?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>

<settings>
<setting name="logImpl" value="STDOUT_LOGGING"/>
</settings>


<typeAliases>
<package name="com.zking.ssm"/>
</typeAliases>
</configuration>

2、之后就是创建Spring文件这个文件是Spring帮我们管理MyBatis

可能有些东西不同但是这个文件是必备的

<?xml version="1.0" encoding="UTF-8"?>
<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:aop="http://www.springframework.org/schema/aop" xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">


<context:component-scan base-package="com.zking.ssm"/>

<context:property-placeholder location="classpath:jdbc.properties"/>

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<constructor-arg ref="dataSource"/>
</bean>

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
<property name="driverClassName" value="${jdbc.driver}"/>
<property name="url" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>


<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">

<property name="dataSource" ref="dataSource"/>

<property name="mapperLocations" value="classpath:com/zking/ssm/spring/**/mapper/*.xml"/>

<property name="typeAliasesPackage" value="com.zking.spring.model"/>

<property name="configLocation" value="Mybatis.xml"/>


<property name="plugins">
<array>
<bean class="com.github.pagehelper.PageInterceptor">
<property name="properties">

<value>
helperDialect=mysql
</value>
</property>
</bean>
</array>
</property>
</bean>

<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>

<property name="basePackage" value="com/zking/ssm/spring/**/mapper"/>
</bean>













<aop:aspectj-autoproxy/>
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>

接下来就是我们写service来测试这个集成好没有，切记记得改jdbc.properties文件里面的参数和驱动程序要和你本机相同

1.创建IStudent借口

public interface IStudent {
List<Student> listPager(Student student, PageBean pageBean);

List<Student> selectByPager(@Param("student") Student student, PageBean pageBean);
}

2.实现这个借口

@Service
public class StudentImpl implements IStudent {
//依赖注入，不写这个会报空值异常
@Autowired
private StudentMapper studentMapper;

@Override
public List<Student> listPager(Student student, PageBean pageBean) {
return studentMapper.listPager(student, pageBean);
}

@Paging //这是一个分页的注解
@Override
public List<Student> selectByPager(Student student, PageBean pageBean) {
return studentMapper.list(student, pageBean);
}
}

然后就可以去test 目录底下编写测试类了

测试类的编写

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath*:Spring.xml")
public class IStudentTest{
@Autowired
private IStudent iStudent;

@Test
public void Pager() {
Student student = new Student();
student.setSname("");
List<Student> students = iStudent.selectByPager(student, new PageBean());
students.forEach(t -> System.out.println(t));
}
}

然后就是去编写咱们的aop切面编程了

首先我们要一个分页对象

PageBean.java

package com.zking.ssm.spring.util;

import lombok.*;
import lombok.experimental.Accessors;

import javax.servlet.http.HttpServletRequest;
import java.util.Map;

//val : 最终局部变量
//@NonNull : 让你不在担忧并且爱上NullPointerException（可以在参数的类型前面加上注解）
//@CleanUp : 自动资源管理：不用再在finally中添加资源的close方法
//@Setter/@Getter : 自动生成set和get方法
//@ToString : 自动生成toString方法
//@EqualsAndHashcode : 从对象的字段中生成hashCode和equals的实现
//@NoArgsConstructor/@RequiredArgsConstructor/@AllArgsConstructor
//自动生成构造方法
//@Data : 自动生成set/get方法，toString方法，equals方法，hashCode方法，不带参数的构造方法
//@Value : 用于注解final类
//@Builder : 产生复杂的构建器api类
//@SneakyThrows : 异常处理（谨慎使用）
//@Synchronized : 同步方法安全的转化
//@Getter(lazy=true) :
//@Log : 支持各种logger对象，使用时用对应的注解，如：@Log4j
@AllArgsConstructor
@NoArgsConstructor
@ToString
@EqualsAndHashCode
@Accessors(chain = true)
@Data
/**
* 用来放分页的参数
*/
public class PageBean {

private Integer total; //数据库的总条数
private Integer page = 1; //当前页数
private Integer row = 5; //当前显示的条数
private boolean pagination = true; //是否需要分页
private String url;
private Map<String, String[]> ms;

public PageBean(HttpServletRequest req) {
String page = req.getParameter("page");
String row = req.getParameter("row");
if (page != null && page.length() > 0) {
this.setPage(Integer.parseInt(page));
}
if (row != null && row.length() > 0) {
this.setRow(Integer.parseInt(row));
}
String pagination = req.getParameter("pagination");
if (pagination != null && pagination.equals("false")) {
this.setPagination(false);
}
this.ms = req.getParameterMap();
}

/**
* 计算开始位置
*/
public Integer start() {
return (page - 1) * row;
}

/**
* 计算最大页数
*/
public Integer max() {
return total ％ row == 0 ? total / row : total / row + 1;
}

/**
* 计算下一页
*/
public Integer next() {
return Math.min(page + 1, max());
}

/**
* 计算上一页
*/
public Integer prev() {
return Math.max(page - 1, 1);
}
}

然后我们要编写aop切面编程了

PageAspect.java

package com.zking.ssm.spring.aop;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.zking.ssm.spring.util.PageBean;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

import java.util.List;

/**
* @author小李飞刀
* @site www.xiaomage.com
* @company xxx公司
* @create 2023-03-30 16:33
*/
@Component
@Aspect
public class PageAspect {
@Around("execution(* *..*Service.*Pager(..))")
public Object invoke(ProceedingJoinPoint joinPoint) throws Throwable {
//获取目标方法的执行参数
Object[] args = joinPoint.getArgs();
//定义PageBean对象
PageBean pageBean = null;
for (Object param : args) {
//判断执行参数中是否有PageBean对象
if (param instanceof PageBean) {
pageBean = (PageBean) param;
break;
}
}
//判断是否分页
if (pageBean != null && pageBean.isPagination()) {
PageHelper.startPage(pageBean.getPage(), pageBean.getRow());
}
Object returnValue = joinPoint.proceed(args);

if (pageBean != null && pageBean.isPagination()) {
if (null != returnValue && returnValue instanceof List) {
List list = (List) returnValue;
PageInfo pageInfo = new PageInfo(list);
pageBean.setTotal((int) pageInfo.getTotal());
}
}
return returnValue;
}
}

@Around("execution(* *..*Service.*Pager(..))")的意思是环绕通知然后里面的是必须是打了@Service注解的类才能识别到，*Pager就是以Pager结尾的前面所以的名字都可以识别到，然后（..）是方法参数不限制

编写好之后

就可以去测试了

但是这样会有识别不到的风险

所以咱们使用注解进行分页

package com.zking.ssm.spring.aop;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.zking.ssm.spring.util.PageBean;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

import java.util.List;

/**
* @author小李飞刀
* @site www.xiaomage.com
* @company xxx公司
* @create 2023-04-01 8:44
*/
@Component
@Aspect
public class PagerAop {
//环绕通知自定义注解分辨是否调用
@Around("@annotation(com.zking.ssm.spring.interfaces.Paging)")
public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
//获取目标方法的所有参数
Object[] args = joinPoint.getArgs();
PageBean pag = null;
for (Object arg : args) {
if (arg instanceof PageBean) {
pag = (PageBean) arg;
if (pag != null && pag.isPagination()) {
PageHelper.startPage(pag.getPage(), pag.getRow());
}
}
}
Object proceed = joinPoint.proceed();
if (pag != null && pag.isPagination()) {
PageInfo info = new PageInfo((List) proceed);
pag.setTotal((int) info.getTotal());
}
return proceed;
}
}

然后就是写@Paging

//编译加载
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD, ElementType.PARAMETER})
public @interface Paging {

}

然后就可以在你要实现的类中打上注解就行了

来源：https://blog.csdn.net/LJT_1314520/article/details/129893691

投稿