将创建FBS9100S_setParam表的创建语句添加到判别是否重建表外部，避免升级时出现的表中列不存在bug

whyclj

2019-01-14 ccf286b393a89f064be9f6a691110b4d4b81eb97

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
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.database_util.DB_web_site; 
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.037; 
    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 init(){ 
        /*//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); 
         
        //´´½¨tb_bts_gprs_state±í 
        BattData_RT_RamDB_Thread_SQL.createBTSGPRSState_Table(GB_MysqlConnPool, recreate_tb); 
         
        //´´½¨tb_fbs9100_battparam±í 
        BattData_RT_RamDB_Thread_SQL.createBattParam_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±í 
            //´´½¨CmccPowerData±í 
            FBS9100_Task_Thread_SQL.createFBS9100CmccPowerDataOnRam(GB_MysqlConnPool); 
            //´´½¨tb_fbs9100S_DFU_StateTable±í²¢Ïò±íÖÐÌí¼ÓÊý¾Ý 
            FBS9100S_DFU_SQL.createFBS9100S_DFU_TableOnRam(GB_MysqlConnPool); 
             
            //´´½¨BTSStationState_Table±í 
        } 
        FBS9100_Task_Thread_SQL.createFBS9100SetTestParamTableOnRam(GB_MysqlConnPool,recreate_tb); 
         
         
        FBS9100_Task_Thread_SQL.createBTSStationState_TableOnRam(GB_MysqlConnPool,recreate_tb); 
         
        FBS9100_Task_Thread_SQL.createFBS9100SysParam_TableOnRam(GB_MysqlConnPool,recreate_tb);                 //´´½¨É豸״̬±í 
         
        FBS9100_Task_Thread_SQL.insertBTSStationState_TableOnRam(GB_MysqlConnPool);                                //³õʼ»¯Â¼Èë»ú·¿×´Ì¬ 
         
        DB_web_site.init(GB_MysqlConnPool, recreate_tb);                //³õʼ»¯ web_siteÊý¾Ý¿âÖеıí 
         
         
        if(true == m_AppConfig.getMysqlDB_RecreateEn()) { 
            m_AppConfig.setMysqlDB_RecreateEn(false); 
            m_AppConfig.writeConfigToXml(); 
        } 
         
         
         
        //ÐÞ¸Ätb_app_sys±íÖеĹؼü×Ö,ÈÃÖ÷³ÌÐòʶ±ð 
        for(int i=0;i<5;i++) {             
            if(BattData_RT_RamDB_Thread_SQL.updateTb_App_Sys_AppServerTable(GB_MysqlConnPool)) { 
                break; 
            } 
            try { 
                Thread.sleep(1000); 
            } catch (InterruptedException e) { 
                e.printStackTrace(); 
            } 
        } 
        try { 
            Thread.sleep(1000); 
        } catch (InterruptedException e) { 
            e.printStackTrace(); 
        } 
         
        System.out.println("BTS DB BUILDER Work Done @ " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms)); 
        /* 
        while(true) { 
            try { 
                Thread.sleep(1000); 
            } catch (InterruptedException e) { 
                e.printStackTrace(); 
            } 
        } 
        */ 
    } 
     
     
    public static void main(String[] args) { 
        init(); 
    } 
}