package com.database_util;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
|
import com.sql.MysqlConnPool;
|
import com.sql.Sql_Mysql;
|
|
public class DB_Pwrdev_Inf {
|
public static void init(MysqlConnPool pool, boolean recreate) {
|
createDB_PWRDEV_INF (pool);
|
|
createPwrdev_Inf_Table(pool, recreate);
|
|
createPwrapp_Sys_Table(pool, recreate);
|
|
}
|
|
/**
|
* ´´½¨ db_pwrdev_inf Êý¾Ý¿â
|
* @param pool
|
*/
|
private static void createDB_PWRDEV_INF(MysqlConnPool pool) {
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
try {
|
sql.sqlMysqlExecute("CREATE DATABASE IF NOT EXISTS " + Sql_Mysql.DB_PWRDEV_INF);
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
/**
|
* ´´½¨ tb_pwrdev_inf ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createPwrdev_Inf_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Pwrdev_Inf_Table;
|
String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Pwrdev_Inf_Table + " (" +
|
" `num` int(11) NOT NULL AUTO_INCREMENT," +
|
" `StationId` varchar(20) NOT NULL DEFAULT '0'," +
|
" `StationName` varchar(100) NOT NULL DEFAULT ' '," +
|
" `StationName1` varchar(100) NOT NULL DEFAULT ' '," +
|
" `StationName2` varchar(100) NOT NULL DEFAULT ' '," +
|
" `StationName3` varchar(100) NOT NULL DEFAULT ' '," +
|
" `StationName4` varchar(100) NOT NULL DEFAULT ' '," +
|
" `StationName5` varchar(100) NOT NULL DEFAULT ' '," +
|
" `StationName6` varchar(100) DEFAULT ' '," +
|
" `StationName7` varchar(100) DEFAULT ' '," +
|
" `StationName8` varchar(100) DEFAULT ' '," +
|
" `StationName9` varchar(100) DEFAULT ' '," +
|
" `StationIP` varchar(20) NOT NULL DEFAULT '0'," +
|
" `PowerDeviceId` bigint(20) NOT NULL DEFAULT '0'," +
|
" `PowerDeviceIp` varchar(50) NOT NULL DEFAULT '192.168.0.88'," +
|
" `PowerDeviceName` varchar(100) NOT NULL DEFAULT '0'," +
|
" `ProtocolName` varchar(100) NOT NULL DEFAULT '0'," +
|
" `DeviceId` varchar(20) DEFAULT '0'," +
|
" `DeviceName` varchar(100) DEFAULT '0'," +
|
" `PowerProducer` varchar(45) NOT NULL DEFAULT '0'," +
|
" `PowerProductDate` date NOT NULL DEFAULT '2006-07-06'," +
|
" `PowerInUseDate` date NOT NULL DEFAULT '2006-07-06'," +
|
" PRIMARY KEY (`num`)," +
|
" KEY `index_station_id` (`StationId`)," +
|
" KEY `index_powerdev_id` (`PowerDeviceId`)," +
|
" KEY `index_station_name` (`StationName`)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=141 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_pwrapp_sys ±í
|
* @param pool
|
* @param recreate
|
*/
|
public static void createPwrapp_Sys_Table(MysqlConnPool pool, boolean recreate) {
|
String sql_str01 = " DROP TABLE IF EXISTS "+Sql_Mysql.Pwrapp_Sys_Table;
|
String sql_str02 = "CREATE TABLE IF NOT EXISTS " + Sql_Mysql.Pwrapp_Sys_Table + " (" +
|
" `num` int(11) NOT NULL AUTO_INCREMENT," +
|
" `SqlDB_Version` float NOT NULL DEFAULT '1'," +
|
" `SqlDB_BackUpTime` datetime NOT NULL DEFAULT '2000-01-01 00:00:00'," +
|
" `SqlDB_BackUpManual_EN` tinyint(1) NOT NULL DEFAULT '0'," +
|
" `AppServer_Reinit_PowerData_EN` tinyint(1) NOT NULL DEFAULT '0'," +
|
" `AppServer_Reinit_BattGroupData_EN` tinyint(1) NOT NULL DEFAULT '0'," +
|
" `AppServer_Reinit_Config_EN` tinyint(1) NOT NULL DEFAULT '0'," +
|
" `AppServer_Version` float NOT NULL DEFAULT '1'," +
|
" `AppClient_Version` float NOT NULL DEFAULT '1'," +
|
" `AppName` varchar(50) NOT NULL DEFAULT '0'," +
|
" PRIMARY KEY (`num`)" +
|
") ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;";
|
Sql_Mysql sql = new Sql_Mysql(pool.getConn());
|
ResultSet res = null;
|
try {
|
if(true == recreate) {
|
sql.sqlMysqlExecute(sql_str01);
|
}
|
sql.sqlMysqlExecute(sql_str02);
|
|
//Ìí¼Ó×Ö¶ÎAppServer_Reinit_PowerData_Charger_EN
|
res = sql.sqlMysqlQuery("SELECT * FROM information_schema.columns"
|
+ " WHERE table_schema='db_pwrdev_inf'"
|
+ " AND table_name='tb_pwrapp_sys'"
|
+ " AND column_name='AppServer_Reinit_BattGroupData_EN'");
|
if(false == res.next()) {
|
sql.sqlMysqlExecute("ALTER TABLE " + Sql_Mysql.Pwrapp_Sys_Table
|
+ " ADD COLUMN `AppServer_Reinit_BattGroupData_EN` tinyint(1) NOT NULL DEFAULT '0';");
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
if(null != res) {
|
try {
|
res.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
sql.close_con();
|
}
|
}
|
|
|
}
|
