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.config.AppParam;
|
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_Batt_Testdata;
|
import com.database_util.DB_Circle;
|
import com.database_util.DB_Dev_History;
|
import com.database_util.DB_Dev_TestParam;
|
import com.database_util.DB_Fbo_testdata;
|
import com.database_util.DB_Ied_Scout;
|
import com.database_util.DB_Ld9_Testdata;
|
import com.database_util.DB_Nj_Measurement;
|
import com.database_util.DB_Param;
|
import com.database_util.DB_Pwrdev_Alarm;
|
import com.database_util.DB_Pwrdev_Data_History;
|
import com.database_util.DB_Pwrdev_Data_History_GW;
|
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_Upspwrdev_Alarm;
|
import com.database_util.DB_Upspwrdev_Data_History;
|
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) 2.08;
|
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 AppParam m_AppParam;
|
|
private static MysqlConnPool GB_MysqlConnPool;
|
|
public static boolean I118N_EN = false; //Êý¾Ý¿âĬÈÏÌí¼ÓÊý¾ÝÊÇ·ñ²åÈëĬÈÏÓ¢ÎÄ true:Ó¢ÎÄ flase:ÖÐÎÄ
|
|
/*********************************************************************************************/
|
/*********************************************************************************************/
|
|
|
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, 50);
|
|
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();
|
boolean recreate_tb = false;
|
|
//³õʼ»¯Êý¾Ý¿â db_battinf
|
DB_battinf.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»°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 + "'" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
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);
|
|
|
//´´½¨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);
|
|
|
|
//³õʼ»¯Êý¾Ý¿â 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);
|
|
//System.out.println("===="+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
//³õʼ»¯Èí¼þÅäÖÃÐÅÏ¢±í 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_Batt_TestdataÊý¾Ý¿â db_ld9_testdata
|
DB_Batt_Testdata.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯²ÎÊýÊý¾Ý¿â db_param
|
DB_Param.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Inf.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Alarm.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Data_Rt.init(GB_MysqlConnPool, recreate_tb);
|
|
|
//System.out.println("===="+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
//³õʼ»¯FBOÀúÊ·ÎļþÊý¾Ý±í
|
DB_Fbo_testdata.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯É豸ÀúʷʵʱÊý¾Ý¿â±í
|
DB_Dev_History.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Dev_TestParam.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Data_History.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Pwrdev_Data_History_GW.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Upspwrdev_Alarm.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Upspwrdev_Data_History.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Ied_Scout.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Nj_Measurement.init(GB_MysqlConnPool, recreate_tb);
|
|
DB_Circle.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++) {
|
|
}
|
try {
|
Thread.sleep(1000);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
|
//³õʼ»¯db_param.
|
m_AppParam = new AppParam(GB_MysqlConnPool);
|
|
//ÐÞ¸´Ä³Ð©»ùÕ¾µÚÒ»´Î¼Ç¼µÄ³ä·ÅµçÎÞ·¨ÏÔʾbug
|
FBS9100_Task_Thread_SQL.repairBattFirstTestData(GB_MysqlConnPool);
|
|
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();
|
}
|
}
|
*/
|
|
/*MysqlConnPool pool1 = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), 3363, 500);
|
MysqlConnPool pool2 = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), 3364, 500);
|
|
//ÖØн¨±í
|
//FBS9100_Task_Thread_SQL.createUser_Log_Table(pool1, true);
|
//FBS9100_Task_Thread_SQL.createUser_Log_Table(pool2, true);
|
|
//ÖØн¨±í
|
//FBS9100_Task_Thread_SQL.createUser_Limit_Table(pool1, true);
|
//FBS9100_Task_Thread_SQL.createUser_Limit_Table(pool2, true);
|
|
|
System.out.println("Ïß³Ì×ÜÊý£º"+m_AppConfig.getWorkThreadCountMax()+"ÿ´ÎSQLÌõÊý£º"+m_AppConfig.getBattAlarmDataDayCountMax());
|
|
StringBuffer buff1 = new StringBuffer("INSERT INTO db_user.tb_user_log(uid,uOprateMsg,operation_detail) VALUES");
|
StringBuffer buff2 = new StringBuffer("INSERT INTO db_user.tb_user_limit(userId,limitDuration,loginTime) VALUES");
|
for(int i=0;i<m_AppConfig.getBattAlarmDataDayCountMax();i++) {
|
if(i>0) {
|
buff1.append(",");
|
buff2.append(",");
|
}
|
|
buff1.append("("+ (1001+i)+",'²âÊÔÊý¾Ý','²âÊÔ²åÈëÊý¾Ý')");
|
|
buff2.append("(11,"+(2502+i)+",NOW())");
|
System.out.println(i);
|
}
|
System.out.println(buff1.toString());
|
System.out.println(buff2.toString());
|
|
final String sql_strs11 = buff1.toString();
|
final String sql_strs22 = buff2.toString();
|
|
|
|
|
for(int i = 0;i < m_AppConfig.getWorkThreadCountMax();i++ ) {
|
new Thread(new Runnable() {
|
|
@Override
|
public void run() {
|
while(true) {
|
try {
|
//FBS9100_Task_Thread_SQL.insertDatatb_user_log(pool1,sql_strs11);
|
FBS9100_Task_Thread_SQL.insertDatatb_user_limit(pool1,sql_strs22);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
}).start();
|
}
|
|
for(int i = 0;i < m_AppConfig.getWorkThreadCountMax();i++ ) {
|
new Thread(new Runnable() {
|
|
@Override
|
public void run() {
|
//System.out.println(Thread.currentThread().getName());
|
while(true) {
|
try {
|
//FBS9100_Task_Thread_SQL.insertDatatb_user_log(pool2,sql_strs11);
|
FBS9100_Task_Thread_SQL.insertDatatb_user_limit(pool2,sql_strs22);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}).start();
|
}
|
System.out.println("Ïß³ÌÒÑÍêÈ«Æô¶¯¡£¡£¡£¡£¡£¡£¡£");*/
|
}
|
|
|
public static void main(String[] args) {
|
init();
|
}
|
}
|
