whyclj
2020-09-24 eef05894ed34d93e60c6d30f82a6d1869e6736fe
src/com/data/PowerArk_Task_SQL.java
@@ -158,7 +158,7 @@
      }
   }
   /**
    * 创建负载信息表
    *    创建负载信息表
    * @param pool
    */
   public static void createTb_Dynamicload_State_rt(MysqlConnPool pool) {
@@ -199,8 +199,19 @@
            "  KEY dev_id_key (dev_id)" + 
            ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";
      Sql_Mysql sql = new Sql_Mysql(pool.getConn());
      ResultSet res = null;
      try {
         sql.sqlMysqlExecute(sql_str);
         //添加记录时间列,方便绘制实时曲线
         res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
               + " WHERE table_schema='db_dynamicsystem'"
               + " AND table_name='tb_dynamicload_state_rt'"
               + " AND column_name='record_time'");
         if(false == res.next()) {
            sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Tb_Dynamicload_State_rt
                  + " ADD COLUMN `record_time`  datetime NOT NULL DEFAULT '2000-01-01 00:00:00' after dev_id;");
         }
      } catch (SQLException e) {
         e.printStackTrace();
      } finally {
@@ -428,7 +439,8 @@
   public static void updateDynamicload_StateTable(MysqlConnPool conn_pool,Dynamicload_state state) {
      String sql_str = " UPDATE  " + Sql_Mysql.Tb_Dynamicload_State_rt 
            + " SET "
            +" start_auto=" + state.getStart_auto()
            +" record_time='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)+"'"
            +",start_auto=" + state.getStart_auto()
            +",stop_auto=" + state.getStop_auto()
            +",sudden_crease=" + state.getSudden_crease()
            +",all_open=" + state.getAll_open()