关于ShardingSphere官网的坑-----java配置实现数据脱敏（或数据分片）

左手的ㄟ右手 2023-01-06 11:39 146阅读 0赞

跟大家分享一下

## 用ShardingSphere实现数据脱敏 ##

根据官网上的数据脱敏功能，添加依赖，我用的是4.1.0版本：

<dependency>
                <groupId>org.apache.shardingsphere</groupId>
                <artifactId>sharding-jdbc-core</artifactId>
                <version>4.1.0</version>
     </dependency>

然后用Java配置：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1bnh1bmZz_size_16_color_FFFFFF_t_70]

其中有一句代码是这样的：

DataSource getEncryptDataSource() throws SQLException {
        
            return EncryptDataSourceFactory.createDataSource(DataSourceUtil.createDataSource("demo_ds"), getEncryptRuleConfiguration(), new Properties());
        }

*DataSourceUtil.createDataSource(“demo\_ds”)* 这里会报红~~~

因为这个DataSourceUtil类是要自己写的~~~

这个类如果没有写，这里就配置不了！！！！！

坑！！！！！！！！！

找了好久，才在网上找到这个类的代码，感谢那位分享的大佬！！！1

我贴一下这个类，免得大家踩坑  
*创建数据源的工具类:*

package com.irisian.sharedjdbc.masterandslave;
    
    import javax.sql.DataSource;
    
    import com.alibaba.druid.pool.DruidDataSource;
    
    public class DataSourceUtil {
        
        private static final String URL_PREFIX = "jdbc:mysql://localhost:3306/";
    
        private static final String USER_NAME = "root";
    
        private static final String PASSWORD = "123456";
    
        public static DataSource createDataSource(final String dataSourceName) {
        
        DruidDataSource result = new DruidDataSource();
    
            result.setDriverClassName(com.mysql.jdbc.Driver.class.getName());
    
            result.setUrl(URL_PREFIX + dataSourceName);
    
            result.setUsername(USER_NAME);
    
            result.setPassword(PASSWORD);
    
            return result;
    
        }
    
    }

这样写了这个类，就可以用官网的代码进行Java配置了！

在开源的代码中看到这个类是这样写的：

import com.zaxxer.hikari.HikariDataSource;
    
    import javax.sql.DataSource;
    
    public final class DataSourceUtil {
        
        
        private static final String HOST = "localhost";
        
        private static final int PORT = 3306;
        
        private static final String USER_NAME = "root";
        
        private static final String PASSWORD = "";
        
        public static DataSource createDataSource(final String dataSourceName) {
        
            HikariDataSource result = new HikariDataSource();
            result.setDriverClassName("com.mysql.jdbc.Driver");
            result.setJdbcUrl(String.format("jdbc:mysql://%s:%s/%s?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=UTF-8", HOST, PORT, dataSourceName));
            result.setUsername(USER_NAME);
            result.setPassword(PASSWORD);
            return result;
        }
    }

参考：  
[shareding-jdbc实现读写分离最简单的容易理解示例][shareding-jdbc]

[ShardingSphere官网\_数据脱敏\_JAVA配置][ShardingSphere_JAVA]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1bnh1bmZz_size_16_color_FFFFFF_t_70]: /images/20221119/2d8228f142914278bf81bbff1938c62e.png
[shareding-jdbc]: https://blog.csdn.net/wumanxin2018/article/details/80212424?utm_source=blogxgwz1
[ShardingSphere_JAVA]: https://shardingsphere.apache.org/document/legacy/4.x/document/cn/manual/sharding-jdbc/configuration/config-java/#%E6%95%B0%E6%8D%AE%E8%84%B1%E6%95%8F