蓄电池监控管理平台数据库初始化程序
DELL
2025-06-10 dda1e55ade2d4e1f60d4bd5169c6ad99eb700b13
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
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();
        }
    }
}