水冷系统提交

whyclxw

2020-08-20 0a6d2dd97665ee556b48a185b5a9291dcf2a5c77

 WaterSystem_MonitorServer/src/com/sql/Sql_Mysql.java

@@ -1,905 +1,915 @@
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 final static String Tb_water_alarm = DB_Watersystem + ".tb_water_alarm";   //水冷系统告警							
	
   //--------------------------------------------------------------------------------------------//
   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;
   }
}