MyBatis-Plus拦截器对敏感数据实现加密

2024-04-02 19:04:59 665人浏览八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录一、定义注解二、定义拦截器类做课程项目petstore时遇到需要加密属性的问题，而mybatis-Plus为开发者提供了拦截器的相关接口，用于与数据库交互的过程中实现特定功能，本

做课程项目petstore时遇到需要加密属性的问题，而mybatis-Plus为开发者提供了拦截器的相关接口，用于与数据库交互的过程中实现特定功能，本文主要介绍通过MyBatis-Plus的拦截器接口自定义一个拦截器类实现敏感数据如用户密码的加密功能，即实现在DAO层写入数据库时传入明文，而数据库中存储的是密文。由于加密算法有多种，这里不展示具体的加密步骤，主要讨论拦截器的构建。

一、定义注解

自定义相关注解，将需要加密的字段及其所在的实体类进行标注，方便拦截器拦截时的判断。这里定义了两个注解(分别形成两个不同的文件)，@SensitiveData和@SensitiveField，分别用于注解实体类、实体类中需要加密的属性。注意，注解@Target内ElementType取值为TYPE时表示该注解用于注解类，取值为FIELD表示该注解用于注解类的属性。


package org.csu.mypetstore.api.utils.encrypt.annotation;

import java.lang.annotation.*;

@Inherited
@Target({ ElementType.TYPE })
@Retention(RetentionPolicy.RUNTIME)
public @interface SensitiveData {
}

二、定义拦截器类

自定义的拦截器类需要实现MyBatis的Interceptor类，主要是重写三个方法public Object intercept(Invocation invocation)、public Object plugin(Object target)、public void setProperties(Properties properties)。这三个方法前两个我们需要使用到，第三个方法这里暂时用不到。

为我们创建的拦截器类打上@Component注解使之被spring容器所管理；打上@Intercepts注解用于标识拦截器开始拦截的情况(执行sql语句过程中的哪个位置)。Mybatis可以在执行语句的过程中对特定对象进行拦截调用，主要有以下四种情况：

Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed) 处理增删改查
ParameterHandler (getParameterObject, setParameters) 设置预编译参数
ResultSetHandler (handleResultSets, handleOutputParameters) 处理结果
StatementHandler (prepare, parameterize, batch, update, query) 处理sql预编译，设置参数

通过@Intercepts注解内部的@Signature注解进行配置，有三个配置选项分别为type、method、args，type用于指定上述四类中的某一类，method用于指定该类型中的哪个方法执行时被拦截，args用于接收被拦截方法的参数。观察注解@Signature的代码可以加深理解：

这里选取ParameterHandler类型的setParameters方法，在每次执行sql之前设置参数前进行拦截加密。整个拦截器类重写intercept方法用于加密、重写plugin方法用于将该拦截器接入拦截器链(这里可以选择不重写plugin方法，因为Interceptor类中定义的该方法默认内容与我们重写的内容是一样的)，代码如下：


package org.csu.mypetstore.api.utils.encrypt;

import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.binding.MapperMethod;
import org.apache.ibatis.executor.parameter.ParameterHandler;
import org.apache.ibatis.plugin.*;
import org.csu.mypetstore.api.utils.encrypt.annotation.SensitiveData;
import org.springframework.core.annotation.AnnotationUtils;
import org.springframework.stereotype.Component;

import java.lang.reflect.Field;
import java.sql.PreparedStatement;
import java.util.Map;
import java.util.Objects;
import java.util.Properties;


@Slf4j
@Component
@Intercepts({
        @Signature(type = ParameterHandler.class, method = "setParameters", args = PreparedStatement.class)
})
public class EncryptInterceptor implements Interceptor {

    // 更新时的参数名称，ParamMap的key值
    private static final String CRYPT = "et";

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        try {
            // @Signature 指定了 type= parameterHandler.class 后，这里的 invocation.getTarget() 便是parameterHandler
            // 若指定ResultSetHandler，这里则能强转为ResultSetHandler
            ParameterHandler parameterHandler = (ParameterHandler) invocation.getTarget();
            // 获取参数对像，即对应MyBatis的 mapper 中 paramsType 的实例
            Field parameterField = parameterHandler.getClass().getDeclaredField("parameterObject");
            parameterField.setAccessible(true);
            // 取出参数实例
            Object parameterObject = parameterHandler.getParameterObject();
            if (parameterObject != null) {
                Object sensitiveObject = null;
                if (parameterObject instanceof MapperMethod.ParamMap) {
                    // 更新操作被拦截
                    Map paramMap = (Map) parameterObject;
                    sensitiveObject = paramMap.get(CRYPT);
                } else {
                    // 插入操作被拦截，parameterObject即为待插入的实体对象
                    sensitiveObject = parameterObject;
                }
                // 获取不到数据就直接放行
                if (Objects.isNull(sensitiveObject)) return invocation.proceed();
                // 校验该实例的类是否被@SensitiveData所注解
                Class<?> sensitiveObjectClass = sensitiveObject.getClass();
                SensitiveData sensitiveData = AnnotationUtils.findAnnotation(sensitiveObjectClass, SensitiveData.class);
                if (Objects.nonNull(sensitiveData)) {
                    // 如果是被注解的类，则进行加密
                    // 取出当前当前类所有字段，传入加密方法
                    Field[] declaredFields = sensitiveObjectClass.getDeclaredFields();
                    EncryptUtil.encrypt(declaredFields, sensitiveObject, EncryptUtil.ENCRYPT_MD5_MODE);
                }
            }
            return invocation.proceed();
        } catch (Exception e) {
            // 未作更多处理，加密失败仍然会放行让数据进入数据库
            log.error("加密失败", e);
        }
        return invocation.proceed();
    }

    @Override
    public Object plugin(Object target) {
        // 将这个拦截器接入拦截器链
        return Plugin.wrap(target, this);
    }

    @Override
    public void setProperties(Properties properties) {}
}

EncryptUtil类的encrypt加密方法的大致处理流程：


static <T> T encrypt(Field[] declaredFields, T sensitiveObject, final int ENCRYPT_MODE) throws IllegalAccessException {
    for (Field field : declaredFields) {
        // 取出所有被SensitiveField注解的字段
        SensitiveField sensitiveField = field.getAnnotation(SensitiveField.class);
        if (Objects.nonNull(sensitiveField)) {
            field.setAccessible(true);
            Object targetProperty = field.get(sensitiveObject);
            // 仅讨论对字符串类型的字段的加密
            if (targetProperty instanceof String) {
                // 取得源字段值
                String value = (String) targetProperty;
                String valueEncrypt;
                if (ENCRYPT_MODE == ENCRYPT_MD5_MODE) {
                    // 使用MD5加密算法进行加密
                    valueEncrypt = EncryptUtil.MD5Encrypt(value);
                } else if (ENCRYPT_MODE == ENCRYPT_AES_MODE) {
                    // 使用AES加密算法进行加密
                    valueEncrypt = EncryptUtil.AESEncrypt(value);
                } else {
                    valueEncrypt = value;
                }
                // 将加密完成的字段值放入待用参数对象
                field.set(sensitiveObject, valueEncrypt);
            }
        }
    }
    return sensitiveObject;
}

构建过程中主要是使用了Java的反射机制来处理。在构建的过程中需要注意的一点是，我们需要在更新、插入时进行加密，但是网上很多方法都是默认为插入时加密，所以取出来的parameterObject对象都是默认为这个表对应的实体类。但是更新操作不同，更新操作时打印parameterObject对象的类型可看到是org.apache.ibatis.binding.MapperMethod$ParamMap，即取出的parameterObject对象是一个ParamMap类，而其中"et"的key对应的value才是我们需要的实体类，因此这里需要通过判断parameterObject对象的类型来分类进行处理。

如果选用的是双向加密算法(可逆)，还可以设计一个用于解密的拦截器类进行处理，选取ResultSetHandler类型的handleResultSets方法，在处理结果集之前进行解密，解密的情况根据具体需求来确定，可以基于selectList方法、基于selectOne方法等等。


package org.csu.mypetstore.api.utils.encrypt;

import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.executor.resultset.ResultSetHandler;
import org.apache.ibatis.plugin.*;
import org.csu.mypetstore.api.utils.encrypt.annotation.SensitiveData;
import org.springframework.core.annotation.AnnotationUtils;
import org.springframework.stereotype.Component;

import java.beans.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.Properties;

@Slf4j
@Component
@Intercepts({
        @Signature(type = ResultSetHandler.class, method = "handleResultSets", args = Statement.class)
})
public class DecryptInterceptor implements Interceptor {
    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        Object resultObject = invocation.proceed();
        try {
            if (Objects.isNull(resultObject)) return null;
            if (resultObject instanceof ArrayList) {
                // 基于selectList
                List resultList = (ArrayList) resultObject;
                if (!resultList.isEmpty() && needToDecrypt(resultList.get(0))) {
                    for (Object result : resultList) {
                        //逐一解密
                        EncryptUtils.decrypt(result);
                    }
                }
            } else {
                // 基于selectOne
                if (needToDecrypt(resultObject)) EncryptUtils.decrypt((String) resultObject);
            }
            return resultObject;
        } catch (Exception e) {
            log.error("解密失败", e);
        }
        return resultObject;
    }

    // 判断是否是需要解密的敏感实体类
    private boolean needToDecrypt(Object object) {
        Class<?> objectClass = object.getClass();
        SensitiveData sensitiveData = AnnotationUtils.findAnnotation(objectClass, SensitiveData.class);
        return Objects.nonNull(sensitiveData);
    }

    @Override
    public Object plugin(Object target) {
        // 将这个拦截器接入拦截器链
        return Plugin.wrap(target, this);
    }

    @Override
    public void setProperties(Properties properties) {}
}

到此这篇关于MyBatis-Plus拦截器对敏感数据实现加密的文章就介绍到这了,更多相关MyBatis-Plus拦截器对敏感数据加密内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: MyBatis-Plus拦截器对敏感数据实现加密

本文链接: https://www.lsjlt.com/news/156775.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

MyBatis-Plus拦截器对敏感数据实现加密

目录一、定义注解二、定义拦截器类做课程项目petstore时遇到需要加密属性的问题，而MyBatis-Plus为开发者提供了拦截器的相关接口，用于与数据库交互的过程中实现特定功能，本...

99+

2024-04-02
mybatis-plus 拦截器敏感字段加解密的实现

目录背景一、查询拦截器二、插入和更新拦截器三、注解背景数据库在保存数据时，对于某些敏感数据需要脱敏或者加密处理，如果一个一个的去加显然工作量大而且容易出错，这个时候可以考虑使用拦截...

99+

2024-04-02
mybatis-plus拦截器敏感字段加解密的实现方法是什么

本篇内容主要讲解“mybatis-plus拦截器敏感字段加解密的实现方法是什么”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“mybatis-plus拦截器敏感字段加解密的实现方法是什么”吧!背景...

99+

2023-06-25
基于Mybatis-Plus拦截器实现MySQL数据加解密

一、背景用户的一些敏感数据，例如手机号、邮箱、身份证等信息，在数据库以明文存储时会存在数据泄露的风险，因此需要进行加密，但存储数据再被取出时，需要进行解密，因此加密算法需要使用对称加密算法。常用的对称加密算法有AES、DES、RC、B...

99+

2023-09-01

数据加密 Mybatis-Plus拦截器对称加密
MyBatis Plus 拦截器实现数据权限控制

一、介绍上篇文章介绍的MyBatis Plus 插件实际上就是用拦截器实现的，MyBatis Plus拦截器对MyBatis的拦截器进行了包装处理，操作起来更加方便二、自定义拦截器 2.1、InnerInterceptor MyBati...

99+

2023-08-20

mybatis java mysql
MyBatis-Plus 使用拦截器实现数据权限控制

前言背景平时开发中遇到根据当前用户的角色，只能查看数据权限范围的数据需求。列表实现方案有两种，一是在开发初期就做好判断赛选，但如果这个需求是中途加的，或不希望每个接口都加一遍，就可以方案二加拦截器的...

99+

2023-09-07

mybatis java
MyBatis-Plus拦截器实现数据权限控制的示例

目录前言背景上代码（基础版）进阶版前言背景平时开发中遇到根据当前用户的角色，只能查看数据权限范围的数据需求。列表实现方案有两种，一是在开发初期就做好判断赛选，但如果这个需求是中途加...

99+

2023-02-24

MyBatis-Plus 权限控制 MyBatis-Plus 拦截器权限控制
Mybatis-Plus实现SQL拦截器的示例

目录起源实现拦截器接口InnerInterceptor修改sql常用的工具类起源最近公司要做多租户，Mybatis-Plus的多租户插件很好用，但是有一个场景是：字典表或者某些数据...

99+

2023-05-19

Mybatis-Plus SQL拦截器 Mybatis-Plus 拦截器
利用Mybatis Plus实现一个SQL拦截器

目录起源实现拦截器接口InnerInterceptor修改sql常用的工具类起源最近公司要做多租户，Mybatis-Plus的多租户插件很好用，但是有一个场景是：字典表或者某些数据...

99+

2023-05-19

Mybatis Plus实现SQL拦截器 Mybatis Plus SQL拦截 Mybatis Plus SQL
详解Mybatis拦截器安全加解密MySQL数据实战

需求背景公司为了通过一些金融安全指标（政策问题）和防止数据泄漏，需要对用户敏感数据进行加密，所以在公司项目中所有存储了用户信息的数据库都需要进行数据加密改造。包括Mysql、red...

99+

2024-04-02
Springboot AOP对指定敏感字段数据加密存储的实现

前言本文主要内容： 1. 插入数据自定义注解方式对指定接口方法的参数的指定字段进行加密存储； 2.对数据内的加密数据，进行解密返回先看看效果：数据存入...

99+

2024-04-02
Mybatis拦截器安全加解密MySQL数据的方法是什么

本文小编为大家详细介绍“Mybatis拦截器安全加解密MySQL数据的方法是什么”，内容详细，步骤清晰，细节处理妥当，希望这篇“Mybatis拦截器安全加解密MySQL数据的方法是什么”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一...

99+

2023-06-26
Java操作MyBatis-Plus通过自定义拦截器对mysql字段以注解形式实现自动加解密

一.需求背景跟大学室友闲谈时，了解到他公司正在做项目内对数据库敏感字段实现自动加解密的需求，使用的技术是Springboot，Mybatis-Plus,MySql等技术栈，加密算法是用的AES，密钥是放在华为云，这里实现一个阉割版的dem...

99+

2023-09-06

mybatis mysql java
springboot+mybatis-plus基于拦截器实现分表的示例代码

目录前言一、设计思路二、实现思路三、代码实现接口描述核心组成部分1.本地线程工具类2.注解部分3.拦截器实现四、测试后记前言最近在工作遇到数据量比较多的情况，单表压力比较大，cru...

99+

2024-04-02
spring boot对敏感信息进行加解密的项目实现

我们使用jasypt最新版本对敏感信息进行加解密。 1.在项目pom文件中加入如下依赖： <dependency> <groupId&...

99+

2023-05-17

springboot敏感信息加解密 springboot敏感信息加密
Mybatis拦截器实现数据权限的示例代码

在我们日常开发过程中，通常会涉及到数据权限问题，下面以我们常见的一种场景举例：一个公司有很多部门，每个人所处的部门和角色也不同，所以数据权限也可能不同，比如超级管理员可以查看某张 ...

99+

2024-04-02
mybatis/mybatis-plus模糊查询语句特殊字符转义拦截器的实现

目录1.使用mybatis提供的拦截器拦截所有的查询请求。 2.定义SQL语句转义模板，分别对Map和Object对象进行处理 mybatis/mybatis-plus模糊查询语句特...

99+

2024-04-02
MyBatis拦截器:给参数对象属性赋值的实例

该拦截器的作用：在进行增加、修改等操作时，给数据模型的一些通用操作属性（如：创建人、创建时间、修改人、修改时间等）自动赋值。该实现是在DAO层拦截，即存入DB前最后一层。后经分析，不是很合理，改为在service层拦截，用spring AO...

99+

2023-05-31

mybatis 拦截器参数
Java通过MySQL的加解密函数实现敏感字段存储

java通过mysql的加解密函数实现敏感字段存储 1.AES加解密工具类： public class AESUtils { public static String e...

99+

2024-04-02
Oracle中如何实现数据加密和数据脱敏

在Oracle数据库中，可以通过以下几种方式来实现数据加密和数据脱敏：使用Oracle Transparent Data En...

99+

2024-04-09

Oracle