蓄电池监控管理平台数据库初始化程序
whyclj
2021-01-12 fd615ffe8549c5399aa0545f0acc6a7927cc48b5
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package com.database_util;
 
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_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());
        try {
            if(true == recreate) {            
                sql.sqlMysqlExecute(sql_str01);
            }
            sql.sqlMysqlExecute(sql_str02);        
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            sql.close_con();
        }
    }
    
    
}