在9100_setParam建表语句中添加LD6设备新添加的列名

军

2018-09-26 c1f19ba51d6bec6312584da4619dc43b3c81b997

在9100_setParam建表语句中添加LD6设备新添加的列名

 BattMonitor_DB_Builder/bin/.gitignore

@@ -1 +1 @@
/main/
/com/

 BattMonitor_DB_Builder/bin/com/dev/fbs9100/FBS9100_Task_Thread_SQL.class

Binary files differ

 BattMonitor_DB_Builder/src/com/dev/fbs9100/FBS9100_Task_Thread_SQL.java

@@ -1,196 +1,197 @@
package com.dev.fbs9100;

import java.sql.SQLException;

import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;

public class FBS9100_Task_Thread_SQL {
	
    /**
     * 创建 tb_fbs9100_state 表并且将设备id和设备ip插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100State_Table;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100State_Table
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
                    + "`dev_version` varchar(20) NOT NULL DEFAULT '0', "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`op_cmd` INT NOT NULL DEFAULT 0, "
                    + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
                    + "`dev_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "
                    + "`dev_testtype` INT NOT NULL DEFAULT 0, "
                    + "`dev_testgroupnum` INT NOT NULL DEFAULT 0, "
                    + "`dev_workstate` INT NOT NULL DEFAULT 0, "
                    + "`dev_alarmstate` INT NOT NULL DEFAULT 0, "
                    + "`dev_temp` float NOT NULL DEFAULT 0, "
                    + "`dev_res_test_state` INT NOT NULL DEFAULT 0, "        //内阻测试状态
                    + "`dev_onlinevollow` BOOLEAN NOT NULL DEFAULT false, "
                    + "`dev_eachgroup_battsum` INT NOT NULL DEFAULT 0, "
                    + "`dev_captest_onlinevol` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_groupvol` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_curr` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_cap` float NOT NULL DEFAULT 0, "
                    + "`dev_captest_timelong` INT NOT NULL DEFAULT 0, "
                    + "`dev_restest_count` INT NOT NULL DEFAULT 0, "
                    + "`dev_restest_moncount` INT NOT NULL DEFAULT 0, "
                    + "`dev_restest_monindex` INT NOT NULL DEFAULT 0, "
                    + "`dev_commcount` INT NOT NULL DEFAULT 0, "
                    + "`dev_errcommcount` INT NOT NULL DEFAULT 0, "
                    + "`dev_rxnullerrcount` INT NOT NULL DEFAULT 0, "
					
                    + "`dev_last_captest_stop_type` INT NOT NULL DEFAULT 0, "
                    + "`dev_concurr`  float NOT NULL DEFAULT 0, "
                    + "`dev_condvoldp`  float NOT NULL DEFAULT 0, "
                    + "`dev_conresist`  float NOT NULL DEFAULT 0, "
                    + "`dev_condcurr`  float NOT NULL DEFAULT 0, "
                    + "`dev_61850alarms`  varchar(64) NOT NULL DEFAULT '', "
					
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
        /*
        String str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table + " (dev_ip, dev_id) ";
        str3 += " SELECT dev_ip, dev_id FROM " + Sql_Mysql.BattInf_Table;
        */
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
            //sql.sqlMysqlExecute(str3);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     * 创建 tb_fbs9100s_dcdc_data 表并且将设备id和设备ip插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100S_DCDC_DataTableOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`dcdc_num` BIGINT NOT NULL DEFAULT 0, "
                    + "`dcdc_Vsys` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Vout` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Vbat` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Iout` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Ibuck` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Tmp_Dis` float NOT NULL DEFAULT 0, "
                    + "`dcdc_Tmp_Chr` float NOT NULL DEFAULT 0, "
                    + "`dcdc_SMR_Alarm1` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_SMR_Alarm2` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_version` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_ModeSetComm` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_RunSetComm` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_BuckISet` float NOT NULL DEFAULT 0, "
                    + "`dcdc_DisVolSet` float NOT NULL DEFAULT 0, "
                    + "`dcdc_DisCurrSet` float NOT NULL DEFAULT 0, "
                    + "`dcdc_CommTxCnt` INT NOT NULL DEFAULT 0, "
                    + "`dcdc_CommRxCnt` INT NOT NULL DEFAULT 0, "
                    + " UNIQUE INDEX index_dcdc_num_uniq (`dcdc_num`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     * 创建 tb_fbs9100_setparam 表，并且将设备id和设备ip插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SetParam_Table;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SetParam_Table
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`op_cmd` INT NOT NULL DEFAULT 0, "
                    + "`TestCmd` INT NOT NULL DEFAULT 0, "
                    + "`HourRate` INT NOT NULL DEFAULT 0, "
                    + "`DisCurr` FLOAT NOT NULL DEFAULT 0, "
                    + "`DisCap` FLOAT NOT NULL DEFAULT 0, "
                    + "`DisTime` INT NOT NULL DEFAULT 0, "
                    + "`GroupVol_LOW` FLOAT NOT NULL DEFAULT 0, "
                    + "`MonomerVol_LOW` FLOAT NOT NULL DEFAULT 0, "
                    + "`MonomerLowCount` INT NOT NULL DEFAULT 0, "
                    + "`BattGroupNum` INT NOT NULL DEFAULT 0, "
                    + "`OnlineVolLowAction` INT NOT NULL DEFAULT 0, "
                    + "`DCVolHighLimit` FLOAT NOT NULL DEFAULT 0, "
                    + "`ChargeCurrSet` FLOAT NOT NULL DEFAULT 0, "
                    + "`MonomerTmp_High` FLOAT NOT NULL DEFAULT 0, "
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";
		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
	
    /**
     * 创建 Sql_Mysql.RamDB_CMCC_POWER_Data 表并且将设备id插入到表中
     * @param con_pool
     * @param al_param
     */
    public static void createFBS9100CmccPowerDataOnRam(MysqlConnPool con_pool)
    {
        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data;
        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data
                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "
                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "
                    + "`vol1` float NOT NULL DEFAULT 0, "
                    + "`vol2` float NOT NULL DEFAULT 0, "
                    + "`vol3` float NOT NULL DEFAULT 0, "
                    + "`vol4` float NOT NULL DEFAULT 0, "
                    + "`vol5` float NOT NULL DEFAULT 0, "
                    + "`curr1` float NOT NULL DEFAULT 0, "
                    + "`curr2` float NOT NULL DEFAULT 0, "
                    + "`curr3` float NOT NULL DEFAULT 0, "
                    + "`curr4` float NOT NULL DEFAULT 0, "
                    + "`curr5` float NOT NULL DEFAULT 0, "
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "
                    + " PRIMARY KEY (`num`) ) "
                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";
		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());
        try {
            sql.sqlMysqlExecute(str1);
            sql.sqlMysqlExecute(str2);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
    /***********************************************************************************/
}
package com.dev.fbs9100;



import java.sql.SQLException;



import com.sql.MysqlConnPool;

import com.sql.Sql_Mysql;



public class FBS9100_Task_Thread_SQL {

	
    /**

     * 创建 tb_fbs9100_state 表并且将设备id和设备hip插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100StateTableOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100State_Table;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100State_Table

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "

                    + "`dev_version` varchar(20) NOT NULL DEFAULT '0', "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`op_cmd` INT NOT NULL DEFAULT 0, "

                    + "`record_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "

                    + "`dev_datetime` varchar(20) NOT NULL DEFAULT '2015-12-02 12:10:00', "

                    + "`dev_testtype` INT NOT NULL DEFAULT 0, "

                    + "`dev_testgroupnum` INT NOT NULL DEFAULT 0, "

                    + "`dev_workstate` INT NOT NULL DEFAULT 0, "

                    + "`dev_alarmstate` INT NOT NULL DEFAULT 0, "

                    + "`dev_temp` float NOT NULL DEFAULT 0, "

                    + "`dev_res_test_state` INT NOT NULL DEFAULT 0, "        //内阻测试状态

                    + "`dev_onlinevollow` BOOLEAN NOT NULL DEFAULT false, "

                    + "`dev_eachgroup_battsum` INT NOT NULL DEFAULT 0, "

                    + "`dev_captest_onlinevol` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_groupvol` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_curr` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_cap` float NOT NULL DEFAULT 0, "

                    + "`dev_captest_timelong` INT NOT NULL DEFAULT 0, "

                    + "`dev_restest_count` INT NOT NULL DEFAULT 0, "

                    + "`dev_restest_moncount` INT NOT NULL DEFAULT 0, "

                    + "`dev_restest_monindex` INT NOT NULL DEFAULT 0, "

                    + "`dev_commcount` INT NOT NULL DEFAULT 0, "

                    + "`dev_errcommcount` INT NOT NULL DEFAULT 0, "

                    + "`dev_rxnullerrcount` INT NOT NULL DEFAULT 0, "

					
                    + "`dev_last_captest_stop_type` INT NOT NULL DEFAULT 0, "

                    + "`dev_concurr`  float NOT NULL DEFAULT 0, "

                    + "`dev_condvoldp`  float NOT NULL DEFAULT 0, "

                    + "`dev_conresist`  float NOT NULL DEFAULT 0, "

                    + "`dev_condcurr`  float NOT NULL DEFAULT 0, "

                    + "`dev_61850alarms`  varchar(64) NOT NULL DEFAULT '', "					
					
                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";

        /*

        String str3 = "INSERT INTO " + Sql_Mysql.FBS9100State_Table + " (dev_ip, dev_id) ";

        str3 += " SELECT dev_ip, dev_id FROM " + Sql_Mysql.BattInf_Table;

        */

        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

            //sql.sqlMysqlExecute(str3);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     * 创建 tb_fbs9100s_dcdc_data 表并且将设备id和设备ip插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100S_DCDC_DataTableOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100S_DcDcState_Table

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`dcdc_num` BIGINT NOT NULL DEFAULT 0, "

                    + "`dcdc_Vsys` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Vout` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Vbat` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Iout` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Ibuck` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Tmp_Dis` float NOT NULL DEFAULT 0, "

                    + "`dcdc_Tmp_Chr` float NOT NULL DEFAULT 0, "

                    + "`dcdc_SMR_Alarm1` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_SMR_Alarm2` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_version` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_ModeSetComm` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_RunSetComm` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_BuckISet` float NOT NULL DEFAULT 0, "

                    + "`dcdc_DisVolSet` float NOT NULL DEFAULT 0, "

                    + "`dcdc_DisCurrSet` float NOT NULL DEFAULT 0, "

                    + "`dcdc_CommTxCnt` INT NOT NULL DEFAULT 0, "

                    + "`dcdc_CommRxCnt` INT NOT NULL DEFAULT 0, "

                    + " UNIQUE INDEX index_dcdc_num_uniq (`dcdc_num`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";

		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     * 创建 tb_fbs9100_setparam 表，并且将设备id和设备ip插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100SetTestParamTableOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.FBS9100SetParam_Table;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.FBS9100SetParam_Table

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_ip` varchar(20) NOT NULL DEFAULT '127.0.0.0', "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`op_cmd` INT NOT NULL DEFAULT 0, "

                    + "`TestCmd` INT NOT NULL DEFAULT 0, "

                    + "`HourRate` INT NOT NULL DEFAULT 0, "

                    + "`DisCurr` FLOAT NOT NULL DEFAULT 0, "

                    + "`DisCap` FLOAT NOT NULL DEFAULT 0, "

                    + "`DisTime` INT NOT NULL DEFAULT 0, "

                    + "`GroupVol_LOW` FLOAT NOT NULL DEFAULT 0, "

                    + "`MonomerVol_LOW` FLOAT NOT NULL DEFAULT 0, "

                    + "`MonomerLowCount` INT NOT NULL DEFAULT 0, "

                    + "`BattGroupNum` INT NOT NULL DEFAULT 0, "

                    + "`OnlineVolLowAction` INT NOT NULL DEFAULT 0, "

                    + "`DCVolHighLimit` FLOAT NOT NULL DEFAULT 0, "

                    + "`ChargeCurrSet` FLOAT NOT NULL DEFAULT 0, "

                    + "`MonomerTmp_High` FLOAT NOT NULL DEFAULT 0, "

                    + "`AutoTestStartVol`  float NOT NULL DEFAULT 0, "            //起始电压

                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=MEMORY DEFAULT CHARSET=utf8";

		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

	
    /**

     * 创建 Sql_Mysql.RamDB_CMCC_POWER_Data 表并且将设备id插入到表中

     * @param con_pool

     * @param al_param

     */

    public static void createFBS9100CmccPowerDataOnRam(MysqlConnPool con_pool)

    {

        String str1 = "DROP TABLE IF EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data;

        String str2 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.RamDB_CMCC_POWER_Data

                    + " ( `num` BIGINT NOT NULL AUTO_INCREMENT, "

                    + "`dev_id` BIGINT NOT NULL DEFAULT 0, "

                    + "`vol1` float NOT NULL DEFAULT 0, "

                    + "`vol2` float NOT NULL DEFAULT 0, "

                    + "`vol3` float NOT NULL DEFAULT 0, "

                    + "`vol4` float NOT NULL DEFAULT 0, "

                    + "`vol5` float NOT NULL DEFAULT 0, "

                    + "`curr1` float NOT NULL DEFAULT 0, "

                    + "`curr2` float NOT NULL DEFAULT 0, "

                    + "`curr3` float NOT NULL DEFAULT 0, "

                    + "`curr4` float NOT NULL DEFAULT 0, "

                    + "`curr5` float NOT NULL DEFAULT 0, "

                    + " UNIQUE INDEX index_dev_id_uniq (`dev_id`), "

                    + " PRIMARY KEY (`num`) ) "

                    + " ENGINE=InnoDB DEFAULT CHARSET=utf8";

		
        Sql_Mysql sql = new Sql_Mysql(con_pool.getConn());

        try {

            sql.sqlMysqlExecute(str1);

            sql.sqlMysqlExecute(str2);

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } finally {

            sql.close_con();

        }

    }

    /***********************************************************************************/

}


 BattMonitor_DB_Builder/src/main/main_BTS_DB_Builder.java

@@ -1,105 +1,105 @@
package main;
import java.sql.SQLException;
import java.util.Date;

import com.base.Com;
import com.battdata_rt.BattData_RT_RamDB_Thread_SQL;
import com.config.AppConfig;
import com.dev.fbs9100.FBS9100S_DFU_SQL;
import com.dev.fbs9100.FBS9100_Task_Thread_SQL;
import com.sql.MysqlConnPool;
import com.sql.Sql_Mysql;

public class main_BTS_DB_Builder {
    /**************************************************************************/
    /**************************************************************************/
    public final static boolean app_debug = false;
    public final static float m_VersionNum = (float) 1.001;
    public final static String m_Version = "Welcome To Use BTS DB BUILDER V" + m_VersionNum + " RC_20180908";
    /**************************************************************************/
    /**************************************************************************/
    public static final int DEF_MysqlServerFBS_Port = 3360;
    public static int MysqlServer_Port = DEF_MysqlServerFBS_Port;
	
    private static AppConfig m_AppConfig;
	
    private static MysqlConnPool GB_MysqlConnPool;
    /*********************************************************************************************/
    /*********************************************************************************************/
    public static void main(String[] args) {
        /*//BasicConfigurator.configure();*/
        String ver = m_Version;
        System.out.println("/****************************************************************");
        System.out.println("*****************************************************************");
        System.out.println("****************************************************************/");
        System.out.println(ver);
        System.out.println("App Started At DateTime: " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
		
        m_AppConfig = new AppConfig();
		
        System.out.println("正在连接数据库 DBserver IP：" + m_AppConfig.getMysqlServerIp() + ", port: " + MysqlServer_Port);
		
        GB_MysqlConnPool = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), MysqlServer_Port, 5);
		
        Sql_Mysql sql_ck = new Sql_Mysql(GB_MysqlConnPool.getConn());
        if(null != sql_ck.mysql_con) {
            System.out.println("成功连接数据库" 
                                + " DBserver IP：" + m_AppConfig.getMysqlServerIp() 
                                + ", port: " + MysqlServer_Port 
                                + " @ " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
        }
        try {
            sql_ck.checkAndCreateDB();
        } catch (SQLException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        } finally {
            sql_ck.close_con();
        }
        /*********************************************************************************/
        boolean recreate_tb = m_AppConfig.getMysqlDB_RecreateEn();
        //创建tb_batt_rtstate表格并且将电池组id的值
        BattData_RT_RamDB_Thread_SQL.createBattState_RT_RamDB_Table(GB_MysqlConnPool, recreate_tb);
        //创建tb_batt_rtdata表格并且将电池组id的值
        BattData_RT_RamDB_Thread_SQL.createBattData_RT_RamDB_Table(GB_MysqlConnPool, recreate_tb);
        //创建tb_server_state表并且设置表中的值
        BattData_RT_RamDB_Thread_SQL.createServerState_RamDB_Table(GB_MysqlConnPool, recreate_tb);
        /*********************************************************************************/
        System.out.println("Recreate RamDB Tables State Is '" + recreate_tb + "'");
        if(true == recreate_tb) {
            //创建tb_fbs9100s_state表
            FBS9100_Task_Thread_SQL.createFBS9100StateTableOnRam(GB_MysqlConnPool);
            //创建tb_fbs9100s_dcdc_data表
            FBS9100_Task_Thread_SQL.createFBS9100S_DCDC_DataTableOnRam(GB_MysqlConnPool);
            //创建tb_fbs9100s_setparam表
            FBS9100_Task_Thread_SQL.createFBS9100SetTestParamTableOnRam(GB_MysqlConnPool);
            //创建CmccPowerData表
            FBS9100_Task_Thread_SQL.createFBS9100CmccPowerDataOnRam(GB_MysqlConnPool);
            //创建tb_fbs9100S_DFU_StateTable表并向表中添加数据
            FBS9100S_DFU_SQL.createFBS9100S_DFU_TableOnRam(GB_MysqlConnPool);
        }
		
        if(true == m_AppConfig.getMysqlDB_RecreateEn()) {
            m_AppConfig.setMysqlDB_RecreateEn(false);
            m_AppConfig.writeConfigToXml();
        }
		
        System.out.println("BTS DB BUILDER Work Done @ " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
		
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
		
        /*
        while(true) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        */
    }
}
package main;

import java.sql.SQLException;

import java.util.Date;



import com.base.Com;

import com.battdata_rt.BattData_RT_RamDB_Thread_SQL;

import com.config.AppConfig;

import com.dev.fbs9100.FBS9100S_DFU_SQL;

import com.dev.fbs9100.FBS9100_Task_Thread_SQL;

import com.sql.MysqlConnPool;

import com.sql.Sql_Mysql;



public class main_BTS_DB_Builder {

    /**************************************************************************/

    /**************************************************************************/

    public final static boolean app_debug = false;

    public final static float m_VersionNum = (float) 1.001;

    public final static String m_Version = "Welcome To Use BTS DB BUILDER V" + m_VersionNum + " RC_20180908";

    /**************************************************************************/

    /**************************************************************************/

    public static final int DEF_MysqlServerFBS_Port = 3360;

    public static int MysqlServer_Port = DEF_MysqlServerFBS_Port;

	
    private static AppConfig m_AppConfig;

	
    private static MysqlConnPool GB_MysqlConnPool;

    /*********************************************************************************************/

    /*********************************************************************************************/

    public static void main(String[] args) {

        /*//BasicConfigurator.configure();*/

        String ver = m_Version;

        System.out.println("/****************************************************************");

        System.out.println("*****************************************************************");

        System.out.println("****************************************************************/");

        System.out.println(ver);

        System.out.println("App Started At DateTime: " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));

		
        m_AppConfig = new AppConfig();

		
        System.out.println("正在连接数据库 DBserver IP：" + m_AppConfig.getMysqlServerIp() + ", port: " + MysqlServer_Port);

		
        GB_MysqlConnPool = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), MysqlServer_Port, 5);

		
        Sql_Mysql sql_ck = new Sql_Mysql(GB_MysqlConnPool.getConn());

        if(null != sql_ck.mysql_con) {

            System.out.println("成功连接数据库" 
                                + " DBserver IP：" + m_AppConfig.getMysqlServerIp() 
                                + ", port: " + MysqlServer_Port 
                                + " @ " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));

        }

        try {

            sql_ck.checkAndCreateDB();

        } catch (SQLException e1) {

            // TODO Auto-generated catch block

            e1.printStackTrace();

        } finally {

            sql_ck.close_con();

        }

        /*********************************************************************************/

        boolean recreate_tb = m_AppConfig.getMysqlDB_RecreateEn();

        //创建tb_batt_rtstate表格并且将电池组id的值

        BattData_RT_RamDB_Thread_SQL.createBattState_RT_RamDB_Table(GB_MysqlConnPool, recreate_tb);

        //创建tb_batt_rtdata表格并且将电池组id的值

        BattData_RT_RamDB_Thread_SQL.createBattData_RT_RamDB_Table(GB_MysqlConnPool, recreate_tb);

        //创建tb_server_state表并且设置表中的值

        BattData_RT_RamDB_Thread_SQL.createServerState_RamDB_Table(GB_MysqlConnPool, recreate_tb);

        /*********************************************************************************/

        System.out.println("Recreate RamDB Tables State Is '" + recreate_tb + "'");

        if(true == recreate_tb) {

            //创建tb_fbs9100s_state表

            FBS9100_Task_Thread_SQL.createFBS9100StateTableOnRam(GB_MysqlConnPool);

            //创建tb_fbs9100s_dcdc_data表

            FBS9100_Task_Thread_SQL.createFBS9100S_DCDC_DataTableOnRam(GB_MysqlConnPool);

            //创建tb_fbs9100s_setparam表

            FBS9100_Task_Thread_SQL.createFBS9100SetTestParamTableOnRam(GB_MysqlConnPool);

            //创建CmccPowerData表

            FBS9100_Task_Thread_SQL.createFBS9100CmccPowerDataOnRam(GB_MysqlConnPool);

            //创建tb_fbs9100S_DFU_StateTable表并向表中添加数据

            FBS9100S_DFU_SQL.createFBS9100S_DFU_TableOnRam(GB_MysqlConnPool);

        }

		
        if(true == m_AppConfig.getMysqlDB_RecreateEn()) {

            m_AppConfig.setMysqlDB_RecreateEn(false);

            m_AppConfig.writeConfigToXml();

        }

		
        System.out.println("BTS DB BUILDER Work Done @ " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));

		
        try {

            Thread.sleep(1000);

        } catch (InterruptedException e) {

            e.printStackTrace();

        }

		
        /*

        while(true) {

            try {

                Thread.sleep(1000);

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        */

    }

}