在tb_battinf表中 添加 负载电流字段: LoaderCurr 最大核容电流：DisCurrMax 字段

LiJun

2018-10-12 098480a1ac42ccdc65bc1995a834850233390d78

在tb_battinf表中 添加
负载电流字段: LoaderCurr
最大核容电流：DisCurrMax
字段

 BattMonitor_DB_Builder/bin/com/sql/Sql_Mysql.class

Binary files differ

 BattMonitor_DB_Builder/config.xml

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="gbk"?>

<root>
  <mysql_ramdb_recreate_en>true</mysql_ramdb_recreate_en>
  <mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
  <mysql_server_ip>127.0.0.1</mysql_server_ip>
  <!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
  <!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->

 BattMonitor_DB_Builder/src/com/sql/Sql_Mysql.java

@@ -1,840 +1,862 @@
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`";
    //--------------------------------------------------------------------------------------------//
    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_BattRtState = "tb_batt_rtstate";
    public final static String TB_BattRtData = "tb_server_state";
	
    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 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 BTSStationState_Table = DB_RamDB + ".`tb_bts_station_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 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_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 WEB_Site = "`web_site`";

    //--------------------------------------------------------------------------------------------//

    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_BattRtState = "tb_batt_rtstate";

    public final static String TB_BattRtData = "tb_server_state";

	
    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 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 BTSStationState_Table = DB_RamDB + ".`tb_bts_station_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 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_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`");

                        }

                //---------------------------------------------------------------------------------------------//

                //-------------------------------- 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");

                        }

				
                //---------------------------------------------------------------------------------------------//

						
						
        //---------------------------------------------------------------------------------------------//

        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;

    }

}