数据脱敏

Author: chengxy-nds

springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/contoller/UserController.java

@@ -0,0 +1,46 @@
+package com.xiaofu.sharding.contoller;
+
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.xiaofu.sharding.mapper.ConfigRepository;
+import com.xiaofu.sharding.mapper.OrderItemRepository;
+import com.xiaofu.sharding.mapper.OrderRepository;
+import com.xiaofu.sharding.mapper.UserRepository;
+import com.xiaofu.sharding.model.TConfig;
+import com.xiaofu.sharding.model.TOrder;
+import com.xiaofu.sharding.model.TOrderDto;
+import com.xiaofu.sharding.model.TUser;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+
+@Controller
+@RequestMapping
+public class UserController {
+
+    @Autowired
+    private UserRepository userRepository;
+
+    @GetMapping(value = "/insertUser")
+    @ResponseBody
+    public String insertUser() {
+
+        TUser user = new TUser();
+        user.setUserId(100L);
+        user.setUserName("程序员内点事");
+        user.setMobileNo("1316656565");
+        userRepository.insert(user);
+
+
+        List<TUser> tUsers = userRepository.selectList(null);
+        return JSON.toJSONString(tUsers);
+    }
+}

springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/mapper/UserRepository.java

@@ -0,0 +1,13 @@
+package com.xiaofu.sharding.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xiaofu.sharding.model.TUser;
+import org.apache.ibatis.annotations.Mapper;
+
+
+@Mapper
+public interface UserRepository extends BaseMapper<TUser> {
+
+}
+

springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/model/TUser.java

@@ -0,0 +1,21 @@
+package com.xiaofu.sharding.model;
+
+import lombok.Data;
+
+@Data
+public class TUser {
+
+    private Long userId;
+
+    private String userName;
+
+    private String userNameCipher;
+
+    private String userNamePlain;
+
+    private String mobileNo;
+
+    private String mobileNoPlain;
+
+    private String mobileNoCipher;
+}

springboot-sharding-jdbc/src/main/resources/application.properties

@@ -36,20 +36,6 @@ spring.shardingsphere.sharding.tables.t_order.key-generator.props.worker.id=0000
 # 时钟回拨最大容忍值
 spring.shardingsphere.sharding.tables.t_order.key-generator.max.tolerate.time.difference.milliseconds=5
 
-# 数据脱敏--设置加密器
-spring.shardingsphere.encrypt.encryptors.phone_encryptor.type=aes
-spring.shardingsphere.encrypt.encryptors.phone_encryptor.props.aes.key.value=123456
-spring.shardingsphere.encrypt.encryptors.phone_encryptor.qualifiedColumns = t_order.phone_no
-
-
-# 数据脱敏--密文字段和明文字段
-spring.shardingsphere.encrypt.tables.t_order.columns.phone_no.plainColumn=phone_no_plain
-spring.shardingsphere.encrypt.tables.t_order.columns.phone_no.cipherColumn=phone_no_cipher
-spring.shardingsphere.encrypt.tables.t_order.columns.phone_no.encryptor=phone_encryptor
-
-# 数据脱敏--查询时是否查询密文
-spring.shardingsphere.props.query.with.cipher.comlum=true
-
 # 配置分片表 t_order_item
 spring.shardingsphere.sharding.tables.t_order_item.actual-data-nodes=ds-$->{0..1}.t_order_item_$->{0..2}
 spring.shardingsphere.sharding.tables.t_order_item.database-strategy.inline.sharding-column=order_id
@@ -77,5 +63,15 @@ mybatis-plus.map-underscore-to-camel-case=true
 # 开启热部署（更改文件后，自动重启）
 spring.devtools.restart.enabled=true
 
+# 数据脱敏--设置加密器
+spring.shardingsphere.encrypt.encryptors.user_name_encryptor.type=aes
+spring.shardingsphere.encrypt.encryptors.user_name_encryptor.props.aes.key.value=123456
+# 数据脱敏--密文字段和明文字段
+
+spring.shardingsphere.encrypt.tables.t_user.columns.user_name.plainColumn=user_name_plain
+spring.shardingsphere.encrypt.tables.t_user.columns.user_name.cipherColumn=user_name_cipher
+spring.shardingsphere.encrypt.tables.t_user.columns.user_name.encryptor=user_name_encryptor
 
+# 数据脱敏--查询时是否查询密文
+spring.shardingsphere.props.query.with.cipher.comlum=true
 

springboot-sharding-jdbc/src/main/resources/generator/generatorConfig.xml

@@ -33,7 +33,7 @@
             <property name="enableSubPackages" value="false"/>
         </javaClientGenerator>
 
-        <table  tableName="t_order_1" enableCountByExample="false" enableDeleteByExample="false"
+        <table  tableName="t_user" enableCountByExample="false" enableDeleteByExample="false"
                enableSelectByExample="false" enableUpdateByExample="false"/>
     </context>
 </generatorConfiguration>

springboot-sharding-jdbc/src/main/resources/mapping/TUserMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xiaofu.sharding.mapper.UserRepository">
+
+</mapper>