doris

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

@@ -28,11 +28,11 @@ public class GreenRadioSink extends RichSinkFunction<Cycle> {
     public void open(Configuration parameters) throws Exception {
         super.open(parameters);
         // path暂定为固定值
-        //String path = ".\\realtime\\hologram-streaming\\src\\main\\resources\\mysql.properties";
-        connection = MySQLUtils.getConnection();
+        String path = ".\\realtime\\hologram-streaming\\src\\main\\resources\\doris.properties";
+        connection = MySQLUtils.getConnection(path);
         String cycleSql="insert into app_cycle_green_ratio" +
-                "(id,cross_id,signal_code,begin_time,end_time,duration,cycle_order,green_ratio,loss_time,statistic_time,record_date,p_month) " +
-                "values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
+                "(id,cross_id,signal_code,begin_time,end_time,duration,cycle_order,green_ratio,loss_time,statistic_time,record_date) " +
+                "values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
         insertCyclePstmt = connection.prepareStatement(cycleSql);
 
         //String phaseSql="insert into app_phase_green_ratio(cycle_order,cross_code,phase_value,begin_time,end_time,duration,phase_order,green_ratio,valid_green,loss_time,update_time) values (?,?,?,?,?,?,?,?,?,?,?)";
@@ -58,7 +58,7 @@ public class GreenRadioSink extends RichSinkFunction<Cycle> {
         insertCyclePstmt.setInt(9, cycle.getLossTime());
         insertCyclePstmt.setString(10, DateUtils.getTodayTime());
         insertCyclePstmt.setString(11, DateUtils.getTodayDate());
-        insertCyclePstmt.setString(12, DateUtils.getCurrentMonth());
+        //insertCyclePstmt.setString(12, DateUtils.getCurrentMonth());
         insertCyclePstmt.execute();
 
         //List<Stage> stageList = cycle.getStageList();