MyBatis-Plus 自動加密解密
通過使用MyBatis的typeHandler功能，對入?yún)⒑统鰠⑦M(jìn)行處理，實現(xiàn)無縫加密解密（將明文加密后保存至數(shù)據(jù)庫；從數(shù)據(jù)庫讀取時，自動將密文解密成明文）
實現(xiàn)TypeHandler
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
@Slf4jpublic class UserTypeHandler extends BaseTypeHandler<Object> { /** * 非空字段加密 * @param preparedStatement * @param i * @param parameter * @param jdbcType * @throws SQLException */ @Override public void setNonNullParameter(PreparedStatement preparedStatement, int i, Object parameter, JdbcType jdbcType) { try { if (StrUtil.isBlank((String) parameter)) { return; } // todo 加密操作 String encrypt = ""; preparedStatement.setString(i, encrypt); } catch (Exception e) { log.error("typeHandler加密異常：" + e); } } /** * 非空字段解密 * @param resultSet * @param columnName * @return * @throws SQLException */ @Override public Object getNullableResult(ResultSet resultSet, String columnName) throws SQLException { String col = resultSet.getString(columnName); try { if (StrUtil.isBlank(col)) { return col; } // todo 對結(jié)果col進(jìn)行解密操作 return ""; } catch (Exception e) { log.error("typeHandler解密異常：" + e); } return col; } /** * 可空字段加密 * @param resultSet * @param columnIndex * @return * @throws SQLException */ @Override public Object getNullableResult(ResultSet resultSet, int columnIndex) throws SQLException { String col = resultSet.getString(columnIndex); try { if (StrUtil.isBlank(col)) { return col; } // todo 對結(jié)果col進(jìn)行解密操作 return ""; } catch (Exception e) { log.error("typeHandler解密異常：" + e); } return col; } /** * 可空字段解密 * @param callableStatement * @param columnIndex * @return * @throws SQLException */ @Override public Object getNullableResult(CallableStatement callableStatement, int columnIndex) throws SQLException { String col = callableStatement.getString(columnIndex); try { if (StrUtil.isBlank(col)) { return col; } // todo 對結(jié)果col進(jìn)行解密操作 return ""; } catch (Exception e) { log.error("typeHandler解密異常：" + e); } return col; }} |
添加注解
在對應(yīng)的實體類中
- 在 @TableName 注解中，設(shè)置 autoResultMap 參數(shù)為true
- 在需要加解密的字段上，添加注解 @TableField(typeHandler = UserTypeHandler.class)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@Data@TableName(value = "t_user", autoResultMap = true)public class UserEntity { /** * 主鍵自增 */ @TableId(type = IdType.AUTO) private Integer id; private String name; private Integer age; @TableField(typeHandler = UserTypeHandler.class) private String password; private String role;} |
查詢加密字段
MyBatis-Plus的QueryWrapper在查詢加密字段時，并不會進(jìn)入TypeHandler，需要手寫sql，指定字段進(jìn)行TypeHandler中的流程。
注解方式
|
1
2
3
4
5
|
@Results(id= "resultMap", value = { @Result(column = "password", property = "password", typeHandler = UserTypeHandler.class)})@Select("select * from t_user where password = #{password, typeHandler=com.mybatisdemo.config.UserTypeHandler}")List<UserEntity> list(UserQuery userQuery); |
XML方式
|
1
2
3
4
5
6
|
<resultMap id="userMap" type="com.mybatisdemo.entity.UserEntity"> <result column="password" property="password" typeHandler="com.mybatisdemo.config.UserTypeHandler" /></resultMap><select id="list" resultMap="userMap"> select * from t_user where password = #{password,typeHandler=com.mybatisdemo.config.UserTypeHandler}</select> |
MyBatis-Plus 敏感數(shù)據(jù)的加密
最近在做項目，需要實現(xiàn)對身份證,密碼等敏感數(shù)據(jù)的加密，即不能以明文存儲密碼到數(shù)據(jù)庫。
上網(wǎng)查了一下資料，解決辦法如下：
寫加密解密的工具類
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
import org.apache.commons.codec.binary.Base64;import javax.crypto.Cipher;import javax.crypto.spec.IvParameterSpec;import javax.crypto.spec.SecretKeySpec;public class AES { // 密鑰 public static String key = "AD42F6697B035B7580E4FEF93BE20BAD"; private static String charset = "utf-8"; // 偏移量 private static int offset = 16; private static String transformation = "AES/CBC/PKCS5Padding"; private static String algorithm = "AES"; /** * 加密 * * @param content * @return */ public static String encrypt(String content) { return encrypt(content, key); } /** * 解密 * * @param content * @return */ public static String decrypt(String content) { return decrypt(content, key); } /** * 加密 * * @param content 需要加密的內(nèi)容 * @param key 加密密碼 * @return */ public static String encrypt(String content, String key) { try { SecretKeySpec skey = new SecretKeySpec(key.getBytes(), algorithm); IvParameterSpec iv = new IvParameterSpec(key.getBytes(), 0, offset); Cipher cipher = Cipher.getInstance(transformation); byte[] byteContent = content.getBytes(charset); cipher.init(Cipher.ENCRYPT_MODE, skey, iv);// 初始化 byte[] result = cipher.doFinal(byteContent); return new Base64().encodeToString(result); // 加密 } catch (Exception e) { // LogUtil.exception(e); } return null; } /** * AES（256）解密 * * @param content 待解密內(nèi)容 * @param key 解密密鑰 * @return 解密之后 * @throws Exception */ public static String decrypt(String content, String key) { try { SecretKeySpec skey = new SecretKeySpec(key.getBytes(), algorithm); IvParameterSpec iv = new IvParameterSpec(key.getBytes(), 0, offset); Cipher cipher = Cipher.getInstance(transformation); cipher.init(Cipher.DECRYPT_MODE, skey, iv);// 初始化 byte[] result = cipher.doFinal(new Base64().decode(content)); return new String(result); // 解密 } catch (Exception e) { //LogUtil.exception(e); } return null; } public static void main(String[] args) throws Exception { String s = "hello world"; // 加密 System.out.println("加密前：" + s); String encryptResultStr = encrypt(s); System.out.println("加密后：" + encryptResultStr); // 解密 System.out.println("解密后：" + decrypt(encryptResultStr)); }} |
繼承BaseTypeHandler ，實現(xiàn)對數(shù)據(jù)的轉(zhuǎn)換
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
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;/** * @author starmark * @date 19-12-17 下午8:38 */public class AESEncryptHandler extends BaseTypeHandler { @Override public void setNonNullParameter(PreparedStatement ps, int i, Object parameter, JdbcType jdbcType) throws SQLException { ps.setString(i, AES.encrypt((String)parameter)); } @Override public String getNullableResult(ResultSet rs, String columnName) throws SQLException { String columnValue = rs.getString(columnName); return AES.decrypt(columnValue); } @Override public String getNullableResult(ResultSet rs, int columnIndex) throws SQLException { String columnValue = rs.getString(columnIndex); return AES.decrypt(columnValue); } @Override public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException { String columnValue = cs.getString(columnIndex); return AES.decrypt(columnValue); }} |
有po類中，實現(xiàn)相關(guān)類型注解
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
/** * 用戶管理 */@Data@EqualsAndHashCode(callSuper = false)@TableName(autoResultMap = true)public class SysOrgUser extends BaseUpdateModel { /** * 登陸帳戶 */ private String loginName; /** * 密碼 */ @TableField(typeHandler = AESEncryptHandler.class) private String password; |
至此，密碼等敏感信息已處理好。
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/YW_Danny/article/details/120031966
