From eef05894ed34d93e60c6d30f82a6d1869e6736fe Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期四, 24 九月 2020 14:43:09 +0800
Subject: [PATCH] 建表时添加record_time字段
---
src/com/data/PowerArk_Task_SQL.java | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/src/com/data/PowerArk_Task_SQL.java b/src/com/data/PowerArk_Task_SQL.java
index e453e89..099a74e 100644
--- a/src/com/data/PowerArk_Task_SQL.java
+++ b/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()
--
Gitblit v1.9.1