蓄电池监控管理平台数据库初始化程序
Administrator
2023-03-29 483b1454098287dd6cebf1ea7ed69e9619ec75a0
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
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();
        }
    }
}