whyclj
2020-09-24 eef05894ed34d93e60c6d30f82a6d1869e6736fe
建表时添加record_time字段
1个文件已修改
16 ■■■■ 已修改文件
src/com/data/PowerArk_Task_SQL.java 16 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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()