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_Alarm;
|
import com.database_util.DB_App_Sys;
|
import com.database_util.DB_Batt_History;
|
import com.database_util.DB_Ld9_Testdata;
|
import com.database_util.DB_Param;
|
import com.database_util.DB_Pwrdev_Alarm;
|
import com.database_util.DB_Pwrdev_Data_Rt;
|
import com.database_util.DB_Pwrdev_Inf;
|
import com.database_util.DB_Ram_db;
|
import com.database_util.DB_battinf;
|
import com.database_util.DB_db_user;
|
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.60;
|
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) {
|
e1.printStackTrace();
|
} finally {
|
sql_ck.close_con();
|
}
|
/*********************************************************************************/
|
boolean recreate_tb = m_AppConfig.getMysqlDB_RecreateEn();
|
|
//³õʼ»°db_ram_dbÊý¾Ý¿â
|
DB_Ram_db.init(GB_MysqlConnPool, recreate_tb);
|
|
|
//´´½¨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_dcdc_data±í
|
FBS9100_Task_Thread_SQL.createFBS9100S_DCDC_DataTableOnRam(GB_MysqlConnPool);
|
//´´½¨CmccPowerData±í
|
FBS9100_Task_Thread_SQL.createFBS9100CmccPowerDataOnRam(GB_MysqlConnPool);
|
|
}
|
|
//´´½¨tb_fbs9100S_DFU_StateTable±í²¢Ïò±íÖÐÌí¼ÓÊý¾Ý[ÐÞ¸´Êý¾Ý¿âÖÐȱʧ×Ö¶Îbug]
|
FBS9100S_DFU_SQL.createFBS9100S_DFU_TableOnRam(GB_MysqlConnPool,recreate_tb);
|
|
//´´½¨tb_fbs9100s_setparam±í
|
FBS9100_Task_Thread_SQL.createFBS9100SetTestParamTableOnRam(GB_MysqlConnPool,recreate_tb);
|
|
//´´½¨tb_fbs9100s_state±í
|
FBS9100_Task_Thread_SQL.createFBS9100StateTableOnRam(GB_MysqlConnPool,recreate_tb);
|
|
//´´½¨BTSStationState_Table±í
|
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);
|
|
//ÖØоÀÕý»ú·¿×´Ì¬±íÖеĻú·¿idºÍÉ豸idÖ®¼äµÄ¶ÔÓ¦¹Øϵ
|
FBS9100_Task_Thread_SQL.checkBTSStationState_TableOnRam(GB_MysqlConnPool);
|
|
//´´½¨61850¾ùºâÄ£¿éÐÅÏ¢±í
|
FBS9100_Task_Thread_SQL.createTB_61850_JHState_TableOnRam(GB_MysqlConnPool,recreate_tb);
|
|
//´´½¨61850ÀëÏßÑø»¤¼Æ»®²ÎÊý±í
|
FBS9100_Task_Thread_SQL.createFBS9100_offlineyhplanOnRam(GB_MysqlConnPool, recreate_tb);
|
|
|
//³õʼ»¯Êý¾Ý¿â db_battinf
|
DB_battinf.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Êý¾Ý¿â web_site
|
DB_web_site.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Êý¾Ý¿â db_user
|
DB_db_user.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯¸æ¾¯Êý¾Ý¿â db_alarm
|
DB_Alarm.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Èí¼þÅäÖÃÐÅÏ¢±í db_app_sys
|
DB_App_Sys.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯µç³Ø×éÀúʷʵʱ¼Ç¼¿â db_batt_history
|
DB_Batt_History.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯9¶ÈÀúÊ·Êý¾ÝÊý¾Ý¿â db_ld9_testdata
|
DB_Ld9_Testdata.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯²ÎÊýÊý¾Ý¿â db_param
|
DB_Param.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Alarm.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Data_Rt.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Inf.init(GB_MysqlConnPool, recreate_tb);
|
|
//ÉèÖÃÖØÆô¸æ¾¯Ïß³Ì
|
DB_web_site.setUpThreadRestart(GB_MysqlConnPool);
|
|
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();
|
}
|
}
|
