ClickHouse Connector必须参数加上用户名和密码

2 files changed, 15 insertions, 2 deletions

diff --git a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseConnectorOptions.java b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseConnectorOptions.java
index 3ae2414..28ac94d 100644
--- a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseConnectorOptions.java
+++ b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseConnectorOptions.java
@@ -5,6 +5,8 @@ import org.apache.flink.configuration.ConfigOptions;
 
 import java.time.Duration;
 
+import static com.geedgenetworks.connectors.clickhouse.ClickHouseConnectorOptionsUtil.CONNECTION_INFO_PREFIX;
+
 public class ClickHouseConnectorOptions {
     public static final ConfigOption<String> TABLE =
             ConfigOptions.key("table")
@@ -24,11 +26,20 @@ public class ClickHouseConnectorOptions {
                     .defaultValue(100000)
                     .withDescription("The flush max size , over this number of records, will flush data.");
 
-    public static final ConfigOption<Duration>  BATCH_INTERVAL =
+    public static final ConfigOption<Duration> BATCH_INTERVAL =
             ConfigOptions.key("batch.interval")
                     .durationType()
                     .defaultValue(Duration.ofSeconds(30))
                     .withDescription("The flush interval mills, over this time, asynchronous threads will flush data.");
 
-
+    public static final ConfigOption<String> CONNECTION_USER =
+            ConfigOptions.key(CONNECTION_INFO_PREFIX + "user")
+                    .stringType()
+                    .noDefaultValue()
+                    .withDescription("Required clickhouse connection user.");
+    public static final ConfigOption<String> CONNECTION_PASSWORD =
+            ConfigOptions.key(CONNECTION_INFO_PREFIX + "password")
+                    .stringType()
+                    .noDefaultValue()
+                    .withDescription("Required clickhouse connection password.");
 }
diff --git a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseTableFactory.java b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseTableFactory.java
index 1fca98a..438286c 100644
--- a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseTableFactory.java
+++ b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/ClickHouseTableFactory.java
@@ -58,6 +58,8 @@ public class ClickHouseTableFactory implements SinkTableFactory {
         final Set<ConfigOption<?>> options = new HashSet<>();
         options.add(HOST);
         options.add(TABLE);
+        options.add(CONNECTION_USER);
+        options.add(CONNECTION_PASSWORD);
         return options;
     }