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_Param {
|
public static void init(MysqlConnPool pool, boolean recreate) {
|
System.out.println(" db_param init start at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
createDB_PARAM(pool);
|
|
createDev_Param_Table(pool, recreate);
|
|
createApp_Param_Table(pool, recreate);
|
|
createAlarm_Param_Table(pool, recreate);
|
|
System.out.println(" db_param init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
}
|
|
/**
|
* ´´½¨ db_param Êý¾Ý¿â
|
* @param pool
|
*/
|
public static void createDB_PARAM(MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_PARAM);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ´´½¨ tb_dev_param ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createDev_Param_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Dev_Param_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Dev_Param_Table + " (" +
|
" num int(11) NOT NULL AUTO_INCREMENT," +
|
" dev_Id int(11) NOT NULL DEFAULT '91000000'," +
|
" alm_id int(11) NOT NULL DEFAULT '119001'," +
|
" alm_name varchar(64) NOT NULL DEFAULT 'Batt_Alarm_Type_'," +
|
" alm_high_coe float NOT NULL DEFAULT '0.9'," +
|
" alm_low_coe float NOT NULL DEFAULT '0.5'," +
|
" alm_high_level int(11) NOT NULL DEFAULT '4'," +
|
" alm_low_level int(11) NOT NULL DEFAULT '1'," +
|
" alm_high_en int(11) NOT NULL DEFAULT '0'," +
|
" alm_low_en int(11) NOT NULL DEFAULT '0'," +
|
" note varchar(64) NOT NULL DEFAULT ''," +
|
" PRIMARY KEY (num)," +
|
" KEY index_alm_id (alm_id)," +
|
" KEY index_dev_id (dev_Id)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;";
|
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_app_param ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createApp_Param_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.App_Param_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.App_Param_Table + " (" +
|
" num int(11) NOT NULL AUTO_INCREMENT," +
|
" param_name varchar(50) DEFAULT NULL," +
|
" param_value varchar(50) DEFAULT NULL," +
|
" param_caption varchar(200) DEFAULT NULL," +
|
" PRIMARY KEY (num)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=17 DEFAULT CHARSET=utf8;";
|
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_alarm_param ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createAlarm_Param_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Alarm_Param_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Alarm_Param_Table + " (" +
|
" num int(11) NOT NULL AUTO_INCREMENT," +
|
" alm_id int(11) NOT NULL DEFAULT '0'," +
|
" alm_name varchar(50) NOT NULL DEFAULT ' '," +
|
" alm_high_coe float NOT NULL DEFAULT '0'," +
|
" alm_low_coe float NOT NULL DEFAULT '0'," +
|
" alm_high_level int(11) NOT NULL DEFAULT '0'," +
|
" alm_low_level int(11) NOT NULL DEFAULT '0'," +
|
" alm_high_en tinyint(1) NOT NULL DEFAULT '0'," +
|
" alm_low_en tinyint(1) NOT NULL DEFAULT '0'," +
|
" PRIMARY KEY (num)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8;";
|
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();
|
}
|
}
|
}
|