From 01218fde055b6fcd55f2820caa20cf9dd0c6d7e3 Mon Sep 17 00:00:00 2001 From: Administrator <1525436766@qq.com> Date: 星期二, 09 八月 2022 14:31:02 +0800 Subject: [PATCH] V1.37 edit at date 2022-08-09 1.默认创建'db_pwrdev_data_rt.tb_pwrdev_event'表用于记录山西61850设备的交流输入1/2的状态切换记录 --- BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 56 insertions(+), 0 deletions(-) diff --git a/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java b/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java index 08622dd..cb90000 100644 --- a/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java +++ b/BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Data_Rt.java @@ -15,6 +15,8 @@ createPwrdev_Acdcdata_Table(pool, recreate); createPwrdev_Dcdata_Table(pool, recreate); + + createPwrdev_Event_Table(pool,recreate); } /** @@ -2111,6 +2113,30 @@ sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrdev_Acdcdata_Table + " ADD COLUMN `acIn2_currC` float NOT NULL DEFAULT '0';"); } + + //添加acIn1_switch_st字段 + res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" + + " WHERE table_schema='db_pwrdev_data_rt'" + + " AND table_name='tb_pwrdev_acdcdata'" + + " AND column_name='acIn1_switch_st'"); + if(false == res.next()) { + sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrdev_Acdcdata_Table + + " ADD COLUMN `acIn1_switch_st` int(11) NOT NULL DEFAULT '0' COMMENT '交流输入1分合闸状态:0---未知(用于兼容以前的),1-分闸,2-合闸,3-脱扣',;"); + } + + //添加acIn2_switch_st字段 + res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" + + " WHERE table_schema='db_pwrdev_data_rt'" + + " AND table_name='tb_pwrdev_acdcdata'" + + " AND column_name='acIn2_switch_st'"); + if(false == res.next()) { + sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrdev_Acdcdata_Table + + " ADD COLUMN `acIn2_switch_st` int(11) NOT NULL DEFAULT '0' COMMENT '交流输入2分合闸状态 :0---未知(用于兼容以前的),1-分闸,2-合闸,3-脱扣',;"); + } + + + + } catch (SQLException e) { e.printStackTrace(); } finally { @@ -2180,6 +2206,36 @@ } /** + * 创建 tb_pwrdev_event 表 + * @param pool + * @param recreate + */ + public static void createPwrdev_Event_Table(MysqlConnPool pool, boolean recreate) { + String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Pwrdev_Event_Table; + String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Pwrdev_Event_Table + " (" + + " `num` bigint(20) NOT NULL AUTO_INCREMENT," + + " `power_device_id` int(11) NOT NULL DEFAULT '0' COMMENT '电源ID'," + + " `record_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '记录事件'," + + " `now_state` int(11) NOT NULL DEFAULT '0' COMMENT '当前状态'," + + " `last_state` int(11) NOT NULL DEFAULT '0' COMMENT '上一次状态'," + + " `event_type` int(11) NOT NULL DEFAULT '0' COMMENT '事件类型'," + + " `event_txt` text NOT NULL COMMENT '事件描述'," + + " PRIMARY KEY (`num`)" + + ") ENGINE=InnoDB AUTO_INCREMENT=246 DEFAULT CHARSET=utf8;"; + Sql_Mysql sql = new Sql_Mysql(pool.getConn()); + try { + if(true == recreate) { + sql.sqlMysqlExecute(sql_str01); + } + sql.sqlMysqlExecute(sql_str02); + } catch (SQLException e) { + e.printStackTrace(); + } finally { + sql.close_con(); + } + } + + /** * 创建 tb_pwrdev_acdata 表 * @param pool * @param recreate -- Gitblit v1.9.1