蓄电池监控管理平台数据库初始化程序
Administrator
2021-01-19 cbe11e1b664acc48cc55639eabbdd194c810af5a
修改
1个文件已修改
20 ■■■■■ 已修改文件
BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Inf.java 20 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
BattMonitor_DB_Builder/src/com/database_util/DB_Pwrdev_Inf.java
@@ -1,5 +1,6 @@
package com.database_util;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.sql.MysqlConnPool;
@@ -91,6 +92,7 @@
                "  `SqlDB_BackUpTime` datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," + 
                "  `SqlDB_BackUpManual_EN` tinyint(1) NOT NULL DEFAULT '0'," + 
                "  `AppServer_Reinit_PowerData_EN` tinyint(1) NOT NULL DEFAULT '0'," + 
                "  `AppServer_Reinit_BattGroupData_EN` tinyint(1) NOT NULL DEFAULT '0'," +
                "  `AppServer_Reinit_Config_EN` tinyint(1) NOT NULL DEFAULT '0'," + 
                "  `AppServer_Version` float NOT NULL DEFAULT '1'," + 
                "  `AppClient_Version` float NOT NULL DEFAULT '1'," + 
@@ -98,14 +100,32 @@
                "  PRIMARY KEY (`num`)" + 
                ") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;";
        Sql_Mysql sql = new Sql_Mysql(pool.getConn());
        ResultSet res = null;
        try {
            if(true == recreate) {            
                sql.sqlMysqlExecute(sql_str01);
            }
            sql.sqlMysqlExecute(sql_str02);        
            //添加字段AppServer_Reinit_PowerData_Charger_EN
            res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
                    + " WHERE table_schema='db_pwrdev_inf'"
                    + " AND table_name='tb_pwrapp_sys'"
                    + " AND column_name='AppServer_Reinit_BattGroupData_EN'");
            if(false == res.next()) {
                sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrapp_Sys_Table
                        + " ADD COLUMN `AppServer_Reinit_BattGroupData_EN` tinyint(1) NOT NULL DEFAULT '0';");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(null != res) {
                try {
                    res.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            sql.close_con();
        }
    }