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

数据留痕的方法

     在项目中,数据变更时,经常需要记录上次的数据,以便查看对比,专业术语叫做数据留痕。数据变更留痕(即记录数据的变更历史)是一个常见的需求,例如在审计、追踪数据变化或满足合规性要求的场景中。以下是数据留痕几种常见的实现方式:


1. 手动记录变更日志

在业务代码中手动记录数据变更的日志,将变更前后的数据保存到日志表或日志文件中。

实现步骤:

  1. 在数据变更的地方(如更新、删除操作)手动记录变更前后的数据。

  2. 将变更信息保存到数据库的日志表或日志文件中。

示例代码:

public class UserService {@Autowiredprivate UserRepository userRepository;@Autowiredprivate AuditLogRepository auditLogRepository;public void updateUser(User newUser) {// 获取旧数据User oldUser = userRepository.findById(newUser.getId()).orElseThrow();// 更新数据userRepository.save(newUser);// 记录变更日志AuditLog auditLog = new AuditLog();auditLog.setAction("UPDATE");auditLog.setEntityName("User");auditLog.setEntityId(newUser.getId());auditLog.setOldValue(oldUser.toString()); // 旧数据auditLog.setNewValue(newUser.toString()); // 新数据auditLog.setChangeTime(new Date());auditLogRepository.save(auditLog);}
}

优点:

  • 实现简单,直接控制日志内容。

  • 灵活性高,可以根据需求定制日志格式。

缺点:

  • 代码侵入性强,需要在每个变更点手动添加日志记录。

  • 容易遗漏,维护成本较高。


2. 使用AOP(面向切面编程)

通过AOP在数据变更的方法上添加切面,自动记录变更日志。

实现步骤:

  1. 定义一个切面,拦截数据变更的方法(如updatedelete)。

  2. 在切面中获取方法的参数和返回值,记录变更前后的数据。

示例代码:

@Aspect
@Component
public class DataChangeAspect {@Autowiredprivate AuditLogRepository auditLogRepository;@AfterReturning(pointcut = "execution(* com.example.service.UserService.updateUser(..))", returning = "result")public void logDataChange(JoinPoint joinPoint, Object result) {Object[] args = joinPoint.getArgs();User newUser = (User) args[0]; // 获取新数据User oldUser = (User) result;  // 获取旧数据// 记录变更日志AuditLog auditLog = new AuditLog();auditLog.setAction("UPDATE");auditLog.setEntityName("User");auditLog.setEntityId(newUser.getId());auditLog.setOldValue(oldUser.toString()); // 旧数据auditLog.setNewValue(newUser.toString()); // 新数据auditLog.setChangeTime(new Date());auditLogRepository.save(auditLog);}
}

优点:

  • 代码侵入性低,集中管理日志逻辑。

  • 灵活,可以根据需求定制切面。

缺点:

  • 需要熟悉AOP编程。

  • 可能增加系统复杂性。

3. 使用数据库触发器

通过数据库触发器在数据变更时自动记录历史数据。

实现步骤:

  1. 在数据库中创建触发器,监听目标表的变更(如 INSERTUPDATEDELETE)。

  2. 在触发器中将变更前后的数据插入到历史表中。

示例 SQL:

CREATE TABLE users_history (id INT PRIMARY KEY AUTO_INCREMENT,user_id INT,name VARCHAR(255),email VARCHAR(255),action VARCHAR(10),change_time TIMESTAMP
);CREATE TRIGGER trg_user_history
AFTER UPDATE ON users
FOR EACH ROW
BEGININSERT INTO users_history (user_id, name, email, action, change_time)VALUES (OLD.id, OLD.name, OLD.email, 'UPDATE', NOW());
END;

优点:

  • 与应用程序解耦,数据库层面实现。

  • 无需修改业务代码。

缺点:

  • 触发器可能影响数据库性能。

  • 调试和维护复杂。


4. 使用事件监听机制

通过 Spring 的事件监听机制,在数据变更时发布事件并记录日志。

实现步骤:

  1. 定义一个事件类(如 DataChangeEvent)。

  2. 在数据变更的地方发布事件。

  3. 监听事件并记录日志。

示例代码:

事件类:
@Data
public class DataChangeEvent {private String entityName;private Long entityId;private String oldValue;private String newValue;}
发布事件:
@Service
public class UserService {@Autowiredprivate ApplicationEventPublisher eventPublisher;public void updateUser(User newUser) {User oldUser = userRepository.findById(newUser.getId()).orElseThrow();userRepository.save(newUser);// 发布事件DataChangeEvent event = new DataChangeEvent("User", newUser.getId(), oldUser.toString(), newUser.toString());eventPublisher.publishEvent(event);}
}
监听事件:
@Component
public class DataChangeListener {@Autowiredprivate AuditLogRepository auditLogRepository;@EventListenerpublic void handleDataChangeEvent(DataChangeEvent event) {AuditLog auditLog = new AuditLog();auditLog.setAction("UPDATE");auditLog.setEntityName(event.getEntityName());auditLog.setEntityId(event.getEntityId());auditLog.setOldValue(event.getOldValue());auditLog.setNewValue(event.getNewValue());auditLog.setChangeTime(new Date());auditLogRepository.save(auditLog);}
}

优点:

  • 解耦业务逻辑和日志记录。

  • 灵活,支持异步处理。

缺点:

  • 需要熟悉 Spring 事件机制。

  • 可能增加系统复杂性。


5.总结

方式优点缺点适用场景
手动记录日志简单直接,灵活性高代码侵入性强,维护成本高小型项目,简单需求
AOP代码侵入性低,集中管理日志逻辑需要熟悉 AOP,可能增加复杂性需要集中管理日志的中大型项目
数据库触发器与应用程序解耦,无需修改代码调试复杂,可能影响性能数据库层面的审计需求
事件监听机制解耦业务逻辑,支持异步处理需要熟悉 Spring 事件机制需要解耦和异步处理的场景

    根据项目需求和技术栈选择合适的方式。

    如果项目使用 Hibernate,推荐使用 Envers;如果需要解耦业务逻辑,可以使用 AOP 或事件监听机制;如果希望与应用程序解耦,可以使用数据库触发器。

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

相关文章:

  • 机器学习数学基础:19.线性相关与线性无关
  • ArgoCD实战指南:GitOps驱动下的Kubernetes自动化部署与Helm/Kustomize集成
  • JVM虚拟机以及跨平台原理
  • 【AIGC提示词系统】基于 DeepSeek R1 + ClaudeAI 易经占卜系统
  • 电路笔记 : opa 运放失调电压失调电流输入偏置电流 + 反向放大器的平衡电阻 R3 = R1 // R2 以减小输出直流噪声
  • ScrapeGraphAI颠覆传统网络爬虫技术
  • 通过多层混合MTL结构提升股票市场预测的准确性,R²最高为0.98
  • java将list转成树结构
  • 互联网分布式ID解决方案
  • xinference 安装(http导致错误解决)
  • 334递增的三元子序列贪心算法(思路解析+源码)
  • 【Linux】29.Linux 多线程(3)
  • 利用UNIAPP实现短视频上下滑动播放功能
  • vscode+CMake+Debug实现 及权限不足等诸多问题汇总
  • 【提示词工程】探索大语言模型的参数设置:优化提示词交互的技巧
  • 基于 .NET 8.0 gRPC通讯架构设计讲解,客户端+服务端
  • 6.Centos7上部署flask+SQLAlchemy+python+达梦数据库
  • 【C语言系列】深入理解指针(5)
  • mysql自连接 处理层次结构数据
  • ##__VA_ARGS__有什么作用
  • 鸿蒙 router.back()返回不到上个页面
  • 深度学习模型蒸馏技术的发展与应用
  • STM32G0B1 ADC DMA normal
  • <tauri><rust><GUI>基于rust和tauri,在已有的前端框架上手动集成tauri示例
  • 模型 冗余系统(系统科学)
  • Deepseek部署的模型参数要求
  • AI-学习路线图-PyTorch-我是土堆
  • [LeetCode]day17 349.两个数组的交集
  • axios 发起 post请求 json 需要传入数据格式
  • linux交叉编译paho-mqtt-c