From 3bde0e9ee5b1e584c29e516fdfc9a99376d228d3 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq,com>
Date: 星期三, 19 八月 2020 16:48:53 +0800
Subject: [PATCH] 水冷提交

---
 WaterSystem_MonitorServer/src/com/sql/Sql_Mysql.java | 1819 +++++++++++++++++++++++++++++-----------------------------
 1 files changed, 914 insertions(+), 905 deletions(-)

diff --git a/WaterSystem_MonitorServer/src/com/sql/Sql_Mysql.java b/WaterSystem_MonitorServer/src/com/sql/Sql_Mysql.java
index dfb91cd..7a9dae4 100644
--- a/WaterSystem_MonitorServer/src/com/sql/Sql_Mysql.java
+++ b/WaterSystem_MonitorServer/src/com/sql/Sql_Mysql.java
@@ -1,905 +1,914 @@
-package com.sql;
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-import java.util.ArrayList;
-
-import com.base.Com;
-
-/**
- * 	创建数据库以及表格
- * @author 军
- *
- */
-public class Sql_Mysql 
-{
-	//--------------------------------------------------------------------------------------------//
-	final public static String DB_AppSys = "`db_app_sys`";
-	final public static String DB_BATT_INF = "`db_battinf`";
-	final public static String DB_BATT_TESTDATA = "`db_batt_testdata`";
-	final public static String DB_PARAM = "`db_param`";
-	final public static String DB_ALARM = "`db_alarm`";
-	final public static String DB_USER = "`db_user`";
-	final public static String DB_RamDB = "`db_ram_db`";
-	final public static String DB_RamDB_BATT_RT = "`db_ram_batt_rt`";
-	
-	final public static String DB_LD9_TESTDATA = "`db_ld9_testdata`";
-	final public static String WEB_Site = "web_site";
-	final public static String DB_Equipstand = "`db_equipstand`";										//独立设备信息数据库
-	final public static String DB_Equip_History = "`db_equip_history`";									//独立设备历史数据数据库
-	final public static String DB_Equip_Alarm = "`db_equip_alarm`";
-	
-	final public static String DB_DynamicSystem = "`db_dynamicsystem`";
-	final public static String DB_Elemachinery = "`db_elemachinery`";
-	final public static String DB_Motor_Realhistory = "`db_motor_realhistory`";
-	
-	final public static String DB_ElectricSystem = "`db_electricsystem`";
-	//--------------------------------------------------------------------------------------------//
-	public final static String TB_HardDevSmsState = "tb_hard_dev_sms_state";
-	//--------------------------------------------------------------------------------------------//
-	public final static String TB_AppSys = "tb_app_sys";
-	
-	public final static String TB_BattTestDataInf = "tb_batttestdata_inf";
-	
-	public final static String TB_Ld9testdata_inf=DB_LD9_TESTDATA+".tb_ld9testdata_inf";
-	public final static String TB_Ld9testdata=DB_LD9_TESTDATA+".tb_ld9testdata_";
-	public final static String TB_Ld9testdatastop=DB_LD9_TESTDATA+".tb_ld9testdatastop_";
-	
-	public final static String TB_UserInf = "tb_user_inf";
-	public final static String TB_UserLog = "tb_user_log";
-	public final static String TB_UserBattGroup_BaoJiGroup = "tb_user_battgroup_baojigroup";
-	public final static String TB_UserBattGroup_BaoJiGroup_BattGroup = "tb_user_battgroup_baojigroup_battgroup";
-	public final static String TB_UserBattGroup_BaoJiGroup_Usr = "tb_user_battgroup_baojigroup_usr";
-	public final static String TB_UserTaskTemplate = "tb_user_task_batt_template";
-	public final static String TB_UserTask = "tb_user_task";
-	public final static String TB_UserPaiXiu = "tb_user_paixiu";
-	public final static String TB_UserListForTask = "tb_user_task_user_list";
-	public final static String TB_UserTaskParam = "tb_user_task_param";
-	public final static String TB_UserBattCkeckTask = "tb_user_task_batt_check";
-	public final static String TB_UserBattTestTask = "tb_user_task_batt_test";
-	public final static String TB_UserBattTaskChange = "tb_user_task_change";
-	public final static String TB_UserSms = "tb_user_sms";
-	public final static String TB_UserSmsFormat = "tb_user_sms_format";
-	public final static String TB_UserPermitGroup = "tb_user_permitgroup";
-	public final static String TB_UserPermitGroupData = "tb_user_permitgroup_data";
-	public final static String TB_UserJieJiaRi = "tb_user_jiejiari";
-	//--------------------------------------------------------------------------------------------//
-	//--------------------------------------------------------------------------------------------//
-	public final static String ServerState_Table = DB_RamDB + ".`tb_server_state`";
-	public final static String BattRtData_Table = DB_RamDB + ".`tb_batt_rtdata`";
-	public final static String BattRtState_Table = DB_RamDB + ".`tb_batt_rtstate`";
-	
-	public final static String LD9_State_Table =DB_RamDB+".tb_LD9_state";
-	public final static String LD9_Setparam_Table =DB_RamDB+".tb_LD9_setparam";
-	
-	public final static String CInterfaceState_Table = DB_RamDB + ".`tb_cinterface_state`";
-	
-	public final static String HardDevSmsState_Table = DB_RamDB + ".`tb_hard_dev_sms_state`";
-	public final static String FBS9100State_Table = DB_RamDB + ".`tb_fbs9100_state`";
-	public final static String FBS9100S_DcDcState_Table = DB_RamDB + ".`tb_fbs9100s_dcdc_state`";
-	public final static String FBS9100SetParam_Table = DB_RamDB + ".`tb_fbs9100_setparam`";
-	public final static String FBS9100S_DFUState_Table = DB_RamDB + ".`tb_fbs9100s_DFU_state`";
-	
-	public final static String BMP7100State_Table = DB_RamDB + ".`tb_bpm7100_state`";
-	
-	public final static String FBS9600State_Table = DB_RamDB + ".`tb_fbs9600_state`";
-	public final static String FBS9600SetParam_Table = DB_RamDB + ".`tb_fbs9600_setparam`";
-	//public final static String FBS9600Param_Table = DB_RamDB + ".`tb_fbs9600_param`";
-	public final static String SocketClientStateTable = DB_RamDB + ".`tb_socketclient_state`";
-	public final static String RamDB_CMCC_POWER_Data = DB_RamDB + ".`cmcc_power_data`";
-	public final static String RamLD9_UpdateStatue_Table = DB_RamDB + ".`tb_ld9_updatestatue`";				//9度设备升级表
-	
-	public final static String LD9_ConcentratorParam_Table = DB_RamDB + ".`tb_ld9_ConcentrateParam`"; 		//9度汇集器参数表
-	public final static String LD9_ConcentratorState_Table = DB_RamDB + ".`tb_ld9_ConcentrateState`"; 		//9度汇集器状态表
-	
-	public final static String BTSGPRSState_Table = DB_RamDB + ".`tb_bts_gprs_state`";
-	
-	
-	//--------------------------------------------------------------------------------------------//
-	//--------------------------------------------------------------------------------------------//
-	public final static String AppSys_Table = DB_AppSys + ".`tb_app_sys`";
-	public final static String FBSDevStateChangeInf_Table = DB_AppSys + ".`tb_fbsdev_statechange_inf`";
-	public final static String BattInf_Table = DB_BATT_INF + ".`tb_battinf`";
-	public final static String BattCurrInf_Table = DB_BATT_INF + ".`tb_battcurr_inf`";
-	public final static String BattMainInf_Table = DB_BATT_INF + ".`tb_batt_maint_inf`";
-	public final static String BattMainProcess_Table = DB_BATT_INF + ".`tb_batt_maint_process`";
-	
-	
-	public final static String BattTestDataInf_Table = DB_BATT_TESTDATA + ".`tb_batttestdata_inf`";
-	public final static String BattResData_Table = DB_BATT_TESTDATA + ".`tb_BattResData`";
-	public final static String BattResDataInf_Table = DB_BATT_TESTDATA + ".`tb_battresdata_inf`";
-	
-	public final static String UserInfTable = DB_USER + ".`tb_user_inf`";
-	public final static String UserLogTable = DB_USER + ".`tb_user_log`";
-	public final static String UserBattGroup_BaoJiGroup_Table = DB_USER + ".`tb_user_battgroup_baojigroup`";
-	public final static String UserBattGroup_BaoJiGroup_BattGroupTable = DB_USER + ".`tb_user_battgroup_baojigroup_battgroup`";
-	public final static String UserBattGroup_BaoJiGroup_UsrTable = DB_USER + ".`tb_user_battgroup_baojigroup_usr`";
-	public final static String UserTaskTemplateTable = DB_USER + ".`tb_user_task_batt_template`";
-	public final static String UserTaskTable = DB_USER + ".`tb_user_task`";
-	public final static String UserPaiXiuTable = DB_USER + ".`tb_user_paixiu`";
-	public final static String UserListForTaskTable = DB_USER + ".`tb_user_task_user_list`";
-	public final static String UserTaskParamTable = DB_USER + ".`tb_user_task_param`";
-	public final static String UserBattCheckTaskTable = DB_USER + ".`tb_user_task_batt_check`";
-	public final static String UserBattTestTaskTable = DB_USER + ".`tb_user_task_batt_test`";
-	
-	public final static String UserBattTaskChangeTable = DB_USER + ".`tb_user_task_change`";
-	
-	public final static String UsrBattMaintCheck_Table = DB_USER + ".`tb_user_battmaint_check`";
-	public final static String UsrBattMaintCheckProcess_Table = DB_USER + ".`tb_user_battmaint_check_process`";
-	
-	public final static String UserSmsTable = DB_USER + ".`tb_user_sms`";
-	public final static String UserSmsFormatTable = DB_USER + ".`tb_user_sms_format`";
-	public final static String UserPermitGroupTable = DB_USER + ".`tb_user_permitgroup`";
-	public final static String UserPermitGroupDataTable = DB_USER + ".`tb_user_permitgroup_data`";
-	public final static String UserJieJiaRiTable = DB_USER + ".`tb_user_jiejiari`";
-	//--------------------------------------------------------------------------------------------//
-	public final static String Tb_BattDischarge_ParamTable = WEB_Site+".tb_battdischarge_param";		//电池放电计划参数表	
-	public final static String Tb_BattMap_InformationTable = WEB_Site+".tb_battmap_information";		//电池定位信息表
-	public final static String Tb_Batt_DevDischargeTable = WEB_Site+".tb_batt_devdischarge";			//几种运营商的电压电流情况表
-	public final static String Tb_BattDischarge_PlanTable = WEB_Site+".tb_battdischarge_plan";			//电池放电计划表
-	public final static String Tb_Batt_ElectricityTable = WEB_Site+".tb_batt_electricity";				//运营商设备的用电量表
-	public final static String Tb_Batt_Devdischarge_ParamTable = WEB_Site+".tb_batt_devdischarge_param";	//运营商设备记录的参数表
-	public final static String Tb_Batt_Devdischarge_CMTable = WEB_Site+".tb_batt_devdischarge_CM";			//移动每个时间戳的电压电流功率表
-	public final static String Tb_Batt_Devdischarge_CTTable = WEB_Site+".tb_batt_devdischarge_CT";			//电信每个时间戳的电压电流功率表
-	public final static String Tb_Batt_Devdischarge_CUTable = WEB_Site+".tb_batt_devdischarge_CU";			//联通每个时间戳的电压电流功率表
-	public final static String Tb_CustomPageTable = WEB_Site + ".tb_custompage";							//页面导航表
-	public final static String Tb_Vip_UserTable = WEB_Site + ".tb_vip_user";								//超级管理员表
-	public final static String Tb_Batt_Param_LowTable = WEB_Site + ".tb_batt_param_low";					//蓄电池各种告警更换参数表
-	public final static String Tb_AnnounceTable = WEB_Site + ".tb_announce";								//公告信息表
-	public final static String Tb_ProcessSurvey = WEB_Site + ".tb_process_survey";							//线程监控表
-	//--------------------------------------------------------------------------------------------//
-	public final static String Tb_Device_InfTable = DB_Equipstand + ".tb_device_inf";						//独立设备-设备信息表 
-	public final static String Tb_DevData_Rt = DB_Equipstand + ".tb_devdata_rt_";							//独立设备-实时状态表 
-	public final static String Tb_DevData_Rt_Cfg = DB_Equipstand + ".tb_devdata_rt_cfg";					//独立设备-实时/历史状态配置表 
-	public final static String Tb_Devdata_Backup_Cfg = DB_Equipstand + ".tb_devdata_backup_cfg";			//独立设备-FTP文件备份信息表
-	//--------------------------------------------------------------------------------------------//
-	public final static String Tb_DevData_historyTable = DB_Equip_History + ".tb_devdata_history_";			//独立设备-历史实时数据记录表
-	public final static String Tb_DevAlarm_Data = DB_Equip_Alarm + ".tb_devalarm_data_";					//独立设备-实时告警数据记录表
-	public final static String Tb_DevAlarm_Data_History = DB_Equip_Alarm + ".tb_devalarm_data_history_";	//独立设备-历史告警数据记录表
-	//--------------------------------------------------------------------------------------------//
-	public final static String Tb_Dynamicload_inf = DB_DynamicSystem + ".tb_dynamicload_inf";				//设备信息表
-	public final static String Tb_Dynamicload_State_rt = DB_DynamicSystem + ".tb_dynamicload_state_rt";		//设备状态表
-	public final static String Tb_Dynamicload_Button_Rt = DB_DynamicSystem +".tb_dynamicload_button_rt";	//按钮反馈表
-	public final static String Tb_Dynamicload_Control = DB_DynamicSystem + ".tb_dynamicload_control";		//电源柜控制表
-	//--------------------------------------------------------------------------------------------//
-	public final static String Tb_Motor_inf = DB_Elemachinery + ".tb_motor_inf";							//电机信息表
-	public final static String Tb_Motor_control = DB_Elemachinery + ".tb_motor_control";					//电机控制表
-	public final static String Tb_Load_Motor_state = DB_Elemachinery + ".tb_load_motor_state";				//加载电机状态表
-	public final static String Tb_Subject_Motor_state = DB_Elemachinery + ".tb_subject_motor_state";		//受试电机状态表
-	public final static String Tb_Devalarm_Rt = DB_Elemachinery + ".tb_devalaram_rt";						//电机实时告警记录表
-	public final static String Tb_Devalarm_History = DB_Elemachinery + ".tb_devalaram_history";				//电机历史告警记录表
-	public final static String Tb_Motor_Readdata = DB_Motor_Realhistory + ".tb_motor_readdata_";			//电机历史实时记录表
-	
-	//--------------------------------------------------------------------------------------------//
-	/***			电源控制相关表										*****/
-	public final static String Tb_Electric_Control_Single = DB_ElectricSystem + ".tb_electric_control_single";		//电源单点控制表
-	public final static String Tb_Electric_Power = DB_ElectricSystem + ".tb_electric_power";						//电源控制状态表
-	public final static String Tb_Electric_Rt = DB_ElectricSystem + ".tb_electric_rt";								
-	public final static String Tb_Electric_State = DB_ElectricSystem + ".tb_electric_state";									
-	public final static String Tb_Electric_Switch = DB_ElectricSystem + ".tb_electric_switch";
-	
-	
-	//--------------------------------------------------------------------------------------------//
-	public Connection mysql_con;
-	
-	public Sql_Mysql(Connection conn)
-	{
-		mysql_con = conn;
-	}
-	
-	/*
-	public static Connection getConnection() throws SQLException, java.lang.ClassNotFoundException{
-		String url = "jdbc:mysql://192.168.48.128:3306/studentinfo";
-		Class.forName("com.mysql.jdbc.Driver");
-		String userName = "root";
-		String password = "lmx8688139";
-		Connection con = DriverManager.getConnection(url,userName,password);
-		return con;
-	}
-	*/
-	
-	public void close_con()
-	{
-		try {
-			mysql_con.close();
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-	}
-	
-	public void checkAndCreateDB() throws SQLException
-	{
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_AppSys);
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_BATT_INF);
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_BATT_TESTDATA);
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_PARAM);
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_ALARM);
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_USER);
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_RamDB);
-		
-		sqlMysqlExecute("DROP DATABASE IF EXISTS " + DB_RamDB_BATT_RT);
-		//sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_RamDB_BATT_RT);
-		
-		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + WEB_Site);
-		
-		String table_0 = "CREATE TABLE IF NOT EXISTS " + AppSys_Table
-						+ " ( `num` INT NOT NULL AUTO_INCREMENT,"
-						+ "`SqlDB_Version` FLOAT NOT NULL DEFAULT '1.0',"
-						+ "`SqlDB_BackUpTime` DATETIME NOT NULL DEFAULT '2000-1-1 00:00:00',"
-						+ "`SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`AppServer_Version` FLOAT NOT NULL DEFAULT '1.0',"
-						+ "`AppClient_Version` FLOAT NOT NULL DEFAULT '1.0',"
-						+ "`AppName` VARCHAR(50) NOT NULL DEFAULT '0',"
-						+ " PRIMARY KEY (`num`)) "
-						+ " ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_1 = "CREATE TABLE IF NOT EXISTS " + BattInf_Table
-						+ " ( `num` INT NOT NULL AUTO_INCREMENT,"
-						+ "`StationId` VARCHAR(20) NOT NULL 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 NOT NULL DEFAULT '0',"
-						+ "`FBSDeviceIp` VARCHAR(50) NOT NULL DEFAULT '192.168.0.88',"
-						+ "`FBSDeviceName` VARCHAR(100) NOT NULL DEFAULT '0',"
-						+ "`GroupIndexInFBSDevice` INT NOT NULL DEFAULT '0',"
-						+ "`BattModel` VARCHAR(100) NOT NULL DEFAULT ' ',"
-						+ "`BattGroupId` INT NOT NULL DEFAULT '0',"
-						+ "`BattGroupNum` INT 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 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 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 NOT NULL DEFAULT '1095',"
-						+ "`SignalId` VARCHAR(20) NOT NULL DEFAULT '0',"
-						+ "`CInterFaceId` INT NOT NULL DEFAULT '0',"
-						+ "`SignalName` VARCHAR(50) NOT NULL DEFAULT '0',"
-						+ "INDEX index_station_id (`StationId`), "
-						+ "INDEX index_battgroup_id (`BattGroupId`), "
-						+ "INDEX index_station_name (`StationName`), "
-						+ "INDEX index_battgroup_name (`BattGroupName`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_2 = "CREATE TABLE IF NOT EXISTS " + BattCurrInf_Table
-						+ " ( `num` INT 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;";
-		
-		String table_3 = "CREATE TABLE IF NOT EXISTS " + BattMainInf_Table
-						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
-						+ "`usr_id` INT NOT NULL DEFAULT 0, "
-						+ "`fault_type_id` INT NOT NULL DEFAULT 0, "
-						+ "`fault_type` VARCHAR(50) NOT NULL DEFAULT ' ', "
-						+ "`fault_level` INT NOT NULL DEFAULT 0, "
-						+ "`fault_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "`fault_time` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
-						+ "`record_uid` INT NOT NULL DEFAULT 0, "
-						+ "`record_time` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
-						+ "`maint_time_limit` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
-						+ "`maint_type_id` INT NOT NULL DEFAULT 0, "
-						+ "`maint_type` VARCHAR(50) NOT NULL DEFAULT ' ', "
-						+ "`maint_result` VARCHAR(100) NOT NULL DEFAULT ' ', "
-						+ "`maint_done` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`maint_done_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
-						+ "`maint_close` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`master_id` INT NOT NULL DEFAULT 0, "
-						+ "`master_audit` INT NOT NULL DEFAULT 0, "				//领导审核
-						+ "`appoint_uid` INT NOT NULL DEFAULT 0, " 				//指派给谁
-						+ "`copy_uids` VARCHAR(200) NOT NULL DEFAULT ' ', "		//抄送给谁
-						+ "`master_check` VARCHAR(100) NOT NULL DEFAULT ' ', "
-						+ "`remark` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "INDEX index_battgroup_id (`BattGroupId`), "
-						+ "INDEX index_user_id (`usr_id`), "
-						+ "INDEX index_fault_type_id (`fault_type_id`), "
-						+ "INDEX index_maint_type_id (`maint_type_id`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_3_1 = "CREATE TABLE IF NOT EXISTS " + BattMainProcess_Table
-						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`batt_maint_rec_id` BIGINT NOT NULL DEFAULT 0, "
-						+ "`usr_id` INT NOT NULL DEFAULT 0, "
-						+ "`work_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "`work_caption_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
-						+ "INDEX index_batt_maint_rec_id (`batt_maint_rec_id`), "
-						+ " PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_3_2 = "CREATE TABLE IF NOT EXISTS " + UsrBattMaintCheck_Table
-						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`StationId` INT NOT NULL DEFAULT 0, "
-						+ "`usr_id` INT NOT NULL DEFAULT 0, "
-						+ "`master_id` INT NOT NULL DEFAULT 0, "
-						+ "`appoint_uid` INT NOT NULL DEFAULT 0, " 				//指派给谁
-						+ "`copy_uids` VARCHAR(200) NOT NULL DEFAULT ' ', "		//抄送给谁
-						+ "`task_type_id` INT NOT NULL DEFAULT 0, "
-						+ "`task_level` INT NOT NULL DEFAULT 0, "
-						+ "`task_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "`task_time_start` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
-						+ "`task_time_end` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
-						+ "`task_process` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "`task_done` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`task_done_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
-						+ "`origin_usr_work_mark` INT NOT NULL DEFAULT 0, "
-						+ "`task_done_confirm` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`master_audit` INT NOT NULL DEFAULT 0, "				//领导审核
-						+ "`remark` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "INDEX index_station_id (`StationId`), "
-						+ "INDEX index_user_id (`usr_id`), "
-						+ "INDEX index_task_type_id (`task_type_id`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_3_2_1 = "CREATE TABLE IF NOT EXISTS " + UsrBattMaintCheckProcess_Table
-						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`task_rec_id` BIGINT NOT NULL DEFAULT 0, "
-						+ "`usr_id` INT NOT NULL DEFAULT 0, "
-						+ "`work_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
-						+ "`work_caption_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
-						+ "INDEX index_task_rec_id (`task_rec_id`), "
-						+ " PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_4 = "CREATE TABLE IF NOT EXISTS " + BattTestDataInf_Table
-						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
-						+ "`test_record_count` INT NOT NULL DEFAULT 0, "
-						+ "`test_record_count_ex` INT NOT NULL DEFAULT 0, "
-						+ "`test_type` INT NOT NULL DEFAULT 0, "
-						+ "`record_time_interval` INT NOT NULL DEFAULT 0, "
-						+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`record_num` INT NOT NULL DEFAULT 0, "
-						+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
-						+ "`test_starttime_ex` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
-						+ "`test_starttype` INT NOT NULL DEFAULT 0, "
-						+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
-						+ "`test_timelong` INT NOT NULL DEFAULT 0, "
-						+ "`test_stoptype` INT NOT NULL DEFAULT 0, "
-						+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
-						+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
-						+ "`test_cap` FLOAT NOT NULL DEFAULT 0, "
-						+ "`max_monnum` INT NOT NULL DEFAULT 0, "
-						+ "`max_monvol` FLOAT NOT NULL DEFAULT 0, "
-						+ "`min_monnum` INT NOT NULL DEFAULT 0, "
-						+ "`min_monvol` FLOAT NOT NULL DEFAULT 0, "
-						+ "`mon_num` INT NOT NULL DEFAULT 0, "
-						+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
-						+ "`upload_usr_id` INT NOT NULL DEFAULT 0, "
-						+ "`upload_data_ext` INT NOT NULL DEFAULT 0, "
-						+ "`upload_client_type` INT NOT NULL DEFAULT 0, "
-						+ "INDEX index_battgroup_id (`BattGroupId`), "
-						+ "INDEX index_test_record_count (`test_record_count`), "
-						+ "INDEX index_test_type (`test_type`), "
-						+ "INDEX index_test_starttime (`test_starttime`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_5 = "CREATE TABLE IF NOT EXISTS " + BattResDataInf_Table
-						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
-						+ "`test_record_count` INT NOT NULL DEFAULT 0, "
-						+ "`test_record_count_ex` INT NOT NULL DEFAULT 0, "
-						+ "`test_type` INT NOT NULL DEFAULT 0, "
-						+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
-						+ "`test_starttime_ex` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
-						+ "`test_devtype` INT NOT NULL DEFAULT 0, "
-						+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
-						+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
-						+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
-						+ "`upload_usr_id` INT NOT NULL DEFAULT 0, "
-						+ "`upload_client_type` INT NOT NULL DEFAULT 0, "
-						+ "INDEX index_battgroup_id (`BattGroupId`), "
-						+ "INDEX index_test_record_count (`test_record_count`), "
-						+ "INDEX index_test_starttime (`test_starttime`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		
-		String table_6 = "DROP TABLE IF EXISTS " + SocketClientStateTable + "; ";
-		String table_7 = "CREATE TABLE IF NOT EXISTS " + SocketClientStateTable
-						+ "(`num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`uId` INT NOT NULL DEFAULT 0, "
-						+ "`client_type` INT NOT NULL DEFAULT 0, "
-						+ "`client_id` BIGINT NOT NULL DEFAULT 0, "
-						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
-						+ "`client_is_connected` BOOLEAN NOT NULL DEFAULT false, "
-						+ "`client_ip` VARCHAR(64) NOT NULL DEFAULT ' ', "
-						+ "`client_conn_time` DATETIME NOT NULL DEFAULT '1980-01-01', "
-						+ "`client_disconn_time` DATETIME NOT NULL DEFAULT '1980-01-01', "
-						+ "INDEX index_user_id (`uId`), "
-						+ "INDEX index_client_type (`client_type`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=MEMORY DEFAULT CHARSET=utf8;";
-		
-		String table_8 = "CREATE TABLE IF NOT EXISTS " + FBSDevStateChangeInf_Table
-						+ "(`num` BIGINT NOT NULL AUTO_INCREMENT, "
-						+ "`dev_id` INT NOT NULL DEFAULT 0, "
-						+ "`rec_time` DATETIME NOT NULL DEFAULT '1980-01-01', "
-						+ "`last_stat` INT NOT NULL DEFAULT 0, "
-						+ "`now_stat` INT NOT NULL DEFAULT 0, "
-						+ "`state_change_reason` INT NOT NULL DEFAULT 0, "
-						+ "`dev_alarm` INT NOT NULL DEFAULT 0, "
-						+ "INDEX index_dev_id (`dev_id`), "
-						+ "PRIMARY KEY (`num`)) "
-						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
-		//-------------------------------------------------------------------------------------//
-		//-------------------------------------------------------------------------------------//
-		sqlMysqlUseDB(Sql_Mysql.DB_AppSys);
-		if(false == sqlMysqlCheckIfTableExist(TB_AppSys))
-		{
-			sqlMysqlExecute(table_0);
-			sqlMysqlExecute("INSERT INTO " + Sql_Mysql.AppSys_Table 
-								+ " (AppName) VALUES ('蓄电池组综合管理系统')");
-		}
-		//-------------------------------------------------------------------------------------//
-		{
-			ResultSet rest = sqlMysqlQuery("SELECT AppServer_Version FROM " + Sql_Mysql.AppSys_Table);
-			if(rest.next()) {
-				float ser_version = rest.getFloat(1);
-				if(ser_version < 1.387) {
-					sqlMysqlExecute("UPDATE " + Sql_Mysql.AppSys_Table + " SET AppServer_Version=1.388");
-					sqlMysqlExecute("USE db_batt_testdata");
-					sqlMysqlExecute("UPDATE tb_batttestdata_inf SET "
-									+ " test_starttime=date_sub(test_starttime, interval 1 month) "
-									+ " WHERE upload_usr_id>0");
-				}
-			}
-		}
-		//---------------------------------------------------------------------------------------------//
-		ResultSet res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns"
-								+ " WHERE table_schema='db_app_sys'"
-								+ " AND table_name='tb_app_sys'"
-								+ " AND column_name='SqlDB_BackUpTime'");
-		if(false == res0.next()) {
-			sqlMysqlExecute("ALTER TABLE " + AppSys_Table 
-							+ " ADD COLUMN `SqlDB_BackUpTime` DATETIME NOT NULL DEFAULT '2000-1-1 00:00:00'"
-							+ " AFTER `SqlDB_Version`,"
-							+ " ADD COLUMN `SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false"
-							+ " AFTER `SqlDB_BackUpTime`");
-		}
-		res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns"
-							+ " WHERE table_schema='db_app_sys'"
-							+ " AND table_name='tb_app_sys'"
-							+ " AND column_name='SqlDB_BackUpManual_EN'");
-		if(false == res0.next()) {
-			sqlMysqlExecute("ALTER TABLE " + AppSys_Table 
-							+ " ADD COLUMN `SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false"
-							+ " AFTER `SqlDB_BackUpTime`");
-		}
-		//---------------------------------------------------------------------------------------------//
-		
-		sqlMysqlExecute(table_1);
-		sqlMysqlExecute(table_2);
-		sqlMysqlExecute(table_3);
-		sqlMysqlExecute(table_3_1);
-		sqlMysqlExecute(table_3_2);
-		sqlMysqlExecute(table_3_2_1);
-		sqlMysqlExecute(table_4);
-		sqlMysqlExecute(table_5);
-		sqlMysqlExecute(table_6);
-		sqlMysqlExecute(table_7);
-		sqlMysqlExecute(table_8);
-		
-		//---------------------------------------------------------------------------------------------//
-		ResultSet res = sqlMysqlQuery("show index from " + BattInf_Table + " where column_name='BattGroupId'");
-		if(false == res.next())
-		{
-			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_station_id` (`StationId` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_battgroup_id` (`BattGroupId` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_station_name` (`StationName` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_battgroup_name` (`BattGroupName` ASC);");
-		}
-		//---------------------------------------------------------------------------------------------//
-		//-------------------------------- 2017-06-06 by mxpopstar ------------------------------------//
-				res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
-										+ " WHERE table_schema='db_battinf'"
-										+ " AND table_name='tb_battinf'"
-										+ " AND column_name='BattGuarantDayCount'");
-				if(false == res.next()) {
-					sqlMysqlExecute("ALTER TABLE " + BattInf_Table 
-									+ " ADD COLUMN `BattGuarantDayCount` INT NOT NULL DEFAULT 1095 AFTER `BattInUseDate`");
-				}
-				//---------------------------------------------------------------------------------------------//
-		//---------------------------------------------------------------------------------------------//
-		res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
-								+ " WHERE table_schema='db_battinf'"
-								+ " AND table_name='tb_batt_maint_inf'"
-								+ " AND column_name='master_audit'");
-		if(false == res.next()) {
-			sqlMysqlExecute("ALTER TABLE " + BattMainInf_Table 
-							+ " ADD COLUMN `fault_type_id` INT NOT NULL DEFAULT 0 AFTER `usr_id`,"
-							+ " ADD COLUMN `maint_type_id` INT NOT NULL DEFAULT 0 AFTER `maint_time_limit`,"
-							+ " ADD COLUMN `master_audit` INT NOT NULL DEFAULT 0 AFTER `master_id`,"
-							+ " ADD COLUMN `maint_close` BOOLEAN NOT NULL DEFAULT FALSE AFTER `maint_done_time`,"
-							+ " ADD COLUMN `appoint_uid` INT NOT NULL DEFAULT 0 AFTER `master_audit`,"
-							+ " ADD COLUMN `copy_uids` VARCHAR(200) NOT NULL DEFAULT ' ' AFTER `master_audit`");
-		}
-		//---------------------------------------------------------------------------------------------//
-		//---------------------------------------------------------------------------------------------//
-		res = sqlMysqlQuery("show index from " + BattTestDataInf_Table + " where column_name='test_starttime'");
-		if(false == res.next())
-		{
-			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " ADD INDEX `index_test_record_count` (`test_record_count` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " ADD INDEX `index_test_type` (`test_type` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " ADD INDEX `index_test_starttime` (`test_starttime` ASC);");
-		}
-		//---------------------------------------------------------------------------------------------//
-		//---------------------------------------------------------------------------------------------//
-		res = sqlMysqlQuery("show index from " + BattResDataInf_Table + " where column_name='test_starttime'");
-		if(false == res.next())
-		{
-			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " ADD INDEX `index_test_record_count` (`test_record_count` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " ADD INDEX `index_test_type` (`test_type` ASC);");
-			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " ADD INDEX `index_test_starttime` (`test_starttime` ASC);");
-		}
-		//---------------------------------------------------------------------------------------------//
-		res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
-										+ " WHERE table_schema='db_batt_testdata'"
-										+ " AND table_name='tb_batttestdata_inf'"
-										+ " AND column_name='test_record_count_ex'");
-		if(false == res.next())
-		{
-			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table
-							+ " ADD COLUMN `test_record_count_ex` INT NOT NULL DEFAULT 0 AFTER `test_record_count`,"
-							+ " ADD COLUMN `test_starttime_ex` DATETIME NOT NULL DEFAULT '1920-01-01 00:00:00' AFTER `test_starttime`,"
-							+ " ADD COLUMN `upload_usr_id` INT NOT NULL DEFAULT 0 AFTER `mon_vol`");
-		}
-		//---------------------------------------------------------------------------------------------//
-		//---------------------------------------------------------------------------------------------//
-		res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
-												+ " WHERE table_schema='db_batt_testdata'"
-												+ " AND table_name='tb_batttestdata_inf'"
-												+ " AND column_name='upload_data_ext'");
-		if(false == res.next())
-		{
-			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table
-							+ " ADD COLUMN `upload_data_ext` INT NOT NULL DEFAULT 0 AFTER `upload_usr_id`,"
-							+ " ADD COLUMN `upload_client_type` INT NOT NULL DEFAULT 0 AFTER `upload_data_ext`");
-			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table
-							+ " ADD COLUMN `upload_client_type` INT NOT NULL DEFAULT 0 AFTER `upload_usr_id`");
-		}
-		//---------------------------------------------------------------------------------------------//
-		//----------------------------将num自增字段改为bigint类型---------------------------------------//
-		res = sqlMysqlQuery("SELECT DATA_TYPE FROM information_schema.columns"
-										+ " WHERE table_schema='db_batt_testdata'"
-										+ " AND table_name='tb_batttestdata_inf'"
-										+ " AND column_name='num'");
-		if(true == res.next()) {
-			if(false == "bigint".equals(res.getString("DATA_TYPE").toLowerCase())) {
-				sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " MODIFY COLUMN num BIGINT NOT NULL AUTO_INCREMENT;");
-				sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " MODIFY COLUMN num BIGINT NOT NULL AUTO_INCREMENT;");
-			}
-		}
-		//---------------------------------------------------------------------------------------------//
-	}
-	
-	//使用db数据库
-	public void sqlMysqlUseDB(String db) throws SQLException
-	{
-		sqlMysqlExecute("use " + db);
-	}
-	
-	//获取电池组机房的个数
-	public int getBattStationCount()
-	{
-		int st_count = 0;
-		
-		try {
-			sqlMysqlUseDB(Sql_Mysql.DB_BATT_INF);
-			
-			String sql_str = "SELECT DISTINCT StationId FROM " + BattInf_Table;
-			ResultSet res = sqlMysqlQuery(sql_str);
-			while(res.next())
-			{
-				st_count++;
-			}
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-		
-		return st_count;
-	}
-	
-	/**
-	 * 检查tb表是否存在
-	 * @param tb
-	 * @return
-	 * @throws SQLException
-	 */
-	public boolean sqlMysqlCheckIfTableExist(String tb) throws SQLException
-	{
-		String sql_str = "SHOW TABLES LIKE '" + tb + "'";
-		ResultSet res = sqlMysqlQuery(sql_str);
-		boolean exist = false;
-		while(res.next())
-		{
-			exist = true;
-			break;
-		}
-		
-		return exist;
-	}
-	
-	//执行sql语句
-	public void sqlMysqlExecute(String sql_str) throws SQLException
-	{
-		Statement sql = mysql_con.createStatement();
-		sql.setQueryTimeout(30);
-		sql.execute(sql_str);
-	}
-	
-	
-	//在事物中执行多条sql语句
-	public boolean makeManualCommit(ArrayList<String> al_sql_strs) 
-	{
-		boolean exe_res = true;
-		try {
-			mysql_con.setAutoCommit(false);
-			
-			for(int n=0; n<al_sql_strs.size(); n++) {
-				sqlMysqlExecute(al_sql_strs.get(n));
-			}
-			
-			if(true == exe_res) {
-				mysql_con.commit();
-			}
-		} catch (SQLException e) {
-			// TODO Auto-generated catch block
-			e.printStackTrace();
-			exe_res = false;
-		} finally {
-			try {
-				if(false == exe_res) {
-					mysql_con.rollback();
-				}
-				mysql_con.setAutoCommit(true);
-			} catch (SQLException e1) {
-				// TODO Auto-generated catch block
-				e1.printStackTrace();
-			}
-		}
-		
-		return exe_res;
-	}
-	
-	//根据sql语句执行sql查询语句
-	public ResultSet sqlMysqlQuery(String sql_str)
-	{
-		ResultSet res = null;
-		try
-    	{
-			Statement sql = mysql_con.createStatement();
-			sql.setQueryTimeout(30);
-			String query = sql_str;
-			res =  sql.executeQuery(query);
-    	}
-    	catch(SQLException ex)
-		{
-			System.err.println("SQLException:" + ex.getMessage());
-		}
-		
-		return res;
-	}
-	
-	//根据sql语句执行sql更新语句
-	public void sqlMysqlUpdate(String sql_str)
-	{
-		try
-    	{
-			Statement sql = mysql_con.createStatement();
-			sql.setQueryTimeout(30);
-			String query = sql_str;
-			sql.execute(query);
-    	}
-    	catch(SQLException ex)
-		{
-			System.out.println("SQLException:" + ex.getMessage());
-		}
-	}
-	
-	//根据电池组id 获取机房名称
-	public String getStationName(int bg_id)
-	{
-		String stname = " ";
-		
-		String sql_str = "SELECT DISTINCT StationName FROM " 
-							+ Sql_Mysql.BattInf_Table + " WHERE BattGroupId=" + bg_id;
-		ResultSet res = sqlMysqlQuery(sql_str);
-		try {
-			if(res.next())
-			{
-				stname = res.getString("StationName");
-			}
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-		
-		return stname;
-	}
-	
-	//根据电池组id 获取电池组名称
-	public String getBattGroupName(int bg_id)
-	{
-		String bgname = " ";
-		
-		String sql_str = "SELECT DISTINCT BattGroupName FROM " 
-							+ Sql_Mysql.BattInf_Table + " WHERE BattGroupId=" + bg_id;
-		ResultSet res = sqlMysqlQuery(sql_str);
-		try {
-			if(res.next())
-			{
-				bgname = res.getString("BattGroupName");
-			}
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-		
-		return bgname;
-	}
-	
-	//根据用户的id获取用户的名称
-	public String getUsrName(int uid)
-	{
-		String usrname = " ";
-		
-		String sql_str = "SELECT uName FROM " + Sql_Mysql.UserInfTable + " WHERE uId=" + uid;
-		ResultSet res = sqlMysqlQuery(sql_str);
-		try {
-			if(res.next())
-			{
-				usrname = res.getString("uName");
-			}
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-		
-		return usrname;
-	}
-	
-	//根据format_type 获取format_str 的样式
-	public String getTaskSmsFormatStr(String format_type)
-	{
-		String str = "";
-		String sql_str = "SELECT DISTINCT " 
-						+ Sql_Mysql.UserSmsFormatTable + ".format_str"
-						+ " FROM " + Sql_Mysql.UserSmsFormatTable
-						+ " WHERE " 
-						+ Sql_Mysql.UserSmsFormatTable + ".format_type='" + format_type + "'";
-		
-		ResultSet sql_res = sqlMysqlQuery(sql_str);
-		try {
-			if(sql_res.next())
-			{
-				str = sql_res.getString("format_str");
-			}
-		} catch (SQLException e1) {
-			// TODO Auto-generated catch block
-			//e1.printStackTrace();
-		}
-		
-		return str;
-	}
-	
-	//根据作业id获取作业的名称
-	public String getUsrTaskName(int taskid)
-	{
-		String taskname = " ";
-		
-		String sql_str = "SELECT task_name FROM " + Sql_Mysql.UserTaskTable + " WHERE task_id=" + taskid;
-		ResultSet res = sqlMysqlQuery(sql_str);
-		try {
-			if(res.next()) {
-				taskname = res.getString("task_name");
-			}
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-		
-		return taskname;
-	}
-	
-	//根据作业id获取用户作业的创建时间
-	public String getUsrTaskCreateTime(int taskid)
-	{
-		String taskcreatetime = " ";
-		
-		String sql_str = "SELECT task_create_date FROM " + Sql_Mysql.UserTaskTable + " WHERE task_id=" + taskid;
-		ResultSet res = sqlMysqlQuery(sql_str);
-		try {
-			if(res.next())
-			{
-				taskcreatetime = Com.getDateTimeFormat(res.getTimestamp("task_create_date"), Com.DTF_YMDhms);
-			}
-		} catch (SQLException e) {
-			e.printStackTrace();
-		}
-		
-		return taskcreatetime;
-	}
-	
-	
-	//获取新创建的记录的testrecordcount的值
-	public int getBattTestRecordCountNew(int bg_id, String table)
-	{
-		int count = 0;
-		boolean res_exe = true;
-		String sql_str0 = "SELECT test_record_count_ex FROM " + table 
-							+ " WHERE BattGroupId=" + bg_id  + " FOR UPDATE";
-		String sql_str1 = "UPDATE " + table + " SET test_record_count_ex=test_record_count+1"
-							+ " WHERE BattGroupId=" + bg_id;
-		String sql_str2 = "SELECT MAX(test_record_count_ex) FROM " + table 
-							+ " WHERE BattGroupId=" + bg_id;
-		String sql_str3 = "INSERT INTO " + table + " (BattGroupId,test_record_count, test_record_count_ex) "
-							+ " VALUES (" + bg_id + "," + 1 + "," + 1 + ")";
-		try {
-			mysql_con.setAutoCommit(false);
-			ResultSet res = sqlMysqlQuery(sql_str0);
-			if(res.next()) {
-				sqlMysqlExecute(sql_str1);
-				res = sqlMysqlQuery(sql_str2);
-				if(res.next()) {
-					count = res.getInt(1);
-				}
-			} else {
-				count = 1;
-				sqlMysqlExecute(sql_str3);
-			}
-			
-			mysql_con.commit();
-		} catch (SQLException e) {
-			e.printStackTrace();
-			res_exe = false;
-		} finally {
-			if(false == res_exe) {
-				try {
-					mysql_con.rollback();
-					mysql_con.setAutoCommit(true);
-				} catch (SQLException e) {
-					// TODO Auto-generated catch block
-					e.printStackTrace();
-				}
-			}
-		}
-		
-		return count;
-	}
-}
+package com.sql;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+
+import com.base.Com;
+
+/**
+ * 	创建数据库以及表格
+ * @author 军
+ *
+ */
+public class Sql_Mysql 
+{
+	//--------------------------------------------------------------------------------------------//
+	final public static String DB_AppSys = "`db_app_sys`";
+	final public static String DB_BATT_INF = "`db_battinf`";
+	final public static String DB_BATT_TESTDATA = "`db_batt_testdata`";
+	final public static String DB_PARAM = "`db_param`";
+	final public static String DB_ALARM = "`db_alarm`";
+	final public static String DB_USER = "`db_user`";
+	final public static String DB_RamDB = "`db_ram_db`";
+	final public static String DB_RamDB_BATT_RT = "`db_ram_batt_rt`";
+	
+	final public static String DB_LD9_TESTDATA = "`db_ld9_testdata`";
+	final public static String WEB_Site = "web_site";
+	final public static String DB_Equipstand = "`db_equipstand`";										//独立设备信息数据库
+	final public static String DB_Equip_History = "`db_equip_history`";									//独立设备历史数据数据库
+	final public static String DB_Equip_Alarm = "`db_equip_alarm`";
+	
+	final public static String DB_DynamicSystem = "`db_dynamicsystem`";
+	final public static String DB_Elemachinery = "`db_elemachinery`";
+	final public static String DB_Motor_Realhistory = "`db_motor_realhistory`";
+	
+	final public static String DB_ElectricSystem = "`db_electricsystem`";
+	
+	final public static String DB_Watersystem = "`db_watersystem`";
+	
+	//--------------------------------------------------------------------------------------------//
+	public final static String TB_HardDevSmsState = "tb_hard_dev_sms_state";
+	//--------------------------------------------------------------------------------------------//
+	public final static String TB_AppSys = "tb_app_sys";
+	
+	public final static String TB_BattTestDataInf = "tb_batttestdata_inf";
+	
+	public final static String TB_Ld9testdata_inf=DB_LD9_TESTDATA+".tb_ld9testdata_inf";
+	public final static String TB_Ld9testdata=DB_LD9_TESTDATA+".tb_ld9testdata_";
+	public final static String TB_Ld9testdatastop=DB_LD9_TESTDATA+".tb_ld9testdatastop_";
+	
+	public final static String TB_UserInf = "tb_user_inf";
+	public final static String TB_UserLog = "tb_user_log";
+	public final static String TB_UserBattGroup_BaoJiGroup = "tb_user_battgroup_baojigroup";
+	public final static String TB_UserBattGroup_BaoJiGroup_BattGroup = "tb_user_battgroup_baojigroup_battgroup";
+	public final static String TB_UserBattGroup_BaoJiGroup_Usr = "tb_user_battgroup_baojigroup_usr";
+	public final static String TB_UserTaskTemplate = "tb_user_task_batt_template";
+	public final static String TB_UserTask = "tb_user_task";
+	public final static String TB_UserPaiXiu = "tb_user_paixiu";
+	public final static String TB_UserListForTask = "tb_user_task_user_list";
+	public final static String TB_UserTaskParam = "tb_user_task_param";
+	public final static String TB_UserBattCkeckTask = "tb_user_task_batt_check";
+	public final static String TB_UserBattTestTask = "tb_user_task_batt_test";
+	public final static String TB_UserBattTaskChange = "tb_user_task_change";
+	public final static String TB_UserSms = "tb_user_sms";
+	public final static String TB_UserSmsFormat = "tb_user_sms_format";
+	public final static String TB_UserPermitGroup = "tb_user_permitgroup";
+	public final static String TB_UserPermitGroupData = "tb_user_permitgroup_data";
+	public final static String TB_UserJieJiaRi = "tb_user_jiejiari";
+	//--------------------------------------------------------------------------------------------//
+	//--------------------------------------------------------------------------------------------//
+	public final static String ServerState_Table = DB_RamDB + ".`tb_server_state`";
+	public final static String BattRtData_Table = DB_RamDB + ".`tb_batt_rtdata`";
+	public final static String BattRtState_Table = DB_RamDB + ".`tb_batt_rtstate`";
+	
+	public final static String LD9_State_Table =DB_RamDB+".tb_LD9_state";
+	public final static String LD9_Setparam_Table =DB_RamDB+".tb_LD9_setparam";
+	
+	public final static String CInterfaceState_Table = DB_RamDB + ".`tb_cinterface_state`";
+	
+	public final static String HardDevSmsState_Table = DB_RamDB + ".`tb_hard_dev_sms_state`";
+	public final static String FBS9100State_Table = DB_RamDB + ".`tb_fbs9100_state`";
+	public final static String FBS9100S_DcDcState_Table = DB_RamDB + ".`tb_fbs9100s_dcdc_state`";
+	public final static String FBS9100SetParam_Table = DB_RamDB + ".`tb_fbs9100_setparam`";
+	public final static String FBS9100S_DFUState_Table = DB_RamDB + ".`tb_fbs9100s_DFU_state`";
+	
+	public final static String BMP7100State_Table = DB_RamDB + ".`tb_bpm7100_state`";
+	
+	public final static String FBS9600State_Table = DB_RamDB + ".`tb_fbs9600_state`";
+	public final static String FBS9600SetParam_Table = DB_RamDB + ".`tb_fbs9600_setparam`";
+	//public final static String FBS9600Param_Table = DB_RamDB + ".`tb_fbs9600_param`";
+	public final static String SocketClientStateTable = DB_RamDB + ".`tb_socketclient_state`";
+	public final static String RamDB_CMCC_POWER_Data = DB_RamDB + ".`cmcc_power_data`";
+	public final static String RamLD9_UpdateStatue_Table = DB_RamDB + ".`tb_ld9_updatestatue`";				//9度设备升级表
+	
+	public final static String LD9_ConcentratorParam_Table = DB_RamDB + ".`tb_ld9_ConcentrateParam`"; 		//9度汇集器参数表
+	public final static String LD9_ConcentratorState_Table = DB_RamDB + ".`tb_ld9_ConcentrateState`"; 		//9度汇集器状态表
+	
+	public final static String BTSGPRSState_Table = DB_RamDB + ".`tb_bts_gprs_state`";
+	
+	
+	//--------------------------------------------------------------------------------------------//
+	//--------------------------------------------------------------------------------------------//
+	public final static String AppSys_Table = DB_AppSys + ".`tb_app_sys`";
+	public final static String FBSDevStateChangeInf_Table = DB_AppSys + ".`tb_fbsdev_statechange_inf`";
+	public final static String BattInf_Table = DB_BATT_INF + ".`tb_battinf`";
+	public final static String BattCurrInf_Table = DB_BATT_INF + ".`tb_battcurr_inf`";
+	public final static String BattMainInf_Table = DB_BATT_INF + ".`tb_batt_maint_inf`";
+	public final static String BattMainProcess_Table = DB_BATT_INF + ".`tb_batt_maint_process`";
+	
+	
+	public final static String BattTestDataInf_Table = DB_BATT_TESTDATA + ".`tb_batttestdata_inf`";
+	public final static String BattResData_Table = DB_BATT_TESTDATA + ".`tb_BattResData`";
+	public final static String BattResDataInf_Table = DB_BATT_TESTDATA + ".`tb_battresdata_inf`";
+	
+	public final static String UserInfTable = DB_USER + ".`tb_user_inf`";
+	public final static String UserLogTable = DB_USER + ".`tb_user_log`";
+	public final static String UserBattGroup_BaoJiGroup_Table = DB_USER + ".`tb_user_battgroup_baojigroup`";
+	public final static String UserBattGroup_BaoJiGroup_BattGroupTable = DB_USER + ".`tb_user_battgroup_baojigroup_battgroup`";
+	public final static String UserBattGroup_BaoJiGroup_UsrTable = DB_USER + ".`tb_user_battgroup_baojigroup_usr`";
+	public final static String UserTaskTemplateTable = DB_USER + ".`tb_user_task_batt_template`";
+	public final static String UserTaskTable = DB_USER + ".`tb_user_task`";
+	public final static String UserPaiXiuTable = DB_USER + ".`tb_user_paixiu`";
+	public final static String UserListForTaskTable = DB_USER + ".`tb_user_task_user_list`";
+	public final static String UserTaskParamTable = DB_USER + ".`tb_user_task_param`";
+	public final static String UserBattCheckTaskTable = DB_USER + ".`tb_user_task_batt_check`";
+	public final static String UserBattTestTaskTable = DB_USER + ".`tb_user_task_batt_test`";
+	
+	public final static String UserBattTaskChangeTable = DB_USER + ".`tb_user_task_change`";
+	
+	public final static String UsrBattMaintCheck_Table = DB_USER + ".`tb_user_battmaint_check`";
+	public final static String UsrBattMaintCheckProcess_Table = DB_USER + ".`tb_user_battmaint_check_process`";
+	
+	public final static String UserSmsTable = DB_USER + ".`tb_user_sms`";
+	public final static String UserSmsFormatTable = DB_USER + ".`tb_user_sms_format`";
+	public final static String UserPermitGroupTable = DB_USER + ".`tb_user_permitgroup`";
+	public final static String UserPermitGroupDataTable = DB_USER + ".`tb_user_permitgroup_data`";
+	public final static String UserJieJiaRiTable = DB_USER + ".`tb_user_jiejiari`";
+	//--------------------------------------------------------------------------------------------//
+	public final static String Tb_BattDischarge_ParamTable = WEB_Site+".tb_battdischarge_param";		//电池放电计划参数表	
+	public final static String Tb_BattMap_InformationTable = WEB_Site+".tb_battmap_information";		//电池定位信息表
+	public final static String Tb_Batt_DevDischargeTable = WEB_Site+".tb_batt_devdischarge";			//几种运营商的电压电流情况表
+	public final static String Tb_BattDischarge_PlanTable = WEB_Site+".tb_battdischarge_plan";			//电池放电计划表
+	public final static String Tb_Batt_ElectricityTable = WEB_Site+".tb_batt_electricity";				//运营商设备的用电量表
+	public final static String Tb_Batt_Devdischarge_ParamTable = WEB_Site+".tb_batt_devdischarge_param";	//运营商设备记录的参数表
+	public final static String Tb_Batt_Devdischarge_CMTable = WEB_Site+".tb_batt_devdischarge_CM";			//移动每个时间戳的电压电流功率表
+	public final static String Tb_Batt_Devdischarge_CTTable = WEB_Site+".tb_batt_devdischarge_CT";			//电信每个时间戳的电压电流功率表
+	public final static String Tb_Batt_Devdischarge_CUTable = WEB_Site+".tb_batt_devdischarge_CU";			//联通每个时间戳的电压电流功率表
+	public final static String Tb_CustomPageTable = WEB_Site + ".tb_custompage";							//页面导航表
+	public final static String Tb_Vip_UserTable = WEB_Site + ".tb_vip_user";								//超级管理员表
+	public final static String Tb_Batt_Param_LowTable = WEB_Site + ".tb_batt_param_low";					//蓄电池各种告警更换参数表
+	public final static String Tb_AnnounceTable = WEB_Site + ".tb_announce";								//公告信息表
+	public final static String Tb_ProcessSurvey = WEB_Site + ".tb_process_survey";							//线程监控表
+	//--------------------------------------------------------------------------------------------//
+	public final static String Tb_Device_InfTable = DB_Equipstand + ".tb_device_inf";						//独立设备-设备信息表 
+	public final static String Tb_DevData_Rt = DB_Equipstand + ".tb_devdata_rt_";							//独立设备-实时状态表 
+	public final static String Tb_DevData_Rt_Cfg = DB_Equipstand + ".tb_devdata_rt_cfg";					//独立设备-实时/历史状态配置表 
+	public final static String Tb_Devdata_Backup_Cfg = DB_Equipstand + ".tb_devdata_backup_cfg";			//独立设备-FTP文件备份信息表
+	//--------------------------------------------------------------------------------------------//
+	public final static String Tb_DevData_historyTable = DB_Equip_History + ".tb_devdata_history_";			//独立设备-历史实时数据记录表
+	public final static String Tb_DevAlarm_Data = DB_Equip_Alarm + ".tb_devalarm_data_";					//独立设备-实时告警数据记录表
+	public final static String Tb_DevAlarm_Data_History = DB_Equip_Alarm + ".tb_devalarm_data_history_";	//独立设备-历史告警数据记录表
+	//--------------------------------------------------------------------------------------------//
+	public final static String Tb_Dynamicload_inf = DB_DynamicSystem + ".tb_dynamicload_inf";				//设备信息表
+	public final static String Tb_Dynamicload_State_rt = DB_DynamicSystem + ".tb_dynamicload_state_rt";		//设备状态表
+	public final static String Tb_Dynamicload_Button_Rt = DB_DynamicSystem +".tb_dynamicload_button_rt";	//按钮反馈表
+	public final static String Tb_Dynamicload_Control = DB_DynamicSystem + ".tb_dynamicload_control";		//电源柜控制表
+	//--------------------------------------------------------------------------------------------//
+	public final static String Tb_Motor_inf = DB_Elemachinery + ".tb_motor_inf";							//电机信息表
+	public final static String Tb_Motor_control = DB_Elemachinery + ".tb_motor_control";					//电机控制表
+	public final static String Tb_Load_Motor_state = DB_Elemachinery + ".tb_load_motor_state";				//加载电机状态表
+	public final static String Tb_Subject_Motor_state = DB_Elemachinery + ".tb_subject_motor_state";		//受试电机状态表
+	public final static String Tb_Devalarm_Rt = DB_Elemachinery + ".tb_devalaram_rt";						//电机实时告警记录表
+	public final static String Tb_Devalarm_History = DB_Elemachinery + ".tb_devalaram_history";				//电机历史告警记录表
+	public final static String Tb_Motor_Readdata = DB_Motor_Realhistory + ".tb_motor_readdata_";			//电机历史实时记录表
+	
+	//--------------------------------------------------------------------------------------------//
+	/***			电源控制相关表										*****/
+	public final static String Tb_Electric_Control_Single = DB_ElectricSystem + ".tb_electric_control_single";		//电源单点控制表
+	public final static String Tb_Electric_Power = DB_ElectricSystem + ".tb_electric_power";						//电源控制状态表
+	public final static String Tb_Electric_Rt = DB_ElectricSystem + ".tb_electric_rt";								
+	public final static String Tb_Electric_State = DB_ElectricSystem + ".tb_electric_state";									
+	public final static String Tb_Electric_Switch = DB_ElectricSystem + ".tb_electric_switch";
+	
+	//-----------------------------------------------------------------------------------------------//
+	/*             水冷系统相关表                                                                                                  */
+	public final static String Tb_water_inf = DB_Watersystem + ".tb_water_inf";		//水冷系统信息
+	public final static String Tb_water_rt = DB_Watersystem + ".tb_water_rt";		//水冷系统实时数据
+	public final static String Tb_water_brach = DB_Watersystem + ".tb_water_brach"; //水冷系统分支实时数据					
+	public final static String Tb_water_state = DB_Watersystem + ".tb_water_state";	//水冷系统实时状态								
+	
+	//--------------------------------------------------------------------------------------------//
+	public Connection mysql_con;
+	
+	public Sql_Mysql(Connection conn)
+	{
+		mysql_con = conn;
+	}
+	
+	/*
+	public static Connection getConnection() throws SQLException, java.lang.ClassNotFoundException{
+		String url = "jdbc:mysql://192.168.48.128:3306/studentinfo";
+		Class.forName("com.mysql.jdbc.Driver");
+		String userName = "root";
+		String password = "lmx8688139";
+		Connection con = DriverManager.getConnection(url,userName,password);
+		return con;
+	}
+	*/
+	
+	public void close_con()
+	{
+		try {
+			mysql_con.close();
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+	}
+	
+	public void checkAndCreateDB() throws SQLException
+	{
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_AppSys);
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_BATT_INF);
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_BATT_TESTDATA);
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_PARAM);
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_ALARM);
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_USER);
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_RamDB);
+		
+		sqlMysqlExecute("DROP DATABASE IF EXISTS " + DB_RamDB_BATT_RT);
+		//sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + DB_RamDB_BATT_RT);
+		
+		sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + WEB_Site);
+		
+		String table_0 = "CREATE TABLE IF NOT EXISTS " + AppSys_Table
+						+ " ( `num` INT NOT NULL AUTO_INCREMENT,"
+						+ "`SqlDB_Version` FLOAT NOT NULL DEFAULT '1.0',"
+						+ "`SqlDB_BackUpTime` DATETIME NOT NULL DEFAULT '2000-1-1 00:00:00',"
+						+ "`SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`AppServer_Version` FLOAT NOT NULL DEFAULT '1.0',"
+						+ "`AppClient_Version` FLOAT NOT NULL DEFAULT '1.0',"
+						+ "`AppName` VARCHAR(50) NOT NULL DEFAULT '0',"
+						+ " PRIMARY KEY (`num`)) "
+						+ " ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_1 = "CREATE TABLE IF NOT EXISTS " + BattInf_Table
+						+ " ( `num` INT NOT NULL AUTO_INCREMENT,"
+						+ "`StationId` VARCHAR(20) NOT NULL 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 NOT NULL DEFAULT '0',"
+						+ "`FBSDeviceIp` VARCHAR(50) NOT NULL DEFAULT '192.168.0.88',"
+						+ "`FBSDeviceName` VARCHAR(100) NOT NULL DEFAULT '0',"
+						+ "`GroupIndexInFBSDevice` INT NOT NULL DEFAULT '0',"
+						+ "`BattModel` VARCHAR(100) NOT NULL DEFAULT ' ',"
+						+ "`BattGroupId` INT NOT NULL DEFAULT '0',"
+						+ "`BattGroupNum` INT 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 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 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 NOT NULL DEFAULT '1095',"
+						+ "`SignalId` VARCHAR(20) NOT NULL DEFAULT '0',"
+						+ "`CInterFaceId` INT NOT NULL DEFAULT '0',"
+						+ "`SignalName` VARCHAR(50) NOT NULL DEFAULT '0',"
+						+ "INDEX index_station_id (`StationId`), "
+						+ "INDEX index_battgroup_id (`BattGroupId`), "
+						+ "INDEX index_station_name (`StationName`), "
+						+ "INDEX index_battgroup_name (`BattGroupName`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_2 = "CREATE TABLE IF NOT EXISTS " + BattCurrInf_Table
+						+ " ( `num` INT 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;";
+		
+		String table_3 = "CREATE TABLE IF NOT EXISTS " + BattMainInf_Table
+						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
+						+ "`usr_id` INT NOT NULL DEFAULT 0, "
+						+ "`fault_type_id` INT NOT NULL DEFAULT 0, "
+						+ "`fault_type` VARCHAR(50) NOT NULL DEFAULT ' ', "
+						+ "`fault_level` INT NOT NULL DEFAULT 0, "
+						+ "`fault_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "`fault_time` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
+						+ "`record_uid` INT NOT NULL DEFAULT 0, "
+						+ "`record_time` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
+						+ "`maint_time_limit` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
+						+ "`maint_type_id` INT NOT NULL DEFAULT 0, "
+						+ "`maint_type` VARCHAR(50) NOT NULL DEFAULT ' ', "
+						+ "`maint_result` VARCHAR(100) NOT NULL DEFAULT ' ', "
+						+ "`maint_done` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`maint_done_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
+						+ "`maint_close` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`master_id` INT NOT NULL DEFAULT 0, "
+						+ "`master_audit` INT NOT NULL DEFAULT 0, "				//领导审核
+						+ "`appoint_uid` INT NOT NULL DEFAULT 0, " 				//指派给谁
+						+ "`copy_uids` VARCHAR(200) NOT NULL DEFAULT ' ', "		//抄送给谁
+						+ "`master_check` VARCHAR(100) NOT NULL DEFAULT ' ', "
+						+ "`remark` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "INDEX index_battgroup_id (`BattGroupId`), "
+						+ "INDEX index_user_id (`usr_id`), "
+						+ "INDEX index_fault_type_id (`fault_type_id`), "
+						+ "INDEX index_maint_type_id (`maint_type_id`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_3_1 = "CREATE TABLE IF NOT EXISTS " + BattMainProcess_Table
+						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`batt_maint_rec_id` BIGINT NOT NULL DEFAULT 0, "
+						+ "`usr_id` INT NOT NULL DEFAULT 0, "
+						+ "`work_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "`work_caption_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
+						+ "INDEX index_batt_maint_rec_id (`batt_maint_rec_id`), "
+						+ " PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_3_2 = "CREATE TABLE IF NOT EXISTS " + UsrBattMaintCheck_Table
+						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`StationId` INT NOT NULL DEFAULT 0, "
+						+ "`usr_id` INT NOT NULL DEFAULT 0, "
+						+ "`master_id` INT NOT NULL DEFAULT 0, "
+						+ "`appoint_uid` INT NOT NULL DEFAULT 0, " 				//指派给谁
+						+ "`copy_uids` VARCHAR(200) NOT NULL DEFAULT ' ', "		//抄送给谁
+						+ "`task_type_id` INT NOT NULL DEFAULT 0, "
+						+ "`task_level` INT NOT NULL DEFAULT 0, "
+						+ "`task_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "`task_time_start` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
+						+ "`task_time_end` DATETIME NOT NULL DEFAULT '2005-1-1 00:00:00', "
+						+ "`task_process` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "`task_done` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`task_done_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
+						+ "`origin_usr_work_mark` INT NOT NULL DEFAULT 0, "
+						+ "`task_done_confirm` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`master_audit` INT NOT NULL DEFAULT 0, "				//领导审核
+						+ "`remark` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "INDEX index_station_id (`StationId`), "
+						+ "INDEX index_user_id (`usr_id`), "
+						+ "INDEX index_task_type_id (`task_type_id`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_3_2_1 = "CREATE TABLE IF NOT EXISTS " + UsrBattMaintCheckProcess_Table
+						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`task_rec_id` BIGINT NOT NULL DEFAULT 0, "
+						+ "`usr_id` INT NOT NULL DEFAULT 0, "
+						+ "`work_caption` VARCHAR(200) NOT NULL DEFAULT ' ', "
+						+ "`work_caption_time` DATETIME DEFAULT '2005-1-1 00:00:00', "
+						+ "INDEX index_task_rec_id (`task_rec_id`), "
+						+ " PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_4 = "CREATE TABLE IF NOT EXISTS " + BattTestDataInf_Table
+						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
+						+ "`test_record_count` INT NOT NULL DEFAULT 0, "
+						+ "`test_record_count_ex` INT NOT NULL DEFAULT 0, "
+						+ "`test_type` INT NOT NULL DEFAULT 0, "
+						+ "`record_time_interval` INT NOT NULL DEFAULT 0, "
+						+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`record_num` INT NOT NULL DEFAULT 0, "
+						+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
+						+ "`test_starttime_ex` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
+						+ "`test_starttype` INT NOT NULL DEFAULT 0, "
+						+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
+						+ "`test_timelong` INT NOT NULL DEFAULT 0, "
+						+ "`test_stoptype` INT NOT NULL DEFAULT 0, "
+						+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
+						+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
+						+ "`test_cap` FLOAT NOT NULL DEFAULT 0, "
+						+ "`max_monnum` INT NOT NULL DEFAULT 0, "
+						+ "`max_monvol` FLOAT NOT NULL DEFAULT 0, "
+						+ "`min_monnum` INT NOT NULL DEFAULT 0, "
+						+ "`min_monvol` FLOAT NOT NULL DEFAULT 0, "
+						+ "`mon_num` INT NOT NULL DEFAULT 0, "
+						+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
+						+ "`upload_usr_id` INT NOT NULL DEFAULT 0, "
+						+ "`upload_data_ext` INT NOT NULL DEFAULT 0, "
+						+ "`upload_client_type` INT NOT NULL DEFAULT 0, "
+						+ "INDEX index_battgroup_id (`BattGroupId`), "
+						+ "INDEX index_test_record_count (`test_record_count`), "
+						+ "INDEX index_test_type (`test_type`), "
+						+ "INDEX index_test_starttime (`test_starttime`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_5 = "CREATE TABLE IF NOT EXISTS " + BattResDataInf_Table
+						+ " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
+						+ "`test_record_count` INT NOT NULL DEFAULT 0, "
+						+ "`test_record_count_ex` INT NOT NULL DEFAULT 0, "
+						+ "`test_type` INT NOT NULL DEFAULT 0, "
+						+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
+						+ "`test_starttime_ex` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
+						+ "`test_devtype` INT NOT NULL DEFAULT 0, "
+						+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
+						+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
+						+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
+						+ "`upload_usr_id` INT NOT NULL DEFAULT 0, "
+						+ "`upload_client_type` INT NOT NULL DEFAULT 0, "
+						+ "INDEX index_battgroup_id (`BattGroupId`), "
+						+ "INDEX index_test_record_count (`test_record_count`), "
+						+ "INDEX index_test_starttime (`test_starttime`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		
+		String table_6 = "DROP TABLE IF EXISTS " + SocketClientStateTable + "; ";
+		String table_7 = "CREATE TABLE IF NOT EXISTS " + SocketClientStateTable
+						+ "(`num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`uId` INT NOT NULL DEFAULT 0, "
+						+ "`client_type` INT NOT NULL DEFAULT 0, "
+						+ "`client_id` BIGINT NOT NULL DEFAULT 0, "
+						+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
+						+ "`client_is_connected` BOOLEAN NOT NULL DEFAULT false, "
+						+ "`client_ip` VARCHAR(64) NOT NULL DEFAULT ' ', "
+						+ "`client_conn_time` DATETIME NOT NULL DEFAULT '1980-01-01', "
+						+ "`client_disconn_time` DATETIME NOT NULL DEFAULT '1980-01-01', "
+						+ "INDEX index_user_id (`uId`), "
+						+ "INDEX index_client_type (`client_type`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=MEMORY DEFAULT CHARSET=utf8;";
+		
+		String table_8 = "CREATE TABLE IF NOT EXISTS " + FBSDevStateChangeInf_Table
+						+ "(`num` BIGINT NOT NULL AUTO_INCREMENT, "
+						+ "`dev_id` INT NOT NULL DEFAULT 0, "
+						+ "`rec_time` DATETIME NOT NULL DEFAULT '1980-01-01', "
+						+ "`last_stat` INT NOT NULL DEFAULT 0, "
+						+ "`now_stat` INT NOT NULL DEFAULT 0, "
+						+ "`state_change_reason` INT NOT NULL DEFAULT 0, "
+						+ "`dev_alarm` INT NOT NULL DEFAULT 0, "
+						+ "INDEX index_dev_id (`dev_id`), "
+						+ "PRIMARY KEY (`num`)) "
+						+ "ENGINE=InnoDB DEFAULT CHARSET=utf8;";
+		//-------------------------------------------------------------------------------------//
+		//-------------------------------------------------------------------------------------//
+		sqlMysqlUseDB(Sql_Mysql.DB_AppSys);
+		if(false == sqlMysqlCheckIfTableExist(TB_AppSys))
+		{
+			sqlMysqlExecute(table_0);
+			sqlMysqlExecute("INSERT INTO " + Sql_Mysql.AppSys_Table 
+								+ " (AppName) VALUES ('蓄电池组综合管理系统')");
+		}
+		//-------------------------------------------------------------------------------------//
+		{
+			ResultSet rest = sqlMysqlQuery("SELECT AppServer_Version FROM " + Sql_Mysql.AppSys_Table);
+			if(rest.next()) {
+				float ser_version = rest.getFloat(1);
+				if(ser_version < 1.387) {
+					sqlMysqlExecute("UPDATE " + Sql_Mysql.AppSys_Table + " SET AppServer_Version=1.388");
+					sqlMysqlExecute("USE db_batt_testdata");
+					sqlMysqlExecute("UPDATE tb_batttestdata_inf SET "
+									+ " test_starttime=date_sub(test_starttime, interval 1 month) "
+									+ " WHERE upload_usr_id>0");
+				}
+			}
+		}
+		//---------------------------------------------------------------------------------------------//
+		ResultSet res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns"
+								+ " WHERE table_schema='db_app_sys'"
+								+ " AND table_name='tb_app_sys'"
+								+ " AND column_name='SqlDB_BackUpTime'");
+		if(false == res0.next()) {
+			sqlMysqlExecute("ALTER TABLE " + AppSys_Table 
+							+ " ADD COLUMN `SqlDB_BackUpTime` DATETIME NOT NULL DEFAULT '2000-1-1 00:00:00'"
+							+ " AFTER `SqlDB_Version`,"
+							+ " ADD COLUMN `SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false"
+							+ " AFTER `SqlDB_BackUpTime`");
+		}
+		res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns"
+							+ " WHERE table_schema='db_app_sys'"
+							+ " AND table_name='tb_app_sys'"
+							+ " AND column_name='SqlDB_BackUpManual_EN'");
+		if(false == res0.next()) {
+			sqlMysqlExecute("ALTER TABLE " + AppSys_Table 
+							+ " ADD COLUMN `SqlDB_BackUpManual_EN` BOOLEAN NOT NULL DEFAULT false"
+							+ " AFTER `SqlDB_BackUpTime`");
+		}
+		//---------------------------------------------------------------------------------------------//
+		
+		sqlMysqlExecute(table_1);
+		sqlMysqlExecute(table_2);
+		sqlMysqlExecute(table_3);
+		sqlMysqlExecute(table_3_1);
+		sqlMysqlExecute(table_3_2);
+		sqlMysqlExecute(table_3_2_1);
+		sqlMysqlExecute(table_4);
+		sqlMysqlExecute(table_5);
+		sqlMysqlExecute(table_6);
+		sqlMysqlExecute(table_7);
+		sqlMysqlExecute(table_8);
+		
+		//---------------------------------------------------------------------------------------------//
+		ResultSet res = sqlMysqlQuery("show index from " + BattInf_Table + " where column_name='BattGroupId'");
+		if(false == res.next())
+		{
+			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_station_id` (`StationId` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_battgroup_id` (`BattGroupId` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_station_name` (`StationName` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD INDEX `index_battgroup_name` (`BattGroupName` ASC);");
+		}
+		//---------------------------------------------------------------------------------------------//
+		//-------------------------------- 2017-06-06 by mxpopstar ------------------------------------//
+				res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
+										+ " WHERE table_schema='db_battinf'"
+										+ " AND table_name='tb_battinf'"
+										+ " AND column_name='BattGuarantDayCount'");
+				if(false == res.next()) {
+					sqlMysqlExecute("ALTER TABLE " + BattInf_Table 
+									+ " ADD COLUMN `BattGuarantDayCount` INT NOT NULL DEFAULT 1095 AFTER `BattInUseDate`");
+				}
+				//---------------------------------------------------------------------------------------------//
+		//---------------------------------------------------------------------------------------------//
+		res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
+								+ " WHERE table_schema='db_battinf'"
+								+ " AND table_name='tb_batt_maint_inf'"
+								+ " AND column_name='master_audit'");
+		if(false == res.next()) {
+			sqlMysqlExecute("ALTER TABLE " + BattMainInf_Table 
+							+ " ADD COLUMN `fault_type_id` INT NOT NULL DEFAULT 0 AFTER `usr_id`,"
+							+ " ADD COLUMN `maint_type_id` INT NOT NULL DEFAULT 0 AFTER `maint_time_limit`,"
+							+ " ADD COLUMN `master_audit` INT NOT NULL DEFAULT 0 AFTER `master_id`,"
+							+ " ADD COLUMN `maint_close` BOOLEAN NOT NULL DEFAULT FALSE AFTER `maint_done_time`,"
+							+ " ADD COLUMN `appoint_uid` INT NOT NULL DEFAULT 0 AFTER `master_audit`,"
+							+ " ADD COLUMN `copy_uids` VARCHAR(200) NOT NULL DEFAULT ' ' AFTER `master_audit`");
+		}
+		//---------------------------------------------------------------------------------------------//
+		//---------------------------------------------------------------------------------------------//
+		res = sqlMysqlQuery("show index from " + BattTestDataInf_Table + " where column_name='test_starttime'");
+		if(false == res.next())
+		{
+			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " ADD INDEX `index_test_record_count` (`test_record_count` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " ADD INDEX `index_test_type` (`test_type` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " ADD INDEX `index_test_starttime` (`test_starttime` ASC);");
+		}
+		//---------------------------------------------------------------------------------------------//
+		//---------------------------------------------------------------------------------------------//
+		res = sqlMysqlQuery("show index from " + BattResDataInf_Table + " where column_name='test_starttime'");
+		if(false == res.next())
+		{
+			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " ADD INDEX `index_test_record_count` (`test_record_count` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " ADD INDEX `index_test_type` (`test_type` ASC);");
+			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " ADD INDEX `index_test_starttime` (`test_starttime` ASC);");
+		}
+		//---------------------------------------------------------------------------------------------//
+		res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
+										+ " WHERE table_schema='db_batt_testdata'"
+										+ " AND table_name='tb_batttestdata_inf'"
+										+ " AND column_name='test_record_count_ex'");
+		if(false == res.next())
+		{
+			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table
+							+ " ADD COLUMN `test_record_count_ex` INT NOT NULL DEFAULT 0 AFTER `test_record_count`,"
+							+ " ADD COLUMN `test_starttime_ex` DATETIME NOT NULL DEFAULT '1920-01-01 00:00:00' AFTER `test_starttime`,"
+							+ " ADD COLUMN `upload_usr_id` INT NOT NULL DEFAULT 0 AFTER `mon_vol`");
+		}
+		//---------------------------------------------------------------------------------------------//
+		//---------------------------------------------------------------------------------------------//
+		res = sqlMysqlQuery("SELECT * FROM information_schema.columns"
+												+ " WHERE table_schema='db_batt_testdata'"
+												+ " AND table_name='tb_batttestdata_inf'"
+												+ " AND column_name='upload_data_ext'");
+		if(false == res.next())
+		{
+			sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table
+							+ " ADD COLUMN `upload_data_ext` INT NOT NULL DEFAULT 0 AFTER `upload_usr_id`,"
+							+ " ADD COLUMN `upload_client_type` INT NOT NULL DEFAULT 0 AFTER `upload_data_ext`");
+			sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table
+							+ " ADD COLUMN `upload_client_type` INT NOT NULL DEFAULT 0 AFTER `upload_usr_id`");
+		}
+		//---------------------------------------------------------------------------------------------//
+		//----------------------------将num自增字段改为bigint类型---------------------------------------//
+		res = sqlMysqlQuery("SELECT DATA_TYPE FROM information_schema.columns"
+										+ " WHERE table_schema='db_batt_testdata'"
+										+ " AND table_name='tb_batttestdata_inf'"
+										+ " AND column_name='num'");
+		if(true == res.next()) {
+			if(false == "bigint".equals(res.getString("DATA_TYPE").toLowerCase())) {
+				sqlMysqlExecute("ALTER TABLE " + BattTestDataInf_Table + " MODIFY COLUMN num BIGINT NOT NULL AUTO_INCREMENT;");
+				sqlMysqlExecute("ALTER TABLE " + BattResDataInf_Table + " MODIFY COLUMN num BIGINT NOT NULL AUTO_INCREMENT;");
+			}
+		}
+		//---------------------------------------------------------------------------------------------//
+	}
+	
+	//使用db数据库
+	public void sqlMysqlUseDB(String db) throws SQLException
+	{
+		sqlMysqlExecute("use " + db);
+	}
+	
+	//获取电池组机房的个数
+	public int getBattStationCount()
+	{
+		int st_count = 0;
+		
+		try {
+			sqlMysqlUseDB(Sql_Mysql.DB_BATT_INF);
+			
+			String sql_str = "SELECT DISTINCT StationId FROM " + BattInf_Table;
+			ResultSet res = sqlMysqlQuery(sql_str);
+			while(res.next())
+			{
+				st_count++;
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		
+		return st_count;
+	}
+	
+	/**
+	 * 检查tb表是否存在
+	 * @param tb
+	 * @return
+	 * @throws SQLException
+	 */
+	public boolean sqlMysqlCheckIfTableExist(String tb) throws SQLException
+	{
+		String sql_str = "SHOW TABLES LIKE '" + tb + "'";
+		ResultSet res = sqlMysqlQuery(sql_str);
+		boolean exist = false;
+		while(res.next())
+		{
+			exist = true;
+			break;
+		}
+		
+		return exist;
+	}
+	
+	//执行sql语句
+	public void sqlMysqlExecute(String sql_str) throws SQLException
+	{
+		Statement sql = mysql_con.createStatement();
+		sql.setQueryTimeout(30);
+		sql.execute(sql_str);
+	}
+	
+	
+	//在事物中执行多条sql语句
+	public boolean makeManualCommit(ArrayList<String> al_sql_strs) 
+	{
+		boolean exe_res = true;
+		try {
+			mysql_con.setAutoCommit(false);
+			
+			for(int n=0; n<al_sql_strs.size(); n++) {
+				sqlMysqlExecute(al_sql_strs.get(n));
+			}
+			
+			if(true == exe_res) {
+				mysql_con.commit();
+			}
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			exe_res = false;
+		} finally {
+			try {
+				if(false == exe_res) {
+					mysql_con.rollback();
+				}
+				mysql_con.setAutoCommit(true);
+			} catch (SQLException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+			}
+		}
+		
+		return exe_res;
+	}
+	
+	//根据sql语句执行sql查询语句
+	public ResultSet sqlMysqlQuery(String sql_str)
+	{
+		ResultSet res = null;
+		try
+    	{
+			Statement sql = mysql_con.createStatement();
+			sql.setQueryTimeout(30);
+			String query = sql_str;
+			res =  sql.executeQuery(query);
+    	}
+    	catch(SQLException ex)
+		{
+			System.err.println("SQLException:" + ex.getMessage());
+		}
+		
+		return res;
+	}
+	
+	//根据sql语句执行sql更新语句
+	public void sqlMysqlUpdate(String sql_str)
+	{
+		try
+    	{
+			Statement sql = mysql_con.createStatement();
+			sql.setQueryTimeout(30);
+			String query = sql_str;
+			sql.execute(query);
+    	}
+    	catch(SQLException ex)
+		{
+			System.out.println("SQLException:" + ex.getMessage());
+		}
+	}
+	
+	//根据电池组id 获取机房名称
+	public String getStationName(int bg_id)
+	{
+		String stname = " ";
+		
+		String sql_str = "SELECT DISTINCT StationName FROM " 
+							+ Sql_Mysql.BattInf_Table + " WHERE BattGroupId=" + bg_id;
+		ResultSet res = sqlMysqlQuery(sql_str);
+		try {
+			if(res.next())
+			{
+				stname = res.getString("StationName");
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		
+		return stname;
+	}
+	
+	//根据电池组id 获取电池组名称
+	public String getBattGroupName(int bg_id)
+	{
+		String bgname = " ";
+		
+		String sql_str = "SELECT DISTINCT BattGroupName FROM " 
+							+ Sql_Mysql.BattInf_Table + " WHERE BattGroupId=" + bg_id;
+		ResultSet res = sqlMysqlQuery(sql_str);
+		try {
+			if(res.next())
+			{
+				bgname = res.getString("BattGroupName");
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		
+		return bgname;
+	}
+	
+	//根据用户的id获取用户的名称
+	public String getUsrName(int uid)
+	{
+		String usrname = " ";
+		
+		String sql_str = "SELECT uName FROM " + Sql_Mysql.UserInfTable + " WHERE uId=" + uid;
+		ResultSet res = sqlMysqlQuery(sql_str);
+		try {
+			if(res.next())
+			{
+				usrname = res.getString("uName");
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		
+		return usrname;
+	}
+	
+	//根据format_type 获取format_str 的样式
+	public String getTaskSmsFormatStr(String format_type)
+	{
+		String str = "";
+		String sql_str = "SELECT DISTINCT " 
+						+ Sql_Mysql.UserSmsFormatTable + ".format_str"
+						+ " FROM " + Sql_Mysql.UserSmsFormatTable
+						+ " WHERE " 
+						+ Sql_Mysql.UserSmsFormatTable + ".format_type='" + format_type + "'";
+		
+		ResultSet sql_res = sqlMysqlQuery(sql_str);
+		try {
+			if(sql_res.next())
+			{
+				str = sql_res.getString("format_str");
+			}
+		} catch (SQLException e1) {
+			// TODO Auto-generated catch block
+			//e1.printStackTrace();
+		}
+		
+		return str;
+	}
+	
+	//根据作业id获取作业的名称
+	public String getUsrTaskName(int taskid)
+	{
+		String taskname = " ";
+		
+		String sql_str = "SELECT task_name FROM " + Sql_Mysql.UserTaskTable + " WHERE task_id=" + taskid;
+		ResultSet res = sqlMysqlQuery(sql_str);
+		try {
+			if(res.next()) {
+				taskname = res.getString("task_name");
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		
+		return taskname;
+	}
+	
+	//根据作业id获取用户作业的创建时间
+	public String getUsrTaskCreateTime(int taskid)
+	{
+		String taskcreatetime = " ";
+		
+		String sql_str = "SELECT task_create_date FROM " + Sql_Mysql.UserTaskTable + " WHERE task_id=" + taskid;
+		ResultSet res = sqlMysqlQuery(sql_str);
+		try {
+			if(res.next())
+			{
+				taskcreatetime = Com.getDateTimeFormat(res.getTimestamp("task_create_date"), Com.DTF_YMDhms);
+			}
+		} catch (SQLException e) {
+			e.printStackTrace();
+		}
+		
+		return taskcreatetime;
+	}
+	
+	
+	//获取新创建的记录的testrecordcount的值
+	public int getBattTestRecordCountNew(int bg_id, String table)
+	{
+		int count = 0;
+		boolean res_exe = true;
+		String sql_str0 = "SELECT test_record_count_ex FROM " + table 
+							+ " WHERE BattGroupId=" + bg_id  + " FOR UPDATE";
+		String sql_str1 = "UPDATE " + table + " SET test_record_count_ex=test_record_count+1"
+							+ " WHERE BattGroupId=" + bg_id;
+		String sql_str2 = "SELECT MAX(test_record_count_ex) FROM " + table 
+							+ " WHERE BattGroupId=" + bg_id;
+		String sql_str3 = "INSERT INTO " + table + " (BattGroupId,test_record_count, test_record_count_ex) "
+							+ " VALUES (" + bg_id + "," + 1 + "," + 1 + ")";
+		try {
+			mysql_con.setAutoCommit(false);
+			ResultSet res = sqlMysqlQuery(sql_str0);
+			if(res.next()) {
+				sqlMysqlExecute(sql_str1);
+				res = sqlMysqlQuery(sql_str2);
+				if(res.next()) {
+					count = res.getInt(1);
+				}
+			} else {
+				count = 1;
+				sqlMysqlExecute(sql_str3);
+			}
+			
+			mysql_con.commit();
+		} catch (SQLException e) {
+			e.printStackTrace();
+			res_exe = false;
+		} finally {
+			if(false == res_exe) {
+				try {
+					mysql_con.rollback();
+					mysql_con.setAutoCommit(true);
+				} catch (SQLException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+		}
+		
+		return count;
+	}
+}

--
Gitblit v1.9.1