package main;
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import com.base.Com;
|
import com.config.AppConfig;
|
import com.config.AppParam;
|
import com.database_util.DB_Ckpwrdev_Alarm;
|
import com.database_util.DB_Ckpwrdev_Break_Alarm;
|
import com.database_util.DB_Ckpwrdev_Data_RT;
|
import com.database_util.DB_Ckpwrdev_Inf;
|
import com.database_util.DB_User;
|
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) 10.03;
|
public final static String m_Version = "Welcome To Use BTS DB BUILDER V" + m_VersionNum + " RC_20180908";
|
/**************************************************************************/
|
/**************************************************************************/
|
public static final int DEF_MysqlServerFBS_Port = 3381;
|
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_ckpwrdev_alarm
|
DB_Ckpwrdev_Alarm.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Êý¾Ý¿â db_ckpwrdev_break_alarm
|
DB_Ckpwrdev_Break_Alarm.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Êý¾Ý¿â db_ckpwrdev_data_rt
|
DB_Ckpwrdev_Data_RT.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Êý¾Ý¿â db_ckpwrdev_data_rt
|
DB_Ckpwrdev_Inf.init(GB_MysqlConnPool, recreate_tb);
|
|
//³õʼ»¯Êý¾Ý¿â db_ckpwrdev_data_rt
|
DB_User.init(GB_MysqlConnPool, recreate_tb);
|
|
if(true == m_AppConfig.getMysqlDB_RecreateEn()) {
|
m_AppConfig.setMysqlDB_RecreateEn(false);
|
m_AppConfig.writeConfigToXml();
|
}
|
try {
|
Thread.sleep(1000);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
|
//³õʼ»¯db_param.
|
m_AppParam = new AppParam(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();
|
}
|
}
|
