MOD:clickhouse 数据存取修改

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/clickhouse/sink/ClickhouseUtil.java

@@ -1,20 +1,28 @@
 package flink.zanxiangnet.ad.monitoring.clickhouse.sink;
 
+import flink.zanxiangnet.ad.monitoring.kafka.KafkaProperties;
 import ru.yandex.clickhouse.settings.ClickHouseProperties;
 
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
+import java.util.Properties;
 
 public class ClickhouseUtil {
     private static Connection connection;
+//    public static class database{
+//        public static
+//    }
 
-    public static Connection getConn(String host, String port, String database) throws ClassNotFoundException, SQLException {
-        Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
+    public static Connection getConn(Properties props,String host, String port, String database) throws ClassNotFoundException, SQLException {
 
-        ClickHouseProperties properties = new ClickHouseProperties();
-        String user = "qc";
-        String password = "Qc_123456";
+        String clickhouseUrl = props.getProperty("clickhouse.url");
+        String clickhouseUser = props.getProperty("clickhouse.username");
+        String clickhousePassword = props.getProperty("clickhouse.password");
+
+        Class.forName(clickhouseUrl);
+        String user = clickhouseUser;
+        String password = clickhousePassword;
 
         String address = "jdbc:clickhouse://" + host + ":" + port + "/" + database;
         connection = DriverManager.getConnection(address, user, password);