| | |
| | | } |
| | | } |
| | | /** |
| | | * 创建负载信息表 |
| | | * 创建负载信息表 |
| | | * @param pool |
| | | */ |
| | | public static void createTb_Dynamicload_State_rt(MysqlConnPool pool) { |
| | |
| | | " 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 { |
| | |
| | | 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() |