优化通过druid获取数据库连接池

realtime/hologram-streaming/src/main/java/com/zhht/irn/sink/GreenRadioSink.java

@@ -4,6 +4,7 @@ import com.zhht.irn.entity.Cycle;
 import com.zhht.irn.entity.Stage;
 import com.zhht.irn.utils.DateUtils;
 import com.zhht.irn.utils.DorisUtils;
+import com.zhht.irn.utils.DruidConnectPoolUtils;
 import com.zhht.irn.utils.MySQLUtils;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
@@ -30,7 +31,7 @@ public class GreenRadioSink extends RichSinkFunction<Cycle> {
         super.open(parameters);
         // path暂定为固定值
         //String path = ".\\realtime\\hologram-streaming\\src\\main\\resources\\doris.properties";
-        connection = DorisUtils.getConnection();
+        connection = DruidConnectPoolUtils.getConncent();
         String cycleSql="insert into app_cycle_green_ratio" +
                 "(id,cycle_order,cross_id,signal_code,begin_time,end_time,duration,green_ratio,loss_time,statistic_time,record_date) " +
                 "values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";