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_Circle {
|
|
|
public static void init(MysqlConnPool pool, boolean recreate) {
|
System.out.println(" db_circle init start at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
createDB_Circle(pool);
|
|
createCircle_Inf_Table(pool, recreate);
|
|
createSub_Inf_Table(pool, recreate);
|
|
System.out.println(" db_circle init end at " + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
}
|
|
|
/**
|
* ´´½¨ db_circle Êý¾Ý¿â
|
* @param pool
|
*/
|
public static void createDB_Circle(MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_CIRCLE);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
|
/**
|
* ´´½¨ tb_circle_inf ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createCircle_Inf_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Circle_Inf_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Circle_Inf_Table + " (" +
|
" `num` int(11) NOT NULL AUTO_INCREMENT," +
|
" `station_id` varchar(20) NOT NULL DEFAULT '0'," +
|
" `station_name` varchar(100) NOT NULL DEFAULT ' '," +
|
" `station_name1` varchar(100) NOT NULL DEFAULT ' '," +
|
" `station_name2` varchar(100) NOT NULL DEFAULT ' '," +
|
" `station_name3` varchar(100) NOT NULL DEFAULT ' '," +
|
" `station_name4` varchar(100) NOT NULL DEFAULT ' '," +
|
" `station_name5` varchar(100) NOT NULL DEFAULT ' '," +
|
" `station_name6` varchar(100) DEFAULT ' '," +
|
" `station_name7` varchar(100) DEFAULT ' '," +
|
" `station_name8` varchar(100) DEFAULT ' '," +
|
" `station_name9` varchar(100) DEFAULT ' '," +
|
" `station_ip` varchar(20) NOT NULL DEFAULT '0'," +
|
" `device_id` varchar(20) DEFAULT '0'," +
|
" `device_name` varchar(100) DEFAULT '0'," +
|
" `circle_product_date` date NOT NULL DEFAULT '2006-07-06'," +
|
" `circle_inuse_date` date NOT NULL DEFAULT '2006-07-06'," +
|
" `device_type` int(11) DEFAULT '1' COMMENT '×ʲúÀà±ð:1 ¶¯»·£¬2É豸ÒÇÆ÷'," +
|
" `device_product` varchar(100) DEFAULT '»ªÎª' COMMENT 'Æ·ÅÆ/³§¼Ò'," +
|
" `device_model` varchar(100) DEFAULT '220kl_9108' COMMENT 'ÐͺÅ/¹æ¸ñ'," +
|
" `device_address` varchar(100) DEFAULT '»ú·¿µçÔ´·¿' COMMENT 'ËùÔÚλÖÃ'," +
|
" `device_state` int(11) DEFAULT '1' COMMENT 'Õý³£'," +
|
" `sub_count` int(11) DEFAULT '0' COMMENT '×Ó¼þÊýÁ¿'," +
|
" `property_name` varchar(100) DEFAULT '½»¡¢Ö±Á÷Åäµç¹ñ'," +
|
" PRIMARY KEY (`num`)," +
|
" KEY `index_station_id` (`station_id`)," +
|
" KEY `index_powerdev_id` (`device_id`)," +
|
" KEY `index_station_name` (`station_name`)" +
|
") ENGINE=InnoDB 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_sub_inf ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createSub_Inf_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Sub_Inf_Table;
|
String sql_str02 = " CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Sub_Inf_Table + " (" +
|
" `sub_id` int(11) NOT NULL AUTO_INCREMENT," +
|
" `device_id` varchar(20) NOT NULL DEFAULT '0'," +
|
" `sub_name` varchar(100) DEFAULT '0'," +
|
" `sub_inuse_date` date NOT NULL DEFAULT '2006-07-06'," +
|
" `sub_type` int(11) DEFAULT '1' COMMENT '×Ó¼þÀà±ð'," +
|
" `sub_device_type` int(11) DEFAULT '1' COMMENT 'ËùÊôÀà±ð'," +
|
" `sub_model` varchar(100) DEFAULT '220kl_9108' COMMENT 'ÐͺÅ/¹æ¸ñ'," +
|
" `sub_property_name` varchar(100) DEFAULT '½»¡¢Ö±Á÷Åäµç¹ñ'," +
|
" PRIMARY KEY (`sub_id`)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=6 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();
|
}
|
}
|
}
|