Spring Boot集成ShardingSphere实现数据加密及数据脱敏 | Spring Cloud 48

@Configuration
public class ShardingSphereConfig {

    @Bean
    public EncryptRuleConfiguration getEncryptRuleConfiguration() {
        EncryptorRuleConfiguration encryptorConfig = new EncryptorRuleConfiguration("AES", "xxx", "xxx");
        EncryptColumnRuleConfiguration columnConfig = new EncryptColumnRuleConfiguration("encrypt_assistant", "age", "age_cipher", "age_plain", "");
        Map<String, EncryptColumnRuleConfiguration> columns = Collections.singletonMap("age", columnConfig);
        EncryptTableRuleConfiguration tableConfig = new EncryptTableRuleConfiguration(columns);
        Map<String, EncryptTableRuleConfiguration> tables = Collections.singletonMap("t_encrypt_assistant", tableConfig);
        return new EncryptRuleConfiguration(Collections.singleton(encryptorConfig), tables);
    }

    @Bean
    public Properties getShardingSphereProperties() {
        Properties properties = new Properties();
        // 配置加密的密钥
        properties.setProperty("encryptor.encryptor.key.value", "xxx");
        return properties;
    }

    @Bean
    public EncryptRule encryptRule(final EncryptRuleConfiguration encryptRuleConfiguration, final Properties properties) throws SQLException {
        return new EncryptRule(encryptRuleConfiguration, properties);
    }
}