蓄电池监控管理平台数据库初始化程序
Administrator
2021-04-27 67f32697f497227b398c28f7a5076d495952bc24
添加用户数据库的初始化
2个文件已修改
27 ■■■■ 已修改文件
BattMonitor_DB_Builder/config.xml 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
BattMonitor_DB_Builder/src/com/database_util/DB_Ram_db.java 25 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
BattMonitor_DB_Builder/config.xml
@@ -2,7 +2,7 @@
<root>
  <mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
  <mysql_server_ip>192.168.10.221</mysql_server_ip>
  <mysql_server_ip>127.0.0.1</mysql_server_ip>
  <!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
  <!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->
  <!--SOURCE_BATTDATA_TYPE_C_INTERFACE = 2-->
BattMonitor_DB_Builder/src/com/database_util/DB_Ram_db.java
@@ -129,13 +129,7 @@
                sql.sqlMysqlExecute(sql_str1);
            }
            sql.sqlMysqlExecute(sql_str2);
            //移除之前的以设备id分组的设备id唯一索引
            res = sql.sqlMysqlQuery("show INDEX FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE KEY_name = 'unique_dev_id'");
            if(res.next()) {
                sql.sqlMysqlExecute("alter table "+Sql_Mysql.FBS9100s_fod_state+" drop index unique_dev_id;");
            }
            //添加剩余时间(组1)
            res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
                    + " WHERE table_schema='db_ram_db'"
@@ -329,6 +323,11 @@
                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.FBS9100s_fod_state 
                                + " ADD COLUMN BattGroupId int(11) NOT NULL DEFAULT '0' COMMENT '电池组id' AFTER dev_id");
            }
            //移除之前的以设备id分组的设备id唯一索引
            res = sql.sqlMysqlQuery("show INDEX FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE KEY_name = 'unique_dev_id'");
            if(res.next()) {
                sql.sqlMysqlExecute("alter table "+Sql_Mysql.FBS9100s_fod_state+" drop index unique_dev_id;");
            }
            //添加电池组id为唯一索引
            res = sql.sqlMysqlQuery("show INDEX FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE KEY_name = 'unique_BattGroupId'");
            if(!res.next()) {
@@ -336,6 +335,18 @@
                sql.sqlMysqlExecute("DELETE FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE num>0");            
                sql.sqlMysqlExecute("alter table "+Sql_Mysql.FBS9100s_fod_state+" add UNIQUE unique_BattGroupId(BattGroupId);");
            }
            //移除之前的以设备id分组的设备id唯一索引
            /*res = sql.sqlMysqlQuery("show INDEX FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE KEY_name = 'unique_BattGroupId'");
            if(res.next()) {
                sql.sqlMysqlExecute("alter table "+Sql_Mysql.FBS9100s_fod_state+" drop index unique_BattGroupId;");
            }
            //添加修复设备id为唯一索引
            res = sql.sqlMysqlQuery("show INDEX FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE KEY_name = 'unique_dev_id'");
            if(!res.next()) {
                //添加唯一索引前先删除表中记录
                sql.sqlMysqlExecute("DELETE FROM "+Sql_Mysql.FBS9100s_fod_state+" WHERE num>0");
                sql.sqlMysqlExecute("alter table "+Sql_Mysql.FBS9100s_fod_state+" add UNIQUE unique_dev_id(dev_id);");
            }*/
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {