feat: clickhouse user and password add encryptrelease-24.01-rc1

2 files changed, 12 insertions, 2 deletions

diff --git a/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickHouseTableFactory.java b/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickHouseTableFactory.java
index 1230f1f..0465cb1 100644
--- a/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickHouseTableFactory.java
+++ b/platform-base/src/main/java/com/zdjizhi/base/sink/clickhouse/ClickHouseTableFactory.java
@@ -4,6 +4,7 @@ import com.zdjizhi.base.common.CommonConfig;
 import com.zdjizhi.base.config.Configs;
 import com.zdjizhi.base.sink.clickhouse.sink.EventBatchIntervalClickHouseSink;
 import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
+import org.jasypt.encryption.pbe.StandardPBEStringEncryptor;
 
 import java.util.Properties;
 
@@ -19,8 +20,10 @@ public class ClickHouseTableFactory {
         int batchSize = Configs.get(CommonConfig.CLICKHOUSE_BATCH_SIZE);
         long batchIntervalMs = Configs.get(CommonConfig.CLICKHOUSE_BATCH_INTERVAL_MS).toMillis();
         Properties connInfo = new Properties();
-        connInfo.put("user", Configs.get(CommonConfig.CLICKHOUSE_USERNAME));
-        connInfo.put("password", Configs.get(CommonConfig.CLICKHOUSE_PASSWORD));
+        StandardPBEStringEncryptor encryptor = new StandardPBEStringEncryptor();
+        encryptor.setPassword("galaxy");
+        connInfo.put("user", encryptor.decrypt(Configs.get(CommonConfig.CLICKHOUSE_USERNAME)));
+        connInfo.put("password", encryptor.decrypt(Configs.get(CommonConfig.CLICKHOUSE_PASSWORD)));
         return new EventBatchIntervalClickHouseSink(
                 batchSize,
                 batchIntervalMs,
diff --git a/pom.xml b/pom.xml
index 7dba044..bd4a660 100644
--- a/pom.xml
+++ b/pom.xml
@@ -61,6 +61,13 @@
     </repositories>
 
     <dependencies>
+        <!-- https://mvnrepository.com/artifact/org.jasypt/jasypt -->
+        <dependency>
+            <groupId>org.jasypt</groupId>
+            <artifactId>jasypt</artifactId>
+            <version>1.9.3</version>
+        </dependency>
+
         <dependency>
             <groupId>com.google.guava</groupId>
             <artifactId>guava</artifactId>