package com.database_util;
|
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import com.base.Com;
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class DB_Ied_Scout {
|
public static void init(MysqlConnPool pool, boolean recreate) {
|
System.out.println(" db_ied_scout init start at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
createDB_IED_SCOUT(pool);
|
|
createConnect_Inf_Table(pool, recreate); //´´½¨IED Scout ÅäÖÃÐÅÏ¢±í
|
|
createIed_NodeState_Table(pool, recreate); //´´½¨IED Scout ʵʱ״̬ÐÅÏ¢±í
|
|
System.out.println(" db_ied_scout init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}
|
|
/**
|
* ´´½¨ db_ied_scout Êý¾Ý¿â
|
* @param pool
|
*/
|
public static void createDB_IED_SCOUT(MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_IED_SCOUT);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ´´½¨ tb_connect_inf ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createConnect_Inf_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Connect_Inf_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Connect_Inf_Table + " (" +
|
" `num` bigint(20) NOT NULL COMMENT 'Ö÷¼ü'," +
|
" `target_ip` varchar(255) NOT NULL DEFAULT '127.0.0.1' COMMENT 'Ä¿±êIPµØÖ·'," +
|
" `target_port` int(11) NOT NULL DEFAULT '102' COMMENT 'Ä¿µÄ¶Ë¿ÚºÅ'," +
|
" `target_icd` varchar(255) NOT NULL DEFAULT '' COMMENT 'Ä¿µÄÉ豸icdÎļþ·¾¶'," +
|
" `conn_st` int(11) NOT NULL DEFAULT '0' COMMENT 'Á¬½Ó״̬0-ĬÈÏ 1-¿ªÊ¼Á¬½Ó[ƽ̨ÉèÖÃ] 2-Á¬½ÓÖÐ 3-Á¬½Ó³É¹¦ 4-Á¬½Óʧ°Ü'," +
|
" `fail_reasion` int(11) NOT NULL DEFAULT '0' COMMENT 'ʧ°ÜÔÒò£º0-ÎÞ 1-ICDÎļþ²»´æÔÚ 2-ICDÎļþ²»Æ¥Åä'," +
|
" `comm_num` bigint(20) NOT NULL DEFAULT '0' COMMENT 'ͨÐżÆÊý'," +
|
" `error_num` bigint(20) NOT NULL DEFAULT '0' COMMENT 'ͨÐÅ´íÎó¼ÆÊý'," +
|
" PRIMARY KEY (`num`)" +
|
") ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='IED_Scout Á¬½ÓÅäÖÃÐÅÏ¢±í';";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
if(true == recreate) {
|
sql.sqlMysqlExecute(sql_str01);
|
}
|
sql.sqlMysqlExecute(sql_str02);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ´´½¨ tb_ied_nodestate ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createIed_NodeState_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Ied_NodeState_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Ied_NodeState_Table + " (" +
|
" `num` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '×ÔÔöÖ÷¼ü'," +
|
" `node_path` varchar(255) CHARACTER SET gbk NOT NULL DEFAULT '' COMMENT '½Úµã·¾¶'," +
|
" `node_name` varchar(255) CHARACTER SET gbk NOT NULL DEFAULT '' COMMENT '½ÚµãÖÐÎÄÃû³Æ'," +
|
" `node_value` float NOT NULL DEFAULT '0' COMMENT '½ÚµãÖµ'," +
|
" PRIMARY KEY (`num`)," +
|
" UNIQUE KEY `index_node_path` (`node_path`) USING BTREE" +
|
") ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='IED Scout ʵʱ״̬ÐÅÏ¢±í';";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
if(true == recreate) {
|
sql.sqlMysqlExecute(sql_str01);
|
}
|
sql.sqlMysqlExecute(sql_str02);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
}
|