当前位置: 首页 > news >正文

Springboot中基于注解实现公共字段自动填充

1.使用场景

 当我们有大量的表需要管理公共字段,并且希望提高开发效率和确保数据一致性时,使用这种自动填充方式是很有必要的。它可以达到一下作用
  • 统一管理数据库表中的公共字段:如创建时间、修改时间、创建人ID、修改人ID等,这些字段在所有表中都会存在,需要在插入和更新时保持一致性。

  • 避免重复代码:在不同的业务逻辑中频繁操作相同的字段(如每次插入记录时手动设置创建时间和创建人),使用自动填充可以避免手动填写这些字段,减少重复代码。

  • 提高开发效率:当项目中有大量类似的插入或更新操作时,通过自动填充机制可以减轻手动维护字段的负担,提高开发效率和代码的可维护性。

  • 确保数据的准确性:通过切面统一处理公共字段的填充,减少人为错误,确保创建时间、修改时间等字段始终准确。

2.步骤(以商城数据维护项目为例)

2.1  定义一个枚举类 OperationType

  这个类用于表示数据库操作的类型。枚举包含两个常量:

  1. UPDATE:表示更新操作。
  2. INSERT:表示插入操作。

枚举类通常用于标识某个操作是插入还是更新操作,方便在代码中进行逻辑判断或执行特定操作(如公共字段的自动填充),来让我在不同的数据库操作类型中统一处理。

package com.sky.enumeration;/*** 数据库操作类型*/
public enum OperationType {/*** 更新操作*/UPDATE,/*** 插入操作*/INSERT
}

2.2 定义名为 AutoFill 的自定义注解

自定义注解用于标识某个方法需要进行公共字段的自动填充。注解包含一个刚才定义 OperationType 枚举值,用于指定该方法对应的数据库操作类型,是插入还是更新。

我下面对重要内容进行解释

  1. @Target(ElementType.METHOD):标注该注解只能应用在方法上。
  2. @Retention(RetentionPolicy.RUNTIME):指定该注解在运行时保留,可以通过反射机制获取该注解。
  3. OperationType value():这个方法定义了注解的一个属性,必须设置 OperationType 枚举值(INSERTUPDATE),来表示操作类型。
package com.sky.annotation;import com.sky.enumeration.OperationType;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** 自定义注解,用于标识某个方法需要进行功能字段自动填充*/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface AutoFill {// 数据库操作类型:UPDATE 或 INSERTOperationType value();
}

这个自定义注解的主要作用是在特定的数据库操作方法上使用,通过指定操作类型(插入或更新),结合其他逻辑实现公共字段的自动填充。

2.3 定义名为 AutoFillAspect 的切面类

这个类用于处理带有 @AutoFill 注解的方法,通过定义切面,切入点,前置通知实现

import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;/*** 自定义切面,实现公共字段自动填充处理逻辑*/
@Aspect
@Component
@Slf4j
public class AutoFillAspect {/*** 切入点*/@Pointcut("execution(* com.sky.mapper.*.*(..)) && @annotation(com.sky.annotation.AutoFill)")public void autoFillPointCut() {}/*** 前置通知,在通知中进行公共字段的赋值*/@Before("autoFillPointCut()")public void autoFill(JoinPoint joinPoint){log.info("开始进行公共字段自动填充...");}    
}
  1. @Aspect:声明该类是一个切面类,负责切入业务逻辑并执行相应操作。
  2. @Component:将这个类注册为Spring的组件,以便在应用程序中自动管理和注入。
  3. @Slf4j:启用日志记录功能,方便在切面逻辑中记录日志(当前代码中没有具体使用日志)。
  4. @Pointcut:定义切入点,拦截我com.sky.mapper包下所有带有 @AutoFill 注解的方法。即拦截那些需要自动填充公共字段的数据库操作方法。
  5. @Before("autoFillPointCut()"):表示该方法会在切入点方法执行之前执行,这里切入点是那些符合 autoFillPointCut 定义的带有 @AutoFill 注解的方法。
  6. JoinPoint 参数JoinPoint 是AOP的一个接口,允许在切面中获取被拦截方法的相关信息(如方法名、参数等),便于进行逻辑处理。

那么当我们此时定义好切面后,对于我们自定义的这个auto fill这个注解,需要把它加到我们XXX Mapper的mybatis文件上面。

2.4  插入数据的Mapper方法(我这边以员工数据维护为例)

在我们特定数据库操作(Insert,Update)上使用了@AutoFill注解,指定了操作类型为OperationType.INSERT(UPDATE),意味着该方法会在插入数据或者更新数据时自动填充创建时间和创建人等公共字段。

//INSERT
@Insert("insert into employee (name, username, password, phone, sex, id_number, create_time, update_time, create_user, update_user) " +"values (#{name}, #{username}, #{password}, #{phone}, #{sex}, #{idNumber}, #{createTime}, #{updateTime}, #{createUser}, #{updateUser})")
@AutoFill(value = OperationType.INSERT)
void insert(Employee employee);//UPDATE
@AutoFill(value = OperationType.UPDATE)
void update(Employee employee);

这边当调用 insert(Employee employee) 方法时,SQL插入语句将会执行,并且在插入之前,通过上面自定义 @AutoFill 注解的拦截逻辑自动为 create_timecreate_user 字段赋值。

2.5 切面类中autoFill方法逻辑完成

在上面2.3步骤中我们只是对下面方法进行Log输入,在这个步骤进一步完善通知中逻辑,下面的步骤都是在此方法中实现
    @Before("autoFillPointCut()")public void autoFill(JoinPoint joinPoint){log.info("开始进行公共字段自动填充...");}   
2.5.1 需要获取 @AutoFill 注解的值,以判断当前操作是插入还是更新。
MethodSignature signature = (MethodSignature) joinPoint.getSignature();
AutoFill autoFill = signature.getMethod().getAnnotation(AutoFill.class);
OperationType operationType = autoFill.value();
  1. MethodSignature signature = (MethodSignature) joinPoint.getSignature():通过 JoinPoint 获取方法签名。
  2. AutoFill autoFill = signature.getMethod().getAnnotation(AutoFill.class):通过反射方法签名获取 @AutoFill 注解。
  3. OperationType operationType = autoFill.value():从注解中获取操作类型,判断是 INSERT 还是 UPDATE

2.5.2 获取实体对象

接下来获取当前方法的参数,因为实体对象是作为方法参数传入的。
Object[] args = joinPoint.getArgs();
if (args == null || args.length == 0) {return;
}
Object entity = args[0]; 
  1. Object[] args = joinPoint.getArgs():获取当前方法的参数列表。通常参数的第一个就是实体对象。
  2. Object entity = args[0]:假设实体对象是第一个参数,将其提取出来进行后续的字段赋值操作。

2.5.3 准备数据

为了填充公共字段,首先需要获取当前时间和当前用户ID。通常这些信息是从上下文环境或安全机制中获取的。
LocalDateTime now = LocalDateTime.now();
Long currentId = BaseContext.getCurrentId();
  1. LocalDateTime now = LocalDateTime.now():获取当前时间,用于设置 createTimeupdateTime
  2. Long currentId = BaseContext.getCurrentId():通过 BaseContext 获取当前操作的用户ID,用于设置 createUserupdateUser

2.5.3  根据操作类型自动填充字段

如果操作类型是 INSERT,那么需要为四个字段赋值:createTimecreateUserupdateTimeupdateUser
if (operationType == OperationType.INSERT) {try {Method setCreateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_TIME, LocalDateTime.class);Method setCreateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_USER, Long.class);Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class);Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);setCreateTime.invoke(entity, now);setCreateUser.invoke(entity, currentId);setUpdateTime.invoke(entity, now);setUpdateUser.invoke(entity, currentId);} catch (Exception e) {throw new RuntimeException(e);}
}
  1. Method setCreateTime = entity.getClass().getDeclaredMethod(...):通过反射机制,获取实体对象的 setCreateTime 方法。
  2. setCreateTime.invoke(entity, now):通过反射调用 setCreateTime 方法,将当前时间 now 赋值给 createTime 字段。这里使用反射动态调用实体类中的 set 方法为指定字段赋值,从而实现灵活的字段处理。
  3. setCreateUsersetUpdateTimesetUpdateUser 也执行相同操作,分别赋值给实体的 createUserupdateTimeupdateUser 字段。
如果操作类型是 UPDATE,则只需要为 updateTimeupdateUser 两个字段赋值。
else if (operationType == operationType.UPDATE) {try {Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class);Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);setUpdateTime.invoke(entity, now);setUpdateUser.invoke(entity, currentId);} catch (Exception e) {throw new RuntimeException(e);}
}
  1. 通过反射获取 setUpdateTimesetUpdateUser 方法,并分别为 updateTimeupdateUser 字段赋值。
  2. 更新操作不需要设置 createTimecreateUser,因为这些字段只在插入时赋值。

总结:通过以上步骤实现公共字段填充,这样做其实是为了简化代码,减少重复操作,确保创建和修改相关字段在插入和更新操作中自动且一致地被赋值。

http://www.lryc.cn/news/449563.html

相关文章:

  • Android 已经过时的方法用什么新方法替代?
  • 【RocketMQ】MQ与RocketMQ介绍
  • 【笔记】自动驾驶预测与决策规划_Part4_时空联合规划
  • Linux指令收集
  • 《C++并发编程实战》笔记(五)
  • 在Python中实现多目标优化问题(5)
  • 【Linux:共享内存】
  • 今年Java回暖了吗
  • a = Sw,其中a和w是向量,S是矩阵,求w等于什么?w可以写成关于a和S的什么样子的公式
  • 多线程事务管理:Spring Boot 实现全局事务回滚
  • Vue3 中集成海康 H5 监控视频播放功能
  • Linux: eBPF: libbpf-bootstrap-master 编译
  • 1.1.4 计算机网络的分类
  • 周家庄智慧旅游小程序
  • 【在Linux世界中追寻伟大的One Piece】命名管道
  • 如意控物联网项目-ML307R模组软件及硬件调试环境搭建
  • 大模型分布式训练并行技术(九)-总结
  • uniapp view设置当前view之外的点击事件
  • 【Mybatis篇】动态SQL的详细带练
  • 【MyBatis-Plus】 学习记录 常用功能及代码生成器使用
  • HalconDotNet实现OCR详解
  • 手搓一个Agent#Datawhale 组队学习Task3
  • 基于SpringBoot+Vue+MySQL的在线酷听音乐系统
  • 大数据实时数仓Hologres(一):Hologres 简单介绍
  • 【鸿蒙HarmonyOS NEXT】数据存储之分布式键值数据库
  • 基于springboot+小程序的儿童预防接种预约管理系统(疫苗1)(源码+sql脚本+视频导入教程+文档)
  • 计算物理精解【8】-计算原理精解【5】
  • 【Linux】 tcp | 解除服务器对tcp连接的限制 | 物联网项目配置
  • 如何隐藏Windows10「安全删除硬件」里的USB无线网卡
  • 【QT Quick】基础语法:导入外部JS文件及调试