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 WEB_Site = "`web_site`"; final public static String DB_BATT_HISTORY = "`db_batt_history`"; final public static String DB_LD9_TESTDATA = "`db_ld9_testdata`"; final public static String DB_PWRDEV_ALARM = "`db_pwrdev_alarm`"; final public static String DB_PWRDEV_DATA_RT = "`db_pwrdev_data_rt`"; final public static String DB_PWRDEV_INF = "`db_pwrdev_inf`"; //--------------------------------------------------------------------------------------------// 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_ServerState = "tb_server_state"; public final static String TB_BattTestDataInf = "tb_batttestdata_inf"; public final static String TB_BattRtData = "tb_batt_rtdata"; public final static String TB_BattRtState = "tb_batt_rtstate"; 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 CInterfaceState_Table = DB_RamDB + ".`tb_cinterface_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 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 BattResDataInf_Table = DB_BATT_TESTDATA + ".`tb_battresdata_inf`"; public final static String BattResData_Table = DB_BATT_TESTDATA + ".`tb_BattResData`"; 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 BTSStationEvent_Table = DB_ALARM + ".`tb_bts_station_event`"; //»ú·¿×´Ì¬ÀúÊ·±í /**************************** db_ram_dbÊý¾Ý¿â ***************************************************/ public final static String SocketClientStateTable = DB_RamDB + ".`tb_socketclient_state`"; public final static String ServerState_Table = DB_RamDB + ".`tb_server_state`"; public final static String Ld9_Updatestatue_Table = DB_RamDB + ".`tb_ld9_updatestatue`"; 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 Ld9_Concentratestate_Table = DB_RamDB + ".`tb_ld9_concentratestate`"; public final static String Ld9_Concentrateparam_Table = DB_RamDB + ".`tb_ld9_concentrateparam`"; public final static String HardDevSmsState_Table = DB_RamDB + ".`tb_hard_dev_sms_state`"; public final static String FBS9600State_Table = DB_RamDB + ".`tb_fbs9600_state`"; public final static String FBS9100_NiBian_State = DB_RamDB + ".tb_fbs9100s_nibian_state"; //61850ÀëÏßÑø»¤¼Æ»®²ÎÊý±í public final static String FBS9100s_fod_state = DB_RamDB + ".tb_fbs9100s_fod_state"; //61850³ýÁò״̬±í public final static String FBS9100SetDLParam_Table = DB_RamDB + ".`tb_fbs9100s_fod_param`"; //61850³ýÁò²ÎÊý±í public final static String FBS9100S_DFUState_Table = DB_RamDB + ".`tb_fbs9100s_DFU_state`"; public final static String FBS9100S_DcDcState_Table = DB_RamDB + ".`tb_fbs9100s_dcdc_state`"; public final static String FBS9100SysParam_Table = DB_RamDB + ".`tb_fbs9100_sysparam`"; //ϵͳ²ÎÊý±í public final static String FBS9100State_Table = DB_RamDB + ".`tb_fbs9100_state`"; public final static String FBS9100SetParam_Table = DB_RamDB + ".`tb_fbs9100_setparam`"; public final static String FBS9100_offlineyhplan = DB_RamDB + ".tb_fbs9100_offlineyhplan"; //61850ÀëÏßÑø»¤¼Æ»®²ÎÊý±í public final static String FBS9100BattParam_Table = DB_RamDB + ".`tb_fbs9100_battparam`"; //µç³Ø×é²ÎÊý±í public final static String BTSStationState_Table = DB_RamDB + ".`tb_bts_station_state`"; //»ú·¿×´Ì¬±í public final static String BTSGPRSState_Table = DB_RamDB + ".`tb_bts_gprs_state`"; //gprs ÐÅÏ¢±í public final static String BMP7100State_Table = DB_RamDB + ".`tb_bpm7100_state`"; public final static String BattRtState_Table = DB_RamDB + ".`tb_batt_rtstate`"; public final static String BattRtData_Table = DB_RamDB + ".`tb_batt_rtdata`"; public final static String TB_61850_JHState_Table = DB_RamDB +".tb_61850_jhstate"; //61850¾ùºâ61850¹©µçÄ£¿éÐÅÏ¢ public final static String RamDB_CMCC_POWER_Data = DB_RamDB + ".`cmcc_power_data`"; public final static String FBS9100_InsulatstateTable = DB_RamDB + ".`tb_fbs9100_insulatstate`"; //¾øÔµ×°Öà public final static String FBS9100_CollectionstateTable = DB_RamDB + ".`tb_fbs9100_collectionstate`"; //»ã¼¯×°Öà public final static String FBS9100_ChargerstateTable = DB_RamDB + ".`tb_fbs9100_chargerstate`"; //³äµç»ú public final static String Tb_Lithium_DataTable = DB_RamDB + ".`tb_lithium_data`"; //ï®µç³ØÊý¾Ý±í public final static String Tb_Batt_RSAlarm_Table = DB_RamDB + ".`tb_batt_rsalarm`"; //ï®µç³ØÊý¾Ý±í public final static String Tb_Batt_RTAlarm_Table = DB_RamDB + ".`tb_batt_rtalarm`"; //ï®µç³ØÊý¾Ý±í public final static String FBS9100s_stemnode_state_Table = DB_RamDB + ".`tb_fbs9100s_stemnode_state`"; //¸É½Úµã״̬±í public final static String FBS9100s_buscouple_state_Table = DB_RamDB + ".`tb_fbs9100s_buscouple_state`"; //ĸÁª¿ª¹Ø×´Ì¬±í /**************************** db_userÊý¾Ý¿â ***************************************************/ public final static String User_Permitgroup_Table = DB_USER + ".`tb_user_permitgroup`"; //ȨÏÞ±í public final static String User_Permitgroup_Data_Table = DB_USER + ".`tb_user_permitgroup_data`"; //Óû§È¨ÏÞ±í public final static String User_Task_User_List_Table = DB_USER + ".`tb_user_task_user_list`"; // public final static String User_Task_Template_Table = DB_USER + ".`tb_user_task_template`"; // public final static String User_Task_Param_Table = DB_USER + ".`tb_user_task_param`"; // public final static String User_Task_Change_Table = DB_USER + ".`tb_user_task_change`"; // public final static String User_Task_Batt_Test_Table = DB_USER + ".`tb_user_task_batt_test`"; // public final static String User_Task_Batt_Template_Table = DB_USER + ".`tb_user_task_batt_template`"; // public final static String User_Task_Batt_Check_Table = DB_USER + ".`tb_user_task_batt_check`"; // public final static String User_Task_Table = DB_USER + ".`tb_user_task`"; // public final static String User_Sms_Format_Table = DB_USER + ".`tb_user_sms_format`"; // public final static String User_Sms_Table = DB_USER + ".`tb_user_sms`"; // public final static String User_Paixiu_Table = DB_USER + ".`tb_user_paixiu`"; // public final static String User_Log_Table = DB_USER + ".`tb_user_log`"; // public final static String User_Jiejiari_Table = DB_USER + ".`tb_user_jiejiari`"; // public final static String User_Face_Table = DB_USER + ".`tb_user_face`"; // public final static String User_Battmaint_Check_Process_Table = DB_USER + ".`tb_user_battmaint_check_process`"; // public final static String User_Battmaint_Check_Table = DB_USER + ".`tb_user_battmaint_check`"; // public final static String User_Battgroup_Baojigroup_Usr_Table = DB_USER + ".`tb_user_battgroup_baojigroup_usr`"; // public final static String User_Battgroup_Baojigroup_Battgroup_Table = DB_USER + ".`tb_user_battgroup_baojigroup_battgroup`"; // public final static String User_Battgroup_Baojigroup_Table = DB_USER + ".`tb_user_battgroup_baojigroup`"; // public final static String User_Limit_Table = DB_USER + ".`tb_user_limit`"; // /**************************** web_siteÊý¾Ý¿â ***************************************************/ public final static String ThreadUtil_Table = WEB_Site + ".`tb_thread_util`"; //Ḭ̈߳ïÖú±í public final static String PositiomapUsr_Table = WEB_Site + ".`tb_positiomap_usr`"; //Ê×Ò³µØÍ¼ÖÐÐĵ㶨λ±í public final static String ChartColor_Table = WEB_Site + ".`tb_chart_color`"; //Óû§ÊµÊ±¼à²âÒ³ÃæÖ¸¶¨Öù×´µÄÑÕÉ«ÉèÖñí public final static String UserChart_Table = WEB_Site + ".`tb_user_chart`"; //°à×é¹ÜÀí±í public final static String ProcessSurvey_Table = WEB_Site + ".`tb_process_survey`"; //Ïß³Ì¼à¿Ø±í public final static String EchartsUsr_Table = WEB_Site + ".`tb_echarts_usr`"; //Óû§Ê×Ò³¶¨ÖƱí public final static String DevstateUsr_Table = WEB_Site + ".`tb_devstate_usr`"; //Óû§·ÅµçÌí¼Ó¼Ç¼±í public final static String CustomPage_Table = WEB_Site + ".`tb_custompage`"; //µ¼º½Êý¾Ý±í public final static String Announce_Table = WEB_Site + ".`tb_announce`"; //¹«¸æ±í public final static String BattAttention_Table = WEB_Site + ".`tb_batt_attention`"; //´´½¨µç³Ø×éµ¥Ì幨ע±í public final static String BattpowerOff_Table = WEB_Site + ".`tb_battpower_off`"; //»ú·¿Í£µç±í public final static String BadbattMon_Table = WEB_Site + ".`tb_badbatt_mon`"; //Âäºóµ¥Ìå±í public final static String BadbattMonFlag_Table = WEB_Site + ".`tb_badbatt_mon_flag`"; //Âäºóµ¥Ìå¿ØÖÆ±í public final static String BattEndurance_Table = WEB_Site + ".`tb_batt_endurance`"; //»ú·¿Ðøº½±í public final static String BattParamLow_Table = WEB_Site + ".`tb_batt_param_low`"; //µç³Ø²ÎÊý±í public final static String BattDischargeParam_Table = WEB_Site + ".`tb_battdischarge_param`"; //·Åµç¼Æ»®²ÎÊý±í public final static String BattDischargePlan_Table = WEB_Site + ".`tb_battdischarge_plan`"; //·Åµç¼Æ»®±í public final static String Avoid_plan_Table = WEB_Site + ".`tb_avoid_plan`"; //·Åµç¼Æ»®¹æ±Üʱ¼ä±í public final static String BattMapInformation_Table = WEB_Site + ".`tb_battmap_information`"; //»ùÕ¾¶¨Î»±í public final static String BattDischarge_Table = WEB_Site + ".`tb_batt_discharge`"; //»ùÕ¾¹ÊÕϱí public final static String BattReplace_Table = WEB_Site + ".`tb_batt_replace`"; //µç³Ø¸ü»»¼Ç¼±í public final static String Dev_Restart_Plan_Table = WEB_Site +".`tb_dev_restart_plan`"; //É豸¶¨ÆÚÖØÆô¼Æ»®±í public final static String Vip_User_Table = WEB_Site +".`tb_vip_user`"; //³¬¼¶Óû§±í public final static String License_Table = WEB_Site +".`tb_license`"; //³¬¼¶Óû§±í /***************************** db_battinfÊý¾Ý¿â ***************************************/ public final static String DeverrorRecord_Table = DB_BATT_INF + ".`tb_deverror_record`"; //»ú·¿ÎÊÌâ¼Ç¼±í public final static String BattinfApply_TABLE = DB_BATT_INF + ".`tb_battinf_apply`"; //»ú·¿°²×°ÉóÅú±í public final static String BattinfEx_TABLE = DB_BATT_INF + ".`tb_battinf_ex`"; //»ùÕ¾ÐÅÏ¢±í public final static String BattinfRebuild_TABLE = DB_BATT_INF + ".`tb_battinf_rebuild`"; //»ú·¿Åä×é±í public final static String BattmonTestcap_TABLE = DB_BATT_INF + ".`tb_battmon_testcap`"; //»ú·¿±ê×¼²âÊÔÇúÏ߼Ǽ±í public final static String Battcurr_Inf_TABLE = DB_BATT_INF + ".`tb_battcurr_inf`"; public final static String Batt_Maint_Process_TABLE = DB_BATT_INF + ".`tb_batt_maint_process`"; public final static String Batt_Maint_Inf_TABLE = DB_BATT_INF + ".`tb_batt_maint_inf`"; public final static String Batt_Alm_Param_TABLE = DB_BATT_INF + ".`tb_batt_alm_param`"; /***************************** db_alarmÊý¾Ý¿â ***************************************/ public final static String Devalarm_Data_Table = DB_ALARM + ".`tb_devalarm_data`"; public final static String Devalarm_Data__History_Table = DB_ALARM + ".`tb_devalarm_data_history`"; public final static String Bts_Station_Event_Table = DB_ALARM + ".`tb_bts_station_event`"; public final static String Battalarm_Data_Table = DB_ALARM + ".`tb_battalarm_data`"; public final static String Battalarm_Data_History_Table = DB_ALARM + ".`tb_battalarm_data_history`"; /***************************** db_app_sys Êý¾Ý¿â ***************************************/ public final static String Page_Param_Table = DB_AppSys + ".`tb_page_param`"; public final static String Fbsdev_Statechange_Inf_Table = DB_AppSys + ".`tb_fbsdev_statechange_inf`"; public final static String Dashboard_Module_Chart_Table = DB_AppSys + ".`tb_dashboard_module_chart`"; public final static String Dashboard_Module_Table = DB_AppSys + ".`tb_dashboard_module`"; public final static String Dashboard_Chart_Type_Table = DB_AppSys + ".`tb_dashboard_chart_type`"; public final static String App_Sys_Table = DB_AppSys + ".`tb_app_sys`"; public final static String App_Bts_Comm_Task_Table = DB_AppSys + ".`tb_app_bts_comm_task`"; public final static String App_Bts_Battgroup_Table = DB_AppSys + ".`tb_app_bts_battgroup`"; public final static String Menu_Table = DB_AppSys + ".`tb_menu`"; /***************************** db_ld9_testdata Êý¾Ý¿â ***************************************/ public final static String Ld9testdata_Inf_Table = DB_LD9_TESTDATA + ".`tb_ld9testdata_inf`"; /***************************** db_param Êý¾Ý¿â ***************************************/ public final static String Dev_Param_Table = DB_PARAM + ".`tb_dev_param`"; public final static String App_Param_Table = DB_PARAM + ".`tb_app_param`"; public final static String Alarm_Param_Table = DB_PARAM + ".`tb_alarm_param`"; /***************************** db_pwrdev_alarm Êý¾Ý¿â ************************************/ public final static String Pwrdev_Alarm_Table = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm`"; public final static String Pwrdev_Alarm_History_Table = DB_PWRDEV_ALARM + ".`tb_pwrdev_alarm_history`"; /***************************** db_pwrdev_data_rt Êý¾Ý¿â ************************************/ public final static String Pwrdev_Acdcdata_Table = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_acdcdata`"; public final static String Pwrdev_Dcdata_Table = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_dcdata`"; public final static String Pwrdev_Acdata_Table = DB_PWRDEV_DATA_RT + ".`tb_pwrdev_acdata`"; /***************************** db_pwrdev_inf Êý¾Ý¿â ************************************/ public final static String Pwrdev_Inf_Table = DB_PWRDEV_INF + ".`tb_pwrdev_inf`"; public final static String Pwrapp_Sys_Table = DB_PWRDEV_INF + ".`tb_pwrapp_sys`"; public final static String Display_Config_Table = DB_PWRDEV_INF + ".`tb_display_config`"; public final static String Pwrapp_Stainf_Table = DB_PWRDEV_INF + ".`tb_pwrapp_stainf`"; public final static String Pwrapp_Dcinf_Table = DB_PWRDEV_INF + ".`tb_pwrapp_dcinf`"; public final static String Pwrapp_Acinf_Table = DB_PWRDEV_INF + ".`tb_pwrapp_acinf`"; public final static String Pwrapp_Acdcinf_Table = DB_PWRDEV_INF + ".`tb_pwrapp_acdcinf`"; //--------------------------------------------------------------------------------------------// //--------------------------------------------------------------------------------------------// 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_Reinit_BattGroupData_EN` BOOLEAN NOT NULL DEFAULT false, " + "`AppServer_Reinit_BattGroupData_LD9_EN` BOOLEAN NOT NULL DEFAULT false, " //ÓÃÓÚ9¶È³ÌÐòÖØÐ¼ÓÔØÉ豸 + "`AppServer_Reinit_Config_EN` BOOLEAN NOT NULL DEFAULT false, " + "`AppServer_Version` FLOAT NOT NULL DEFAULT '1.0'," + "`AppClient_Version` FLOAT NOT NULL DEFAULT '1.0'," + "`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;"; String table_9 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.BTSStationEvent_Table + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, " + "`station_id` BIGINT NOT NULL DEFAULT 0, " + "`dev_id` BIGINT NOT NULL DEFAULT 0, " + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', " + "`station_event_type` INT NOT NULL DEFAULT 0, " + "`station_event_trig` INT NOT NULL DEFAULT 0, " + " INDEX index_dev_id (`dev_id`), " + " INDEX index_station_id (`station_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`"); } /**************************** db_app_sys ±íÖÐÌí¼Ó AppServer_Reinit_BattGroupData_ENÁÐ(ÖØÐÂÔØÈëµç³Ø×éÐÅÏ¢) *******************************************/ res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_app_sys'" + " AND table_name='tb_app_sys'" + " AND column_name='AppServer_Reinit_BattGroupData_EN'"); if(false == res0.next()) { sqlMysqlExecute("ALTER TABLE " + AppSys_Table + " ADD COLUMN `AppServer_Reinit_BattGroupData_EN` BOOLEAN NOT NULL DEFAULT false" + " AFTER `SqlDB_BackUpManual_EN`"); } /**************************** db_app_sys ±íÖÐÌí¼Ó AppServer_Reinit_BattGroupData_EN ÁÐ(ÓÃÓÚÖ÷³ÌÐò¶¯Ì¬µ÷ÕûÔËÐвÎÊý) *******************************************/ res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_app_sys'" + " AND table_name='tb_app_sys'" + " AND column_name='AppServer_Reinit_Config_EN'"); if(false == res0.next()) { sqlMysqlExecute("ALTER TABLE " + AppSys_Table + " ADD COLUMN `AppServer_Reinit_Config_EN` BOOLEAN NOT NULL DEFAULT false" + " AFTER `AppServer_Reinit_BattGroupData_EN`"); } /**************************** db_app_sys ±íÖÐÌí¼Ó AppServer_Reinit_BattGroupData_LD9_EN ÁÐ(ÓÃÓÚLD9Ö÷³ÌÐò¶¯Ì¬¼ÓÔØÉ豸²ÎÊý) *******************************************/ res0 = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_app_sys'" + " AND table_name='tb_app_sys'" + " AND column_name='AppServer_Reinit_BattGroupData_LD9_EN'"); if(false == res0.next()) { sqlMysqlExecute("ALTER TABLE " + AppSys_Table + " ADD COLUMN `AppServer_Reinit_BattGroupData_LD9_EN` BOOLEAN NOT NULL DEFAULT false" + " AFTER `AppServer_Reinit_BattGroupData_EN`"); } //---------------------------------------------------------------------------------------------// sqlMysqlExecute(table_1); 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); sqlMysqlExecute(table_9); //---------------------------------------------------------------------------------------------// 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`"); } //---------------------------------------------------------------------------------------------// //-------------------------------- 2018-10-12 by lijun ( binf±íÖÐÌí¼Ó Load_curr->¸ºÔصçÁ÷ disCurrMax -> ×î´óºËÈݵçÁ÷ )------------------------------------// res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='Load_curr'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `Load_curr` float NOT NULL DEFAULT 15"); } res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='disCurrMax'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `disCurrMax` float NOT NULL DEFAULT 0"); } //-------------------------------- 2018-10-16 by lijun ( binf±íÖÐÌí¼Ó station_phone->»ùÕ¾ÊÖ»úºÅ )------------------------------------// res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='station_phone'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `station_phone` varchar(32) DEFAULT ''"); } //---------------------------------------------------------------------------------------------// //-------------------------------- 2018-10-16 by lijun ( binf±íÖÐÌí¼Ó station_install->±êʶ»ú·¿ÊÇ·ñÒѾ­°²×° )------------------------------------// res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='station_install'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `station_install` BOOLEAN NOT NULL DEFAULT false"); } //---------------------------------------------------------------------------------------------// //-------------------------------- 2018-11-29 by lijun ( binf±íÖÐÌí¼Ó StationId_ex->»ùÕ¾Õ¾Ö·±àºÅ install_user-->°²×°ÈË)------------------------------------// res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='StationId_ex'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `StationId_ex` varchar(20) DEFAULT '' AFTER StationId"); } res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='install_user'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `install_user` varchar(64) DEFAULT ''"); } //---------------------------------------------------------------------------------------------// //-------------------------------- 2018-12-12 by lijun ( binf±íÖÐÌí¼Ó charge_curr_max ×î´ó³äµçµçÁ÷)------------------------------------// res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='charge_curr_max'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `charge_curr_max` float DEFAULT '20'"); } //---------------------------------------------------------------------------------------------// //Ϊ×Ͼ§ÄÏÍøÆ½Ì¨Ìí¼ÓÖ¸¶¨µÄÁÐ boolean isZijing = true; if(isZijing) { //Ìí¼ÓµçѹµÈ¼¶ÁÐ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='Vol_grade'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `Vol_grade` float DEFAULT '0'"); } //Éú²ú³§¼Ò res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='Manufacturers'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `Manufacturers` varchar(64) DEFAULT ''"); } //ÊÇ·ñ×ʲú¼¶É豸 res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='Assetequipment'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `Assetequipment` varchar(64) DEFAULT ''"); } //É豸·ÖÀàȫ·¾¶ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='Deviceclasspath'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `Deviceclasspath` varchar(64) DEFAULT ''"); } //É豸ÔËά²¿ÃÅ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='Deviceoperationdepartment'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `DeviceOperationDepartment` varchar(64) DEFAULT ''"); } //²úȨµ¥Î» res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='PropertyRightUnit'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `PropertyRightUnit` varchar(64) DEFAULT ''"); } //²úȨÊôÐÔ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='PropertyAttribute'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `PropertyAttribute` varchar(64) DEFAULT ''"); } //³ö³§±àºÅ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='FactoryNumber'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `FactoryNumber` varchar(64) DEFAULT ''"); } //ÔËά°à×é res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='OperationTeam'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `OperationTeam` varchar(64) DEFAULT ''"); } //É豸Éí·Ý±àÂë res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='DeviceIdentityCode'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `DeviceIdentityCode` varchar(64) DEFAULT ''"); } //ÏîÄ¿ÀàÐÍ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='ProjectType'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `ProjectType` varchar(64) DEFAULT ''"); } //Ðîµç³ØÓ¦ÓÃÀàÐÍ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='BatteryApplicationType'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `BatteryApplicationType` varchar(64) DEFAULT ''"); } //µ¥µç³Ø¶î¶¨µçѹ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='SingleRatedVoltage'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `SingleRatedVoltage` float DEFAULT '0'"); } //ÊÇ·ñʵÏÖÔ¶³Ì¼à¿Ø res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='RemoteMonitor'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `RemoteMonitor` varchar(64) DEFAULT ''"); } //ÊÇ·ñ¶ÀÁ¢Ðîµç³ØÊÒ·ÅÖà res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='BatttIndependentPlaced'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `BatttIndependentPlaced` varchar(64) DEFAULT ''"); } //¾ù³äµçѹÉ趨ֵ res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='JunChargeVoltageValue'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `JunChargeVoltageValue` float DEFAULT '0'"); } //¹«Ô¿X res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='PublicKeyX'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `PublicKeyX` varchar(200) NOT NULL DEFAULT ''"); } //¹«Ô¿Y res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='PublicKeyY'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `PublicKeyY` varchar(200) NOT NULL DEFAULT ''"); } //KeyID res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='KeyID'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `KeyID` varchar(200) NOT NULL DEFAULT ''"); } //ΨһË÷Òý res = sqlMysqlQuery("SELECT * FROM information_schema.columns" + " WHERE table_schema='db_battinf'" + " AND table_name='tb_battinf'" + " AND column_name='SerialNumber'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + BattInf_Table + " ADD COLUMN `SerialNumber` varchar(200) NOT NULL DEFAULT ''"); } } //---------------------------------------------------------------------------------------------// 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;"); } } //---------------------------------------------------------------------------------------------// //----------------------------- tb_fbsdev_statechange_inf ±íÖÐÐÂÔö2¸ö×Ö¶Î ----------------------------------------------------------------// res = sqlMysqlQuery("SELECT DATA_TYPE FROM information_schema.columns" + " WHERE table_schema='db_app_sys'" + " AND table_name='tb_fbsdev_statechange_inf'" + " AND column_name='eve_type'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + FBSDevStateChangeInf_Table + " ADD COLUMN `eve_type` int DEFAULT 0;"); } res = sqlMysqlQuery("SELECT DATA_TYPE FROM information_schema.columns" + " WHERE table_schema='db_app_sys'" + " AND table_name='tb_fbsdev_statechange_inf'" + " AND column_name='module_num'"); if(false == res.next()) { sqlMysqlExecute("ALTER TABLE " + FBSDevStateChangeInf_Table + " ADD COLUMN `module_num` int DEFAULT 0;"); } } //ʹÓÃ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 al_sql_strs) { boolean exe_res = true; try { mysql_con.setAutoCommit(false); for(int n=0; n