蓄电池监控管理平台数据库初始化程序
在db_app_sys.tb_app_sys表中添加AppServer_Reinit_BattGroupData_LD9_EN字段用于9度设备重载设备数据
2个文件已修改
32 ■■■■ 已修改文件
BattMonitor_DB_Builder/src/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.java 19 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
BattMonitor_DB_Builder/src/com/battdata_rt/BattData_RT_RamDB_Thread_SQL.java
@@ -388,7 +388,7 @@
    /************************************************************************************************/
    /************************************************************************************************/
    /**
     * 让主程序重新导入单体数据关键字改成true
     *     让主程序重新导入单体数据关键字改成true
     * @param conn_pool
     */
    public static boolean updateTb_App_Sys_AppServerTable(MysqlConnPool conn_pool)
@@ -400,17 +400,20 @@
            conn.setAutoCommit(false);
            sql.sqlMysqlUseDB(Sql_Mysql.DB_AppSys);
            if(true == sql.sqlMysqlCheckIfTableExist(Sql_Mysql.TB_AppSys)) {
                String sql_str0 = "SELECT AppServer_Reinit_BattGroupData_EN FROM db_app_sys.tb_app_sys ";
                ResultSet rs = sql.sqlMysqlQuery(sql_str0);
                if(rs.next()) {
                    if(rs.getBoolean("AppServer_Reinit_BattGroupData_EN") == false) {
                //String sql_str0 = "SELECT AppServer_Reinit_BattGroupData_EN FROM db_app_sys.tb_app_sys ";
                //ResultSet rs = sql.sqlMysqlQuery(sql_str0);
                //if(rs.next()) {
                //    if(rs.getBoolean("AppServer_Reinit_BattGroupData_EN") == false) {
                        //System.out.println("修改数据库中的是否重载数据");
                        String sql_str_1 = "UPDATE " + Sql_Mysql.AppSys_Table + " SET " 
                                + " AppServer_Reinit_BattGroupData_EN = 1";
                                + " AppServer_Reinit_BattGroupData_EN = 1,"
                                + " AppServer_Reinit_BattGroupData_LD9_EN = 1"
                                + " WHERE num > 0"
                                ;
                        sql.sqlMysqlExecute(sql_str_1);
                        flag = true;
                    }
                }
                //    }
                //}
            }
            conn.setAutoCommit(true);
        } catch (SQLException e) {
BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java
@@ -207,6 +207,7 @@
                        + "`SqlDB_BackUpTime` DATETIME NOT NULL DEFAULT '2000-1-1 00:00:00',"
                        + "`SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false, "
                        + "`AppServer_Reinit_BattGroupData_EN` BOOLEAN NOT NULL DEFAULT false, "
                        + "`AppServer_Reinit_BattGroupData_LD9_EN` BOOLEAN NOT NULL DEFAULT false, "            //用于9度程序重新加载设备
                        + "`AppServer_Reinit_Config_EN` BOOLEAN NOT NULL DEFAULT false, "
                        + "`AppServer_Version` FLOAT NOT NULL DEFAULT '1.0',"
                        + "`AppClient_Version` FLOAT NOT NULL DEFAULT '1.0',"
@@ -528,6 +529,18 @@
                            + " ADD COLUMN `AppServer_Reinit_Config_EN` BOOLEAN NOT NULL DEFAULT false"
                            + " AFTER `AppServer_Reinit_BattGroupData_EN`");
            }
            /**************************** db_app_sys 表中添加 AppServer_Reinit_BattGroupData_LD9_EN 列(用于LD9主程序动态加载设备参数) *******************************************/
            res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns"
                    + " WHERE table_schema='db_app_sys'"
                    + " AND table_name='tb_app_sys'"
                    + " AND column_name='AppServer_Reinit_BattGroupData_LD9_EN'");
            if(false == res0.next()) {
            sqlMysqlExecute("ALTER TABLE " + AppSys_Table
                            + " ADD COLUMN `AppServer_Reinit_BattGroupData_LD9_EN` BOOLEAN NOT NULL DEFAULT false"
                            + " AFTER `AppServer_Reinit_BattGroupData_EN`");
            }
        //---------------------------------------------------------------------------------------------//
        
        sqlMysqlExecute(table_1);