栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java MyBatis typeHandler 敏感数据加密解密

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java MyBatis typeHandler 敏感数据加密解密

业务场景

敏感信息(姓名、身份证)存入数据库时应当需要加密,防止被恶意访问数据库时暴露信息。

解决方案

由于项目数据库中间件使用的是Mybatis,所以使用Mybatis中的baseTypeHandler的一个类型处理器,对数据进行AES加密存入数据

加密方法

package com.cdyl.utils;

import org.apache.commons.lang.StringUtils;
import sun.misc.base64Decoder;
import sun.misc.base64Encoder;

import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;


public class DataDesensitizationUtils {

    private static final String OTHER_LOGIN_KEY = "8ce87b8ec346ff4c80635f667d1592ae";

    
    public static String encrypt(String text) {
        try {
            byte[] plaintext = text.getBytes();
            IvParameterSpec ivspec = new IvParameterSpec(OTHER_LOGIN_KEY.substring(16).getBytes());
            SecretKeySpec keyspec = new SecretKeySpec(OTHER_LOGIN_KEY.substring(0, 16).getBytes(), "AES");
            Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
            cipher.init(Cipher.ENCRYPT_MODE, keyspec, ivspec);
            byte[] encrypted = cipher.doFinal(plaintext);
            return new base64Encoder().encode(encrypted).trim();
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }


    
    public static String decrypt(String text) {
        try {
            byte[] encrypted1 = new base64Decoder().decodeBuffer(text);
            Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
            SecretKeySpec keyspec = new SecretKeySpec(OTHER_LOGIN_KEY.substring(0, 16).getBytes(), "AES");
            IvParameterSpec ivspec = new IvParameterSpec(OTHER_LOGIN_KEY.substring(16).getBytes());
            cipher.init(Cipher.DECRYPT_MODE, keyspec, ivspec);
            byte[] original = cipher.doFinal(encrypted1);
            String originalString = new String(original);
            return originalString.trim();
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    // 手机号码前三后四脱敏
    public static String mobileEncrypt(String mobile) {
        if (StringUtils.isEmpty(mobile) || (mobile.length() != 11)) {
            return mobile;
        }
        return mobile.replaceAll("(\d{3})\d{4}(\d{4})", "$1****$2");
    }


}
实现baseTypeHandler
package com.cdyl.utils;

import org.apache.commons.lang.StringUtils;
import org.apache.ibatis.type.baseTypeHandler;
import org.apache.ibatis.type.JdbcType;

import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;


public class AESTypeHandler extends baseTypeHandler {

    
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, Object parameter, JdbcType jdbcType) {
        try {
            if (StringUtils.isBlank((String) parameter)) return;

            ps.setString(i, DataDesensitizationUtils.encrypt((String) parameter));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public Object getNullableResult(ResultSet rs, String columnName) throws SQLException {
        String col = rs.getString(columnName);
        try {
            if (StringUtils.isBlank(col)) return col;

            return DataDesensitizationUtils.decrypt(col);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return col;
    }

    
    @Override
    public Object getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        String col = rs.getString(columnIndex);
        try {
            if (StringUtils.isBlank(col)) return col;
            return DataDesensitizationUtils.encrypt(col);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return col;
    }


    
    @Override
    public Object getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        String col = cs.getString(columnIndex);
        try {
            if (StringUtils.isBlank(col)) return col;
            return DataDesensitizationUtils.decrypt(col);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return col;
    }

}
 
Mapper中使用 



    
    
    
    
    
     
        insert into info
        
            real_name,
        
        
            
                #{realName,jdbcType=VARCHAR,typeHandler=com.jmx.utils.AESTypeHandler},
            
        
    
   
    
    
结果

 

转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号