| | |
| | | package com.database_util;
|
| | |
|
| | | import java.sql.ResultSet;
|
| | | import java.sql.SQLException;
|
| | |
|
| | | import com.sql.MysqlConnPool;
|
| | | import com.sql.Sql_Mysql;
|
| | |
|
| | | /**
|
| | | * 构建db_battinf数据库中的数据库表 录入在该数据库中新添加的数据库表
|
| | | * @author LiJun
|
| | | *
|
| | | */
|
| | | public class DB_battinf {
|
| | | public static void init(MysqlConnPool pool, boolean recreate) {
|
| | | createDB_battinf(pool); //创建db_battinf 数据库 不存在则创建db_battinf数据库
|
| | | |
| | | createBattInf_Table(pool, recreate); //创建电池组信息配置表
|
| | | |
| | | createBattinfApply_table(pool, recreate); //创建机房安装审批表
|
| | | |
| | | createBattinfEx_TABLE(pool, recreate); //创建基站信息
|
| | | |
| | | createDeverrorRecord_Table(pool, recreate); //创建机房问题记录表
|
| | | |
| | | createBattinfRebuild_TABLE(pool, recreate); //创建机房配组记录表
|
| | | |
| | | createBattmonTestcap_TABLE(pool, recreate); //创建标准测试曲线表
|
| | |
|
| | | createBattcurr_Inf_TABLE(pool, recreate);
|
| | | |
| | | createBatt_Maint_Process_TABLE(pool, recreate);
|
| | | |
| | | createBatt_Maint_Inf_TABLE(pool, recreate);
|
| | | |
| | | createBatt_Alm_Param_TABLE(pool, recreate);
|
| | | }
|
| | |
|
| | | /**
|
| | | * 创建 db_battinf 数据库
|
| | | * @param pool
|
| | | */
|
| | | public static void createDB_battinf(MysqlConnPool pool) {
|
| | | Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
| | | try {
|
| | | sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_BATT_INF);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建机房安装审批表
|
| | | */
|
| | | public static void createBattinfApply_table(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfApply_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattinfApply_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " apply_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " confrim_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " apply_date datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + |
| | | " apply_en int(11) NOT NULL DEFAULT '0'," + |
| | | " apply_note varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationid varchar(64) NOT NULL DEFAULT '0'," + |
| | | " stationname varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname1 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname2 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname3 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname4 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname5 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname6 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname7 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname8 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname9 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationip varchar(64) NOT NULL DEFAULT '127.0.0.1'," + |
| | | " FbsDeviceId int(11) NOT NULL DEFAULT '0'," + |
| | | " FbsDeviceIp varchar(64) NOT NULL DEFAULT '127.000.000.001'," + |
| | | " FbsDeviceIp_YM varchar(64) NOT NULL DEFAULT '255.255.255.0'," + |
| | | " FbsDeviceIp_WG varchar(64) NOT NULL DEFAULT '127.0.0.1'," + |
| | | " FBSDeviceName varchar(64) NOT NULL DEFAULT '设备名称'," + |
| | | " GroupIndexInFBSDevice int(11) NOT NULL DEFAULT '1'," + |
| | | " BattGroupId int(11) NOT NULL DEFAULT '0'," + |
| | | " BattGroupNum int(11) NOT NULL DEFAULT '2'," + |
| | | " BattGroupName varchar(64) NOT NULL DEFAULT '电池组1'," + |
| | | " FloatVolLevel float NOT NULL DEFAULT '54'," + |
| | | " OfflineVolLevel float NOT NULL DEFAULT '42.9'," + |
| | | " BattFloatCurrent float NOT NULL DEFAULT '5'," + |
| | | " MonCount int(11) NOT NULL DEFAULT '24'," + |
| | | " MonCapStd float NOT NULL DEFAULT '300'," + |
| | | " MonVolStd float NOT NULL DEFAULT '2'," + |
| | | " MonResStd float NOT NULL DEFAULT '0.2'," + |
| | | " MonSerStd float NOT NULL DEFAULT '5000'," + |
| | | " MonVolLowToAvg float NOT NULL DEFAULT '0.05'," + |
| | | " Load_curr float NOT NULL DEFAULT '15'," + |
| | | " DisCurrMax float NOT NULL DEFAULT '0'," + |
| | | " station_phone varchar(64) NOT NULL DEFAULT ''," + |
| | | " BattProducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " BattModel varchar(64) NOT NULL DEFAULT ''," + |
| | | " BattProductDate datetime NOT NULL DEFAULT '2018-09-18 00:00:00'," + |
| | | " BattInUseDate datetime NOT NULL DEFAULT '2018-09-18 00:00:00'," + |
| | | " install_user varchar(64) NOT NULL DEFAULT ''," + |
| | | " check_en int(11) NOT NULL DEFAULT '0'," + |
| | | " check_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " longitude double NOT NULL DEFAULT '0'," + |
| | | " latitude double NOT NULL DEFAULT '0'," + |
| | | " address varchar(256) NOT NULL DEFAULT ''," + |
| | | " PRIMARY KEY (num)," + |
| | | " UNIQUE KEY BattGroupId_index (BattGroupId) USING BTREE," + |
| | | " KEY FbsDeviceId_index (FbsDeviceId)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 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();
|
| | | }
|
| | | }
|
| | | /**
|
| | | * 创建基站信息表
|
| | | */
|
| | | public static void createBattinfEx_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfEx_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattinfEx_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " StationId varchar(20) NOT NULL DEFAULT '0' COMMENT '机房id'," + |
| | | " FBSDeviceId bigint(20) NOT NULL DEFAULT '0' COMMENT '设备id'," + |
| | | " StationName varchar(100) NOT NULL DEFAULT '' COMMENT '机房名称'," + |
| | | " stationCode varchar(100) NOT NULL DEFAULT '' COMMENT '站址编码'," + |
| | | " stationRegion varchar(100) NOT NULL DEFAULT '' COMMENT '所属区域'," + |
| | | " keyWords varchar(100) NOT NULL DEFAULT '' COMMENT '关键字'," + |
| | | " affiliation varchar(100) NOT NULL DEFAULT '' COMMENT '所属组织'," + |
| | | " dataSources varchar(100) NOT NULL DEFAULT '' COMMENT '数据来源'," + |
| | | " stationType varchar(100) NOT NULL DEFAULT '' COMMENT '站址类型'," + |
| | | " longitude double NOT NULL DEFAULT '0' COMMENT '经度'," + |
| | | " latitude double NOT NULL DEFAULT '0' COMMENT '纬度'," + |
| | | " stationAddr varchar(100) NOT NULL DEFAULT '' COMMENT '站址地址'," + |
| | | " stationLevel varchar(100) NOT NULL DEFAULT '' COMMENT '站址等级'," + |
| | | " maintenanceState varchar(100) NOT NULL DEFAULT '' COMMENT '维护状态'," + |
| | | " blockedState tinyint(4) NOT NULL DEFAULT '0' COMMENT '封锁状态'," + |
| | | " maintenanceCompany varchar(100) NOT NULL DEFAULT '' COMMENT '维护单位'," + |
| | | " businessScenario varchar(100) NOT NULL DEFAULT '' COMMENT '业务场景'," + |
| | | " CoverScenario varchar(100) NOT NULL DEFAULT '' COMMENT '覆盖场景'," + |
| | | " siteTerrain varchar(100) NOT NULL DEFAULT '' COMMENT '站址地形'," + |
| | | " propertyRights varchar(100) NOT NULL DEFAULT '' COMMENT '产权性质'," + |
| | | " propertyUnit varchar(100) NOT NULL DEFAULT '' COMMENT '产权单位'," + |
| | | " isShare tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否共享'," + |
| | | " useUnit varchar(100) NOT NULL DEFAULT '' COMMENT '使用单位'," + |
| | | " siteCode varchar(100) NOT NULL DEFAULT '' COMMENT '物理站址编码'," + |
| | | " historySiteCode varchar(100) NOT NULL DEFAULT '' COMMENT '历史物理站址编码'," + |
| | | " siteInternalNumber varchar(100) NOT NULL DEFAULT '' COMMENT '站址内部编码'," + |
| | | " sitePinyinReferred varchar(100) NOT NULL DEFAULT '' COMMENT '站址拼音简称'," + |
| | | " siteChineseReferred varchar(100) NOT NULL DEFAULT '' COMMENT '中文简称'," + |
| | | " siteMergeRecord varchar(100) NOT NULL DEFAULT '' COMMENT '站址合并记录'," + |
| | | " isOpenBusiness varchar(16) NOT NULL DEFAULT '' COMMENT '是否开通业务'," + |
| | | " schoolPersonnel varchar(64) NOT NULL DEFAULT '' COMMENT '录入人员'," + |
| | | " entryTime varchar(64) NOT NULL DEFAULT '' COMMENT '录入时间'," + |
| | | " modifyPeople varchar(64) NOT NULL DEFAULT '' COMMENT '修改人'," + |
| | | " modifyTime varchar(64) NOT NULL DEFAULT '' COMMENT '修改时间'," + |
| | | " note varchar(255) NOT NULL DEFAULT '' COMMENT '备注'," + |
| | | " siteReceivesMark tinyint(4) NOT NULL DEFAULT '0' COMMENT '站址接收标记'," + |
| | | " siteValidity tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否有效'," + |
| | | " siteNameCMCC varchar(100) NOT NULL DEFAULT '' COMMENT '移动站址名称'," + |
| | | " siteNameCUCC varchar(100) NOT NULL DEFAULT '' COMMENT '联通站址名称'," + |
| | | " siteNameCTC varchar(100) NOT NULL DEFAULT '' COMMENT '电信站址名称'," + |
| | | " producer varchar(100) NOT NULL DEFAULT '' COMMENT '电池产商'," + |
| | | " lastTimeLong float NOT NULL DEFAULT '0' COMMENT '续航测算时长'," + |
| | | " lastTimeType varchar(100) NOT NULL DEFAULT '' COMMENT '续航测算类别'," + |
| | | " lastTimeDate datetime NOT NULL DEFAULT '1970-10-01 00:00:00' COMMENT '续航发生时间'," + |
| | | " shareInfo varchar(100) NOT NULL DEFAULT '' COMMENT '共享情况'," + |
| | | " electPowerCMCC tinyint(4) NOT NULL DEFAULT '0' COMMENT '移动是否购买发电服务'," + |
| | | " electPowerCUCC tinyint(4) NOT NULL DEFAULT '0' COMMENT '联通是否购买发电服务'," + |
| | | " electPowerCTC tinyint(4) NOT NULL DEFAULT '0' COMMENT '电信是否购买发电服务'," + |
| | | " isCanElectPower tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否具备发电条件'," + |
| | | " upperStationRoute float NOT NULL DEFAULT '0' COMMENT '上站路程'," + |
| | | " upperStationDifficult varchar(100) NOT NULL DEFAULT '' COMMENT '上站难易程度'," + |
| | | " clienteleErrorService varchar(255) NOT NULL DEFAULT '' COMMENT '客户问题库未完成蓄电池维修'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_station_id (StationId)," + |
| | | " KEY index_battgroup_id (FBSDeviceId)," + |
| | | " KEY index_station_name (StationName)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 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();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建机房问题记录表
|
| | | */
|
| | | public static void createDeverrorRecord_Table(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.DeverrorRecord_Table;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.DeverrorRecord_Table + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " stationid varchar(64) NOT NULL DEFAULT '42000001'," + |
| | | " record_time datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + |
| | | " error_descript longtext NOT NULL," + |
| | | " uid int(11) NOT NULL DEFAULT '1002'," + |
| | | " uname varchar(64) NOT NULL DEFAULT ''," + |
| | | " error_en int(11) NOT NULL DEFAULT '0'," + |
| | | " error_dispose longtext NOT NULL," + |
| | | " note varchar(64) NOT NULL DEFAULT ''," + |
| | | " picture_one longblob," + |
| | | " picture_two longblob," + |
| | | " picture_three longblob," + |
| | | " picture_four longblob," + |
| | | " picture_num int(11) NOT NULL DEFAULT '0'," + |
| | | " solve_picture_one longblob," + |
| | | " solve_picture_two longblob," + |
| | | " solve_picture_three longblob," + |
| | | " solve_picture_four longblob," + |
| | | " solve_picture_num int(11) NOT NULL DEFAULT '0'," + |
| | | " solve_uid int(11) NOT NULL DEFAULT '1002'," + |
| | | " solve_uname varchar(64) NOT NULL DEFAULT ''," + |
| | | " solve_record_time datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + |
| | | " error_state int(11) NOT NULL DEFAULT '8'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY stationid_index (stationid)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 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);
|
| | | //添加设备告警列
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_deverror_record'"
|
| | | + " AND column_name='error_state'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.DeverrorRecord_Table |
| | | + " ADD COLUMN error_state int(11) NOT NULL DEFAULT '8'");
|
| | | }
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | |
| | | /**
|
| | | * 创建机房配组记录表
|
| | | */
|
| | | public static void createBattinfRebuild_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfRebuild_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattinfRebuild_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " old_stationname varchar(64) NOT NULL DEFAULT ''," + |
| | | " old_battgroupname varchar(64) NOT NULL DEFAULT ''," + |
| | | " old_battproducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " old_stationid varchar(64) NOT NULL DEFAULT '42000000'," + |
| | | " old_battgroupid int(11) NOT NULL DEFAULT '910000000'," + |
| | | " old_monum int(11) NOT NULL DEFAULT '0'," + |
| | | " new_stationname varchar(64) NOT NULL DEFAULT ''," + |
| | | " new_battgroupname varchar(64) NOT NULL DEFAULT ''," + |
| | | " new_battproducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " new_stationid varchar(64) NOT NULL DEFAULT '42000000'," + |
| | | " new_battgroupid int(11) NOT NULL DEFAULT '910000000'," + |
| | | " new_monum int(11) NOT NULL DEFAULT '0'," + |
| | | " rebuild_time datetime NOT NULL DEFAULT '2018-09-30 00:00:00'," + |
| | | " rebuild_uid int(11) NOT NULL DEFAULT '1002'," + |
| | | " rebuild_address varchar(256) NOT NULL DEFAULT ''," + |
| | | " rebuild_clear_type int(11) NOT NULL DEFAULT '0'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_new_battgroupid (new_battgroupid)," + |
| | | " KEY index_new_stationid (new_stationid)" + |
| | | ") ENGINE=InnoDB 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);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | /**
|
| | | * 创建标准测试曲线记录表
|
| | | */
|
| | | public static void createBattmonTestcap_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattmonTestcap_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattmonTestcap_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " monvolstd float NOT NULL DEFAULT '0'," + |
| | | " moncapstd float NOT NULL DEFAULT '0'," + |
| | | " battproducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " battmodel varchar(64) NOT NULL DEFAULT ''," + |
| | | " test_cap double NOT NULL DEFAULT '0'," + |
| | | " mon_vol double NOT NULL DEFAULT '0'," + |
| | | " note varchar(64) NOT NULL DEFAULT ''," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY test_cap_index (test_cap)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=0 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);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建 tb_battcurr_inf 表
|
| | | * @param pool
|
| | | * @param recreate
|
| | | */
|
| | | public static void createBattcurr_Inf_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Battcurr_Inf_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Battcurr_Inf_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " StationId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " BattGroupId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " BattGroupName varchar(100) NOT NULL DEFAULT '0'," + |
| | | " CurrDeviceId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " CurrDeviceName varchar(100) NOT NULL DEFAULT '0'," + |
| | | " CurrValueId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " CurrValueName varchar(100) NOT NULL DEFAULT '0'," + |
| | | " PRIMARY KEY (num)" + |
| | | ") ENGINE=InnoDB 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);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建 tb_batt_maint_process 表
|
| | | * @param pool
|
| | | * @param recreate
|
| | | */
|
| | | public static void createBatt_Maint_Process_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Batt_Maint_Process_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Batt_Maint_Process_TABLE + " (" + |
| | | " num bigint(20) NOT NULL AUTO_INCREMENT," + |
| | | " batt_maint_rec_id bigint(20) NOT NULL DEFAULT '0'," + |
| | | " usr_id int(11) NOT NULL DEFAULT '0'," + |
| | | " work_caption varchar(200) NOT NULL DEFAULT ' '," + |
| | | " work_caption_time datetime DEFAULT '2005-01-01 00:00:00'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_batt_maint_rec_id (batt_maint_rec_id)" + |
| | | ") ENGINE=InnoDB 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);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建 tb_batt_maint_inf 表
|
| | | * @param pool
|
| | | * @param recreate
|
| | | */
|
| | | public static void createBatt_Maint_Inf_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Batt_Maint_Inf_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Batt_Maint_Inf_TABLE + " (" + |
| | | " num bigint(20) NOT NULL AUTO_INCREMENT," + |
| | | " BattGroupId int(11) NOT NULL DEFAULT '0'," + |
| | | " usr_id int(11) NOT NULL DEFAULT '0'," + |
| | | " fault_type_id int(11) NOT NULL DEFAULT '0'," + |
| | | " fault_type varchar(50) NOT NULL DEFAULT ' '," + |
| | | " fault_level int(11) NOT NULL DEFAULT '0'," + |
| | | " fault_caption varchar(200) NOT NULL DEFAULT ' '," + |
| | | " fault_time datetime NOT NULL DEFAULT '2005-01-01 00:00:00'," + |
| | | " record_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " record_time datetime NOT NULL DEFAULT '2005-01-01 00:00:00'," + |
| | | " maint_time_limit datetime NOT NULL DEFAULT '2005-01-01 00:00:00'," + |
| | | " maint_type_id int(11) NOT NULL DEFAULT '0'," + |
| | | " maint_type varchar(50) NOT NULL DEFAULT ' '," + |
| | | " maint_result varchar(100) NOT NULL DEFAULT ' '," + |
| | | " maint_done tinyint(1) NOT NULL DEFAULT '0'," + |
| | | " maint_done_time datetime DEFAULT '2005-01-01 00:00:00'," + |
| | | " maint_close tinyint(1) NOT NULL DEFAULT '0'," + |
| | | " master_id int(11) NOT NULL DEFAULT '0'," + |
| | | " master_audit int(11) NOT NULL DEFAULT '0'," + |
| | | " appoint_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " copy_uids varchar(200) NOT NULL DEFAULT ' '," + |
| | | " master_check varchar(100) NOT NULL DEFAULT ' '," + |
| | | " remark varchar(200) NOT NULL DEFAULT ' '," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_battgroup_id (BattGroupId)," + |
| | | " KEY index_user_id (usr_id)," + |
| | | " KEY index_fault_type_id (fault_type_id)," + |
| | | " KEY index_maint_type_id (maint_type_id)" + |
| | | ") ENGINE=InnoDB 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);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建 tb_batt_alm_param 表
|
| | | * @param pool
|
| | | * @param recreate
|
| | | */
|
| | | public static void createBatt_Alm_Param_TABLE(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Batt_Alm_Param_TABLE;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Batt_Alm_Param_TABLE + " (" + |
| | | " num bigint(20) NOT NULL AUTO_INCREMENT," + |
| | | " param_id int(11) NOT NULL DEFAULT '2020001' COMMENT '参数id'," + |
| | | " mon_vol_low float NOT NULL DEFAULT '0' COMMENT '单体电压低告警'," + |
| | | " mon_vol_high float NOT NULL DEFAULT '0' COMMENT '单体电压高告警'," + |
| | | " mon_res_low float NOT NULL DEFAULT '0' COMMENT '单体内阻低'," + |
| | | " mon_res_high float NOT NULL DEFAULT '0' COMMENT '单体内阻高'," + |
| | | " mon_tmp_low float NOT NULL DEFAULT '0' COMMENT '单体温度低'," + |
| | | " mon_tmp_high float NOT NULL DEFAULT '0' COMMENT '单体温度高'," + |
| | | " note varchar(255) NOT NULL DEFAULT ''," + |
| | | " PRIMARY KEY (num)," + |
| | | " UNIQUE KEY index_param_id (param_id) USING BTREE" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=3 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);
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | |
| | | /**
|
| | | * 创建 tb_batt_alm_param 表
|
| | | * @param pool
|
| | | * @param recreate
|
| | | */
|
| | | public static void createBattInf_Table(MysqlConnPool pool, boolean recreate) {
|
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattInf_Table;
|
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattInf_Table + " (" + |
| | | " `num` int(11) NOT NULL AUTO_INCREMENT," + |
| | | " `StationId` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `charge_curr_max` float DEFAULT '20'," + |
| | | " `StationId_ex` varchar(20) DEFAULT '0'," + |
| | | " `StationName` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName1` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName2` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName3` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName4` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName5` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName6` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName7` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName8` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName9` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationIP` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `FBSDeviceId` bigint(11) NOT NULL DEFAULT '0'," + |
| | | " `FBSDeviceIp` varchar(50) NOT NULL DEFAULT '192.168.0.88'," + |
| | | " `FBSDeviceName` varchar(100) NOT NULL DEFAULT '0'," + |
| | | " `GroupIndexInFBSDevice` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattModel` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupId` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattGroupNum` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattGroupName` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName1` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName2` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName3` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName4` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName5` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName6` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `FloatVolLevel` float NOT NULL DEFAULT '1.12'," + |
| | | " `OfflineVolLevel` float NOT NULL DEFAULT '1.06'," + |
| | | " `BattFloatCurrent` float NOT NULL DEFAULT '0'," + |
| | | " `DeviceId` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `DeviceName` varchar(100) NOT NULL DEFAULT '0'," + |
| | | " `MonCount` int(11) NOT NULL DEFAULT '0'," + |
| | | " `MonCapStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonVolStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonResStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonSerStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonTmpStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonVolLowToAvg` float NOT NULL DEFAULT '0'," + |
| | | " `MonNum` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattProducer` varchar(45) NOT NULL DEFAULT '0'," + |
| | | " `BattProductDate` date NOT NULL DEFAULT '2006-07-06'," + |
| | | " `BattInUseDate` date NOT NULL DEFAULT '2006-07-06'," + |
| | | " `BattGuarantDayCount` int(11) NOT NULL DEFAULT '1095'," + |
| | | " `SignalId` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `CInterFaceId` int(11) NOT NULL DEFAULT '0'," + |
| | | " `SignalName` varchar(50) NOT NULL DEFAULT '0'," + |
| | | " `Load_curr` float NOT NULL DEFAULT '15'," + |
| | | " `disCurrMax` float NOT NULL DEFAULT '0'," + |
| | | " `FbsDeviceIp_YM` varchar(50) NOT NULL DEFAULT '255.255.255.0'," + |
| | | " `FbsDeviceIp_WG` varchar(50) NOT NULL DEFAULT '127.0.0.1'," + |
| | | " `station_phone` varchar(32) DEFAULT ''," + |
| | | " `station_install` tinyint(1) NOT NULL DEFAULT '0'," + |
| | | " `install_user` varchar(64) DEFAULT ''," + |
| | | " `Vol_grade` float DEFAULT '0'," + |
| | | " `Manufacturers` varchar(64) DEFAULT ''," + |
| | | " `Assetequipment` varchar(64) DEFAULT ''," + |
| | | " `Deviceclasspath` varchar(64) DEFAULT ''," + |
| | | " `DeviceOperationDepartment` varchar(64) DEFAULT ''," + |
| | | " `PropertyRightUnit` varchar(64) DEFAULT ''," + |
| | | " `PropertyAttribute` varchar(64) DEFAULT ''," + |
| | | " `FactoryNumber` varchar(64) DEFAULT ''," + |
| | | " `OperationTeam` varchar(64) DEFAULT ''," + |
| | | " `DeviceIdentityCode` varchar(64) DEFAULT ''," + |
| | | " `ProjectType` varchar(64) DEFAULT ''," + |
| | | " `BatteryApplicationType` varchar(64) DEFAULT ''," + |
| | | " `SingleRatedVoltage` float DEFAULT '0'," + |
| | | " `RemoteMonitor` varchar(64) DEFAULT ''," + |
| | | " `BatttIndependentPlaced` varchar(64) DEFAULT ''," + |
| | | " `JunChargeVoltageValue` float DEFAULT '0'," + |
| | | " `PublicKeyX` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `PublicKeyY` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `KeyID` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `SerialNumber` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `video_url` varchar(200) DEFAULT NULL," + |
| | | " PRIMARY KEY (`num`)," + |
| | | " UNIQUE KEY `index_battgroup_id` (`BattGroupId`) USING BTREE," + |
| | | " KEY `index_station_id` (`StationId`)," + |
| | | " KEY `index_station_name` (`StationName`)," + |
| | | " KEY `index_battgroup_name` (`BattGroupName`)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=3 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);
|
| | | //添加Load_curr
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='Load_curr'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Load_curr` float NOT NULL DEFAULT '15';");
|
| | | }
|
| | | //添加disCurrMax
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='disCurrMax'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `disCurrMax` float NOT NULL DEFAULT '0';");
|
| | | }
|
| | | //添加FbsDeviceIp_YM
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='FbsDeviceIp_YM'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `FbsDeviceIp_YM` varchar(50) NOT NULL DEFAULT '255.255.255.0';");
|
| | | }
|
| | | //添加FbsDeviceIp_WG
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='FbsDeviceIp_WG'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `FbsDeviceIp_WG` varchar(50) NOT NULL DEFAULT '127.0.0.1';");
|
| | | }
|
| | | //添加station_phone
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='station_phone'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `station_phone` varchar(32) DEFAULT '';");
|
| | | }
|
| | | //添加station_install
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='station_install'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `station_install` tinyint(1) NOT NULL DEFAULT '0';");
|
| | | }
|
| | | //添加install_user
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='install_user'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `install_user` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加Vol_grade
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='Vol_grade'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Vol_grade` float DEFAULT '0';");
|
| | | }
|
| | | //添加Manufacturers
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='Manufacturers'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Manufacturers` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加Assetequipment
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='Assetequipment'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Assetequipment` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加Deviceclasspath
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='Deviceclasspath'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Deviceclasspath` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加DeviceOperationDepartment
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='DeviceOperationDepartment'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `DeviceOperationDepartment` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加PropertyRightUnit
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='PropertyRightUnit'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PropertyRightUnit` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加PropertyAttribute
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='PropertyAttribute'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PropertyAttribute` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加FactoryNumber
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='FactoryNumber'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `FactoryNumber` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加OperationTeam
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='OperationTeam'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `OperationTeam` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加DeviceIdentityCode
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='DeviceIdentityCode'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `DeviceIdentityCode` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加ProjectType
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='ProjectType'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `ProjectType` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加BatteryApplicationType
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='BatteryApplicationType'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `BatteryApplicationType` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加SingleRatedVoltage
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='SingleRatedVoltage'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `SingleRatedVoltage` float DEFAULT '0';");
|
| | | }
|
| | | //添加RemoteMonitor
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='RemoteMonitor'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `RemoteMonitor` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加BatttIndependentPlaced
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='BatttIndependentPlaced'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `BatttIndependentPlaced` varchar(64) DEFAULT '';");
|
| | | }
|
| | | //添加JunChargeVoltageValue
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='JunChargeVoltageValue'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `JunChargeVoltageValue` float DEFAULT '0';");
|
| | | }
|
| | | //添加PublicKeyX
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='PublicKeyX'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PublicKeyX` varchar(200) NOT NULL DEFAULT '';");
|
| | | }
|
| | | //添加PublicKeyY
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='PublicKeyY'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PublicKeyY` varchar(200) NOT NULL DEFAULT '';");
|
| | | }
|
| | | //添加KeyID
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='KeyID'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `KeyID` varchar(200) NOT NULL DEFAULT '';");
|
| | | }
|
| | | //添加SerialNumber
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='SerialNumber'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `SerialNumber` varchar(200) NOT NULL DEFAULT '';");
|
| | | } |
| | | //添加SerialNumber
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='video_url'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `video_url` varchar(200) DEFAULT NULL;");
|
| | | }
|
| | | |
| | | //添加charge_type
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='charge_type'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `charge_type` int(11) NOT NULL DEFAULT '1' COMMENT '充放电状态:1:限流充电;2;逆变充电';");
|
| | | }
|
| | | |
| | | //添加buscouple_state
|
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
| | | + " WHERE table_schema='db_battinf'"
|
| | | + " AND table_name='tb_battinf'"
|
| | | + " AND column_name='buscouple_state'");
|
| | | if(false == res.next()) {
|
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `buscouple_state` int(11) NOT NULL DEFAULT '0' COMMENT '母联状态:0:无母联;1:有母联';");
|
| | | }
|
| | | } catch (SQLException e) {
|
| | | e.printStackTrace();
|
| | | } finally {
|
| | | sql.close_con();
|
| | | }
|
| | | }
|
| | | }
|
| | | package com.database_util; |
| | | |
| | | import java.sql.ResultSet; |
| | | import java.sql.SQLException; |
| | | |
| | | import com.sql.MysqlConnPool; |
| | | import com.sql.Sql_Mysql; |
| | | |
| | | /** |
| | | * 构建db_battinf数据库中的数据库表 录入在该数据库中新添加的数据库表 |
| | | * @author LiJun |
| | | * |
| | | */ |
| | | public class DB_battinf { |
| | | public static void init(MysqlConnPool pool, boolean recreate) { |
| | | createDB_battinf(pool); //创建db_battinf 数据库 不存在则创建db_battinf数据库 |
| | | |
| | | createBattInf_Table(pool, recreate); //创建电池组信息配置表 |
| | | |
| | | createBattinfApply_table(pool, recreate); //创建机房安装审批表 |
| | | |
| | | createBattinfEx_TABLE(pool, recreate); //创建基站信息 |
| | | |
| | | createDeverrorRecord_Table(pool, recreate); //创建机房问题记录表 |
| | | |
| | | createBattinfRebuild_TABLE(pool, recreate); //创建机房配组记录表 |
| | | |
| | | createBattmonTestcap_TABLE(pool, recreate); //创建标准测试曲线表 |
| | | |
| | | createBattcurr_Inf_TABLE(pool, recreate); |
| | | |
| | | createBatt_Maint_Process_TABLE(pool, recreate); |
| | | |
| | | createBatt_Maint_Inf_TABLE(pool, recreate); |
| | | |
| | | createBatt_Alm_Param_TABLE(pool, recreate); |
| | | } |
| | | |
| | | /** |
| | | * 创建 db_battinf 数据库 |
| | | * @param pool |
| | | */ |
| | | public static void createDB_battinf(MysqlConnPool pool) { |
| | | Sql_Mysql sql = new Sql_Mysql(pool.getConn()); |
| | | try { |
| | | sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_BATT_INF); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建机房安装审批表 |
| | | */ |
| | | public static void createBattinfApply_table(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfApply_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattinfApply_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " apply_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " confrim_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " apply_date datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + |
| | | " apply_en int(11) NOT NULL DEFAULT '0'," + |
| | | " apply_note varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationid varchar(64) NOT NULL DEFAULT '0'," + |
| | | " stationname varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname1 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname2 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname3 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname4 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname5 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname6 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname7 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname8 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationname9 varchar(256) NOT NULL DEFAULT ''," + |
| | | " stationip varchar(64) NOT NULL DEFAULT '127.0.0.1'," + |
| | | " FbsDeviceId int(11) NOT NULL DEFAULT '0'," + |
| | | " FbsDeviceIp varchar(64) NOT NULL DEFAULT '127.000.000.001'," + |
| | | " FbsDeviceIp_YM varchar(64) NOT NULL DEFAULT '255.255.255.0'," + |
| | | " FbsDeviceIp_WG varchar(64) NOT NULL DEFAULT '127.0.0.1'," + |
| | | " FBSDeviceName varchar(64) NOT NULL DEFAULT '设备名称'," + |
| | | " GroupIndexInFBSDevice int(11) NOT NULL DEFAULT '1'," + |
| | | " BattGroupId int(11) NOT NULL DEFAULT '0'," + |
| | | " BattGroupNum int(11) NOT NULL DEFAULT '2'," + |
| | | " BattGroupName varchar(64) NOT NULL DEFAULT '电池组1'," + |
| | | " FloatVolLevel float NOT NULL DEFAULT '54'," + |
| | | " OfflineVolLevel float NOT NULL DEFAULT '42.9'," + |
| | | " BattFloatCurrent float NOT NULL DEFAULT '5'," + |
| | | " MonCount int(11) NOT NULL DEFAULT '24'," + |
| | | " MonCapStd float NOT NULL DEFAULT '300'," + |
| | | " MonVolStd float NOT NULL DEFAULT '2'," + |
| | | " MonResStd float NOT NULL DEFAULT '0.2'," + |
| | | " MonSerStd float NOT NULL DEFAULT '5000'," + |
| | | " MonVolLowToAvg float NOT NULL DEFAULT '0.05'," + |
| | | " Load_curr float NOT NULL DEFAULT '15'," + |
| | | " DisCurrMax float NOT NULL DEFAULT '0'," + |
| | | " station_phone varchar(64) NOT NULL DEFAULT ''," + |
| | | " BattProducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " BattModel varchar(64) NOT NULL DEFAULT ''," + |
| | | " BattProductDate datetime NOT NULL DEFAULT '2018-09-18 00:00:00'," + |
| | | " BattInUseDate datetime NOT NULL DEFAULT '2018-09-18 00:00:00'," + |
| | | " install_user varchar(64) NOT NULL DEFAULT ''," + |
| | | " check_en int(11) NOT NULL DEFAULT '0'," + |
| | | " check_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " longitude double NOT NULL DEFAULT '0'," + |
| | | " latitude double NOT NULL DEFAULT '0'," + |
| | | " address varchar(256) NOT NULL DEFAULT ''," + |
| | | " PRIMARY KEY (num)," + |
| | | " UNIQUE KEY BattGroupId_index (BattGroupId) USING BTREE," + |
| | | " KEY FbsDeviceId_index (FbsDeviceId)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 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(); |
| | | } |
| | | } |
| | | /** |
| | | * 创建基站信息表 |
| | | */ |
| | | public static void createBattinfEx_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfEx_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattinfEx_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " StationId varchar(20) NOT NULL DEFAULT '0' COMMENT '机房id'," + |
| | | " FBSDeviceId bigint(20) NOT NULL DEFAULT '0' COMMENT '设备id'," + |
| | | " StationName varchar(100) NOT NULL DEFAULT '' COMMENT '机房名称'," + |
| | | " stationCode varchar(100) NOT NULL DEFAULT '' COMMENT '站址编码'," + |
| | | " stationRegion varchar(100) NOT NULL DEFAULT '' COMMENT '所属区域'," + |
| | | " keyWords varchar(100) NOT NULL DEFAULT '' COMMENT '关键字'," + |
| | | " affiliation varchar(100) NOT NULL DEFAULT '' COMMENT '所属组织'," + |
| | | " dataSources varchar(100) NOT NULL DEFAULT '' COMMENT '数据来源'," + |
| | | " stationType varchar(100) NOT NULL DEFAULT '' COMMENT '站址类型'," + |
| | | " longitude double NOT NULL DEFAULT '0' COMMENT '经度'," + |
| | | " latitude double NOT NULL DEFAULT '0' COMMENT '纬度'," + |
| | | " stationAddr varchar(100) NOT NULL DEFAULT '' COMMENT '站址地址'," + |
| | | " stationLevel varchar(100) NOT NULL DEFAULT '' COMMENT '站址等级'," + |
| | | " maintenanceState varchar(100) NOT NULL DEFAULT '' COMMENT '维护状态'," + |
| | | " blockedState tinyint(4) NOT NULL DEFAULT '0' COMMENT '封锁状态'," + |
| | | " maintenanceCompany varchar(100) NOT NULL DEFAULT '' COMMENT '维护单位'," + |
| | | " businessScenario varchar(100) NOT NULL DEFAULT '' COMMENT '业务场景'," + |
| | | " CoverScenario varchar(100) NOT NULL DEFAULT '' COMMENT '覆盖场景'," + |
| | | " siteTerrain varchar(100) NOT NULL DEFAULT '' COMMENT '站址地形'," + |
| | | " propertyRights varchar(100) NOT NULL DEFAULT '' COMMENT '产权性质'," + |
| | | " propertyUnit varchar(100) NOT NULL DEFAULT '' COMMENT '产权单位'," + |
| | | " isShare tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否共享'," + |
| | | " useUnit varchar(100) NOT NULL DEFAULT '' COMMENT '使用单位'," + |
| | | " siteCode varchar(100) NOT NULL DEFAULT '' COMMENT '物理站址编码'," + |
| | | " historySiteCode varchar(100) NOT NULL DEFAULT '' COMMENT '历史物理站址编码'," + |
| | | " siteInternalNumber varchar(100) NOT NULL DEFAULT '' COMMENT '站址内部编码'," + |
| | | " sitePinyinReferred varchar(100) NOT NULL DEFAULT '' COMMENT '站址拼音简称'," + |
| | | " siteChineseReferred varchar(100) NOT NULL DEFAULT '' COMMENT '中文简称'," + |
| | | " siteMergeRecord varchar(100) NOT NULL DEFAULT '' COMMENT '站址合并记录'," + |
| | | " isOpenBusiness varchar(16) NOT NULL DEFAULT '' COMMENT '是否开通业务'," + |
| | | " schoolPersonnel varchar(64) NOT NULL DEFAULT '' COMMENT '录入人员'," + |
| | | " entryTime varchar(64) NOT NULL DEFAULT '' COMMENT '录入时间'," + |
| | | " modifyPeople varchar(64) NOT NULL DEFAULT '' COMMENT '修改人'," + |
| | | " modifyTime varchar(64) NOT NULL DEFAULT '' COMMENT '修改时间'," + |
| | | " note varchar(255) NOT NULL DEFAULT '' COMMENT '备注'," + |
| | | " siteReceivesMark tinyint(4) NOT NULL DEFAULT '0' COMMENT '站址接收标记'," + |
| | | " siteValidity tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否有效'," + |
| | | " siteNameCMCC varchar(100) NOT NULL DEFAULT '' COMMENT '移动站址名称'," + |
| | | " siteNameCUCC varchar(100) NOT NULL DEFAULT '' COMMENT '联通站址名称'," + |
| | | " siteNameCTC varchar(100) NOT NULL DEFAULT '' COMMENT '电信站址名称'," + |
| | | " producer varchar(100) NOT NULL DEFAULT '' COMMENT '电池产商'," + |
| | | " lastTimeLong float NOT NULL DEFAULT '0' COMMENT '续航测算时长'," + |
| | | " lastTimeType varchar(100) NOT NULL DEFAULT '' COMMENT '续航测算类别'," + |
| | | " lastTimeDate datetime NOT NULL DEFAULT '1970-10-01 00:00:00' COMMENT '续航发生时间'," + |
| | | " shareInfo varchar(100) NOT NULL DEFAULT '' COMMENT '共享情况'," + |
| | | " electPowerCMCC tinyint(4) NOT NULL DEFAULT '0' COMMENT '移动是否购买发电服务'," + |
| | | " electPowerCUCC tinyint(4) NOT NULL DEFAULT '0' COMMENT '联通是否购买发电服务'," + |
| | | " electPowerCTC tinyint(4) NOT NULL DEFAULT '0' COMMENT '电信是否购买发电服务'," + |
| | | " isCanElectPower tinyint(4) NOT NULL DEFAULT '0' COMMENT '是否具备发电条件'," + |
| | | " upperStationRoute float NOT NULL DEFAULT '0' COMMENT '上站路程'," + |
| | | " upperStationDifficult varchar(100) NOT NULL DEFAULT '' COMMENT '上站难易程度'," + |
| | | " clienteleErrorService varchar(255) NOT NULL DEFAULT '' COMMENT '客户问题库未完成蓄电池维修'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_station_id (StationId)," + |
| | | " KEY index_battgroup_id (FBSDeviceId)," + |
| | | " KEY index_station_name (StationName)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 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(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建机房问题记录表 |
| | | */ |
| | | public static void createDeverrorRecord_Table(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.DeverrorRecord_Table; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.DeverrorRecord_Table + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " stationid varchar(64) NOT NULL DEFAULT '42000001'," + |
| | | " record_time datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + |
| | | " error_descript longtext NOT NULL," + |
| | | " uid int(11) NOT NULL DEFAULT '1002'," + |
| | | " uname varchar(64) NOT NULL DEFAULT ''," + |
| | | " error_en int(11) NOT NULL DEFAULT '0'," + |
| | | " error_dispose longtext NOT NULL," + |
| | | " note varchar(64) NOT NULL DEFAULT ''," + |
| | | " picture_one longblob," + |
| | | " picture_two longblob," + |
| | | " picture_three longblob," + |
| | | " picture_four longblob," + |
| | | " picture_num int(11) NOT NULL DEFAULT '0'," + |
| | | " solve_picture_one longblob," + |
| | | " solve_picture_two longblob," + |
| | | " solve_picture_three longblob," + |
| | | " solve_picture_four longblob," + |
| | | " solve_picture_num int(11) NOT NULL DEFAULT '0'," + |
| | | " solve_uid int(11) NOT NULL DEFAULT '1002'," + |
| | | " solve_uname varchar(64) NOT NULL DEFAULT ''," + |
| | | " solve_record_time datetime NOT NULL DEFAULT '2018-01-01 00:00:00'," + |
| | | " error_state int(11) NOT NULL DEFAULT '8'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY stationid_index (stationid)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=1 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); |
| | | //添加设备告警列 |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_deverror_record'" |
| | | + " AND column_name='error_state'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.DeverrorRecord_Table |
| | | + " ADD COLUMN error_state int(11) NOT NULL DEFAULT '8'"); |
| | | } |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 创建机房配组记录表 |
| | | */ |
| | | public static void createBattinfRebuild_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattinfRebuild_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattinfRebuild_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " old_stationname varchar(64) NOT NULL DEFAULT ''," + |
| | | " old_battgroupname varchar(64) NOT NULL DEFAULT ''," + |
| | | " old_battproducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " old_stationid varchar(64) NOT NULL DEFAULT '42000000'," + |
| | | " old_battgroupid int(11) NOT NULL DEFAULT '910000000'," + |
| | | " old_monum int(11) NOT NULL DEFAULT '0'," + |
| | | " new_stationname varchar(64) NOT NULL DEFAULT ''," + |
| | | " new_battgroupname varchar(64) NOT NULL DEFAULT ''," + |
| | | " new_battproducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " new_stationid varchar(64) NOT NULL DEFAULT '42000000'," + |
| | | " new_battgroupid int(11) NOT NULL DEFAULT '910000000'," + |
| | | " new_monum int(11) NOT NULL DEFAULT '0'," + |
| | | " rebuild_time datetime NOT NULL DEFAULT '2018-09-30 00:00:00'," + |
| | | " rebuild_uid int(11) NOT NULL DEFAULT '1002'," + |
| | | " rebuild_address varchar(256) NOT NULL DEFAULT ''," + |
| | | " rebuild_clear_type int(11) NOT NULL DEFAULT '0'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_new_battgroupid (new_battgroupid)," + |
| | | " KEY index_new_stationid (new_stationid)" + |
| | | ") ENGINE=InnoDB 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); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | /** |
| | | * 创建标准测试曲线记录表 |
| | | */ |
| | | public static void createBattmonTestcap_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattmonTestcap_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattmonTestcap_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " monvolstd float NOT NULL DEFAULT '0'," + |
| | | " moncapstd float NOT NULL DEFAULT '0'," + |
| | | " battproducer varchar(64) NOT NULL DEFAULT ''," + |
| | | " battmodel varchar(64) NOT NULL DEFAULT ''," + |
| | | " test_cap double NOT NULL DEFAULT '0'," + |
| | | " mon_vol double NOT NULL DEFAULT '0'," + |
| | | " note varchar(64) NOT NULL DEFAULT ''," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY test_cap_index (test_cap)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=0 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); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建 tb_battcurr_inf 表 |
| | | * @param pool |
| | | * @param recreate |
| | | */ |
| | | public static void createBattcurr_Inf_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Battcurr_Inf_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Battcurr_Inf_TABLE + " (" + |
| | | " num int(11) NOT NULL AUTO_INCREMENT," + |
| | | " StationId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " BattGroupId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " BattGroupName varchar(100) NOT NULL DEFAULT '0'," + |
| | | " CurrDeviceId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " CurrDeviceName varchar(100) NOT NULL DEFAULT '0'," + |
| | | " CurrValueId varchar(20) NOT NULL DEFAULT '0'," + |
| | | " CurrValueName varchar(100) NOT NULL DEFAULT '0'," + |
| | | " PRIMARY KEY (num)" + |
| | | ") ENGINE=InnoDB 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); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建 tb_batt_maint_process 表 |
| | | * @param pool |
| | | * @param recreate |
| | | */ |
| | | public static void createBatt_Maint_Process_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Batt_Maint_Process_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Batt_Maint_Process_TABLE + " (" + |
| | | " num bigint(20) NOT NULL AUTO_INCREMENT," + |
| | | " batt_maint_rec_id bigint(20) NOT NULL DEFAULT '0'," + |
| | | " usr_id int(11) NOT NULL DEFAULT '0'," + |
| | | " work_caption varchar(200) NOT NULL DEFAULT ' '," + |
| | | " work_caption_time datetime DEFAULT '2005-01-01 00:00:00'," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_batt_maint_rec_id (batt_maint_rec_id)" + |
| | | ") ENGINE=InnoDB 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); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建 tb_batt_maint_inf 表 |
| | | * @param pool |
| | | * @param recreate |
| | | */ |
| | | public static void createBatt_Maint_Inf_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Batt_Maint_Inf_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Batt_Maint_Inf_TABLE + " (" + |
| | | " num bigint(20) NOT NULL AUTO_INCREMENT," + |
| | | " BattGroupId int(11) NOT NULL DEFAULT '0'," + |
| | | " usr_id int(11) NOT NULL DEFAULT '0'," + |
| | | " fault_type_id int(11) NOT NULL DEFAULT '0'," + |
| | | " fault_type varchar(50) NOT NULL DEFAULT ' '," + |
| | | " fault_level int(11) NOT NULL DEFAULT '0'," + |
| | | " fault_caption varchar(200) NOT NULL DEFAULT ' '," + |
| | | " fault_time datetime NOT NULL DEFAULT '2005-01-01 00:00:00'," + |
| | | " record_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " record_time datetime NOT NULL DEFAULT '2005-01-01 00:00:00'," + |
| | | " maint_time_limit datetime NOT NULL DEFAULT '2005-01-01 00:00:00'," + |
| | | " maint_type_id int(11) NOT NULL DEFAULT '0'," + |
| | | " maint_type varchar(50) NOT NULL DEFAULT ' '," + |
| | | " maint_result varchar(100) NOT NULL DEFAULT ' '," + |
| | | " maint_done tinyint(1) NOT NULL DEFAULT '0'," + |
| | | " maint_done_time datetime DEFAULT '2005-01-01 00:00:00'," + |
| | | " maint_close tinyint(1) NOT NULL DEFAULT '0'," + |
| | | " master_id int(11) NOT NULL DEFAULT '0'," + |
| | | " master_audit int(11) NOT NULL DEFAULT '0'," + |
| | | " appoint_uid int(11) NOT NULL DEFAULT '0'," + |
| | | " copy_uids varchar(200) NOT NULL DEFAULT ' '," + |
| | | " master_check varchar(100) NOT NULL DEFAULT ' '," + |
| | | " remark varchar(200) NOT NULL DEFAULT ' '," + |
| | | " PRIMARY KEY (num)," + |
| | | " KEY index_battgroup_id (BattGroupId)," + |
| | | " KEY index_user_id (usr_id)," + |
| | | " KEY index_fault_type_id (fault_type_id)," + |
| | | " KEY index_maint_type_id (maint_type_id)" + |
| | | ") ENGINE=InnoDB 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); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建 tb_batt_alm_param 表 |
| | | * @param pool |
| | | * @param recreate |
| | | */ |
| | | public static void createBatt_Alm_Param_TABLE(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Batt_Alm_Param_TABLE; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Batt_Alm_Param_TABLE + " (" + |
| | | " num bigint(20) NOT NULL AUTO_INCREMENT," + |
| | | " param_id int(11) NOT NULL DEFAULT '2020001' COMMENT '参数id'," + |
| | | " mon_vol_low float NOT NULL DEFAULT '0' COMMENT '单体电压低告警'," + |
| | | " mon_vol_high float NOT NULL DEFAULT '0' COMMENT '单体电压高告警'," + |
| | | " mon_res_low float NOT NULL DEFAULT '0' COMMENT '单体内阻低'," + |
| | | " mon_res_high float NOT NULL DEFAULT '0' COMMENT '单体内阻高'," + |
| | | " mon_tmp_low float NOT NULL DEFAULT '0' COMMENT '单体温度低'," + |
| | | " mon_tmp_high float NOT NULL DEFAULT '0' COMMENT '单体温度高'," + |
| | | " note varchar(255) NOT NULL DEFAULT ''," + |
| | | " PRIMARY KEY (num)," + |
| | | " UNIQUE KEY index_param_id (param_id) USING BTREE" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=3 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); |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 创建 tb_batt_alm_param 表 |
| | | * @param pool |
| | | * @param recreate |
| | | */ |
| | | public static void createBattInf_Table(MysqlConnPool pool, boolean recreate) { |
| | | String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.BattInf_Table; |
| | | String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BattInf_Table + " (" + |
| | | " `num` int(11) NOT NULL AUTO_INCREMENT," + |
| | | " `StationId` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `charge_curr_max` float DEFAULT '20'," + |
| | | " `StationId_ex` varchar(20) DEFAULT '0'," + |
| | | " `StationName` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName1` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName2` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName3` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName4` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName5` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName6` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName7` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName8` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationName9` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `StationIP` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `FBSDeviceId` bigint(11) NOT NULL DEFAULT '0'," + |
| | | " `FBSDeviceIp` varchar(50) NOT NULL DEFAULT '192.168.0.88'," + |
| | | " `FBSDeviceName` varchar(100) NOT NULL DEFAULT '0'," + |
| | | " `GroupIndexInFBSDevice` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattModel` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupId` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattGroupNum` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattGroupName` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName1` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName2` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName3` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName4` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName5` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `BattGroupName6` varchar(100) NOT NULL DEFAULT ' '," + |
| | | " `FloatVolLevel` float NOT NULL DEFAULT '1.12'," + |
| | | " `OfflineVolLevel` float NOT NULL DEFAULT '1.06'," + |
| | | " `BattFloatCurrent` float NOT NULL DEFAULT '0'," + |
| | | " `DeviceId` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `DeviceName` varchar(100) NOT NULL DEFAULT '0'," + |
| | | " `MonCount` int(11) NOT NULL DEFAULT '0'," + |
| | | " `MonCapStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonVolStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonResStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonSerStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonTmpStd` float NOT NULL DEFAULT '0'," + |
| | | " `MonVolLowToAvg` float NOT NULL DEFAULT '0'," + |
| | | " `MonNum` int(11) NOT NULL DEFAULT '0'," + |
| | | " `BattProducer` varchar(45) NOT NULL DEFAULT '0'," + |
| | | " `BattProductDate` date NOT NULL DEFAULT '2006-07-06'," + |
| | | " `BattInUseDate` date NOT NULL DEFAULT '2006-07-06'," + |
| | | " `BattGuarantDayCount` int(11) NOT NULL DEFAULT '1095'," + |
| | | " `SignalId` varchar(20) NOT NULL DEFAULT '0'," + |
| | | " `CInterFaceId` int(11) NOT NULL DEFAULT '0'," + |
| | | " `SignalName` varchar(50) NOT NULL DEFAULT '0'," + |
| | | " `Load_curr` float NOT NULL DEFAULT '15'," + |
| | | " `disCurrMax` float NOT NULL DEFAULT '0'," + |
| | | " `FbsDeviceIp_YM` varchar(50) NOT NULL DEFAULT '255.255.255.0'," + |
| | | " `FbsDeviceIp_WG` varchar(50) NOT NULL DEFAULT '127.0.0.1'," + |
| | | " `station_phone` varchar(32) DEFAULT ''," + |
| | | " `station_install` tinyint(1) NOT NULL DEFAULT '0'," + |
| | | " `install_user` varchar(64) DEFAULT ''," + |
| | | " `Vol_grade` float DEFAULT '0'," + |
| | | " `Manufacturers` varchar(64) DEFAULT ''," + |
| | | " `Assetequipment` varchar(64) DEFAULT ''," + |
| | | " `Deviceclasspath` varchar(64) DEFAULT ''," + |
| | | " `DeviceOperationDepartment` varchar(64) DEFAULT ''," + |
| | | " `PropertyRightUnit` varchar(64) DEFAULT ''," + |
| | | " `PropertyAttribute` varchar(64) DEFAULT ''," + |
| | | " `FactoryNumber` varchar(64) DEFAULT ''," + |
| | | " `OperationTeam` varchar(64) DEFAULT ''," + |
| | | " `DeviceIdentityCode` varchar(64) DEFAULT ''," + |
| | | " `ProjectType` varchar(64) DEFAULT ''," + |
| | | " `BatteryApplicationType` varchar(64) DEFAULT ''," + |
| | | " `SingleRatedVoltage` float DEFAULT '0'," + |
| | | " `RemoteMonitor` varchar(64) DEFAULT ''," + |
| | | " `BatttIndependentPlaced` varchar(64) DEFAULT ''," + |
| | | " `JunChargeVoltageValue` float DEFAULT '0'," + |
| | | " `PublicKeyX` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `PublicKeyY` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `KeyID` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `SerialNumber` varchar(200) NOT NULL DEFAULT ''," + |
| | | " `video_url` varchar(200) DEFAULT NULL," + |
| | | " PRIMARY KEY (`num`)," + |
| | | " UNIQUE KEY `index_battgroup_id` (`BattGroupId`) USING BTREE," + |
| | | " KEY `index_station_id` (`StationId`)," + |
| | | " KEY `index_station_name` (`StationName`)," + |
| | | " KEY `index_battgroup_name` (`BattGroupName`)" + |
| | | ") ENGINE=InnoDB AUTO_INCREMENT=3 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); |
| | | //添加Load_curr |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='Load_curr'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Load_curr` float NOT NULL DEFAULT '15';"); |
| | | } |
| | | //添加disCurrMax |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='disCurrMax'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `disCurrMax` float NOT NULL DEFAULT '0';"); |
| | | } |
| | | //添加FbsDeviceIp_YM |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='FbsDeviceIp_YM'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `FbsDeviceIp_YM` varchar(50) NOT NULL DEFAULT '255.255.255.0';"); |
| | | } |
| | | //添加FbsDeviceIp_WG |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='FbsDeviceIp_WG'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `FbsDeviceIp_WG` varchar(50) NOT NULL DEFAULT '127.0.0.1';"); |
| | | } |
| | | //添加station_phone |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='station_phone'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `station_phone` varchar(32) DEFAULT '';"); |
| | | } |
| | | //添加station_install |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='station_install'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `station_install` tinyint(1) NOT NULL DEFAULT '0';"); |
| | | } |
| | | //添加install_user |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='install_user'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `install_user` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加Vol_grade |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='Vol_grade'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Vol_grade` float DEFAULT '0';"); |
| | | } |
| | | //添加Manufacturers |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='Manufacturers'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Manufacturers` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加Assetequipment |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='Assetequipment'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Assetequipment` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加Deviceclasspath |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='Deviceclasspath'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `Deviceclasspath` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加DeviceOperationDepartment |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='DeviceOperationDepartment'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `DeviceOperationDepartment` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加PropertyRightUnit |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='PropertyRightUnit'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PropertyRightUnit` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加PropertyAttribute |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='PropertyAttribute'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PropertyAttribute` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加FactoryNumber |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='FactoryNumber'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `FactoryNumber` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加OperationTeam |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='OperationTeam'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `OperationTeam` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加DeviceIdentityCode |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='DeviceIdentityCode'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `DeviceIdentityCode` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加ProjectType |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='ProjectType'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `ProjectType` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加BatteryApplicationType |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='BatteryApplicationType'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `BatteryApplicationType` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加SingleRatedVoltage |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='SingleRatedVoltage'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `SingleRatedVoltage` float DEFAULT '0';"); |
| | | } |
| | | //添加RemoteMonitor |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='RemoteMonitor'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `RemoteMonitor` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加BatttIndependentPlaced |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='BatttIndependentPlaced'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `BatttIndependentPlaced` varchar(64) DEFAULT '';"); |
| | | } |
| | | //添加JunChargeVoltageValue |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='JunChargeVoltageValue'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `JunChargeVoltageValue` float DEFAULT '0';"); |
| | | } |
| | | //添加PublicKeyX |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='PublicKeyX'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PublicKeyX` varchar(200) NOT NULL DEFAULT '';"); |
| | | } |
| | | //添加PublicKeyY |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='PublicKeyY'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `PublicKeyY` varchar(200) NOT NULL DEFAULT '';"); |
| | | } |
| | | //添加KeyID |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='KeyID'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `KeyID` varchar(200) NOT NULL DEFAULT '';"); |
| | | } |
| | | //添加SerialNumber |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='SerialNumber'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `SerialNumber` varchar(200) NOT NULL DEFAULT '';"); |
| | | } |
| | | //添加SerialNumber |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='video_url'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `video_url` varchar(200) DEFAULT NULL;"); |
| | | } |
| | | |
| | | //添加charge_type |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='charge_type'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `charge_type` int(11) NOT NULL DEFAULT '1' COMMENT '充放电状态:1:限流充电;2;逆变充电';"); |
| | | } |
| | | |
| | | //添加buscouple_state |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='buscouple_state'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `buscouple_state` int(11) NOT NULL DEFAULT '0' COMMENT '母联状态:0:无母联;1:有母联';"); |
| | | } |
| | | |
| | | //添加tmp_id |
| | | res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns" |
| | | + " WHERE table_schema='db_battinf'" |
| | | + " AND table_name='tb_battinf'" |
| | | + " AND column_name='tmp_id'"); |
| | | if(false == res.next()) { |
| | | sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.BattInf_Table |
| | | + " ADD COLUMN `tmp_id` int(11) DEFAULT '0';"); |
| | | } |
| | | } catch (SQLException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | sql.close_con(); |
| | | } |
| | | } |
| | | } |