Skip to content

Commit eaaf9ce

Browse files
author
lichengsheng
committed
更新sql
1 parent 8c8dc3c commit eaaf9ce

File tree

2 files changed

+27
-413
lines changed

2 files changed

+27
-413
lines changed

‎doc/mq_basic.sql‎

Lines changed: 27 additions & 101 deletions
Original file line numberDiff line numberDiff line change
@@ -1,25 +1,3 @@
1-
/*
2-
Navicat MySQL Data Transfer
3-
4-
Source Server : localhost
5-
Source Server Version : 50717
6-
Source Host : localhost:3306
7-
Source Database : mq_basic
8-
9-
Target Server Type : MYSQL
10-
Target Server Version : 50717
11-
File Encoding : 65001
12-
13-
Date: 2019-10-15 15:15:45
14-
*/
15-
create database mq_basic;
16-
use mq_basic;
17-
SET FOREIGN_KEY_CHECKS=0;
18-
19-
-- ----------------------------
20-
-- Table structure for audit_log
21-
-- ----------------------------
22-
DROP TABLE IF EXISTS `audit_log`;
231
CREATE TABLE `audit_log` (
242
`id` bigint(20) NOT NULL AUTO_INCREMENT,
253
`tb_name` varchar(100) NOT NULL COMMENT '名称',
@@ -34,10 +12,6 @@ CREATE TABLE `audit_log` (
3412
KEY `tbname_refid_idx` (`tb_name`,`ref_id`)
3513
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='主题';
3614

37-
-- ----------------------------
38-
-- Table structure for consumer
39-
-- ----------------------------
40-
DROP TABLE IF EXISTS `consumer`;
4115
CREATE TABLE `consumer` (
4216
`id` bigint(20) NOT NULL AUTO_INCREMENT,
4317
`ip` varchar(45) NOT NULL,
@@ -54,12 +28,8 @@ CREATE TABLE `consumer` (
5428
PRIMARY KEY (`id`),
5529
UNIQUE KEY `name_UNIQUE` (`name`),
5630
KEY `consumer_name_index` (`name`)
57-
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='订阅者信息';
31+
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='订阅者信息';
5832

59-
-- ----------------------------
60-
-- Table structure for consumer_group
61-
-- ----------------------------
62-
DROP TABLE IF EXISTS `consumer_group`;
6333
CREATE TABLE `consumer_group` (
6434
`id` bigint(20) NOT NULL AUTO_INCREMENT,
6535
`name` varchar(50) NOT NULL COMMENT '订阅者集合名称，唯一',
@@ -88,16 +58,12 @@ CREATE TABLE `consumer_group` (
8858
`meta_update_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '元数据更新时间',
8959
`mode` int(11) NOT NULL DEFAULT '1' COMMENT '1，为集群模式，2，为广播模式,3，为代理模式',
9060
`origin_name` varchar(50) DEFAULT NULL COMMENT '原始的消费者组名',
91-
`sub_env` varchar(45) NOT NULL DEFAULT 'default' COMMENT '子环境名称',
92-
`push_flag` int(11) NOT NULL DEFAULT '0' COMMENT '1，表示实时推送，0，表示非实时推送',
61+
`sub_env` varchar(45) NOT NULL DEFAULT 'default',
62+
`push_flag` int(11) NOT NULL DEFAULT '0' COMMENT '1,表示实时推送，0，表示非实时推送'
9363
PRIMARY KEY (`id`),
9464
UNIQUE KEY `name_index` (`name`)
95-
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
65+
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='消费者组元数据表';
9666

97-
-- ----------------------------
98-
-- Table structure for consumer_group_consumer
99-
-- ----------------------------
100-
DROP TABLE IF EXISTS `consumer_group_consumer`;
10167
CREATE TABLE `consumer_group_consumer` (
10268
`id` bigint(20) NOT NULL AUTO_INCREMENT,
10369
`consumer_id` bigint(20) NOT NULL COMMENT '消费者Id',
@@ -112,12 +78,8 @@ CREATE TABLE `consumer_group_consumer` (
11278
PRIMARY KEY (`id`),
11379
UNIQUE KEY `consumer_group_consumer_uq` (`consumer_id`,`consumer_group_id`),
11480
KEY `consumer_group_id_idx` (`consumer_group_id`)
115-
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='订阅者信息';
81+
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='订阅者信息';
11682

117-
-- ----------------------------
118-
-- Table structure for consumer_group_topic
119-
-- ----------------------------
120-
DROP TABLE IF EXISTS `consumer_group_topic`;
12183
CREATE TABLE `consumer_group_topic` (
12284
`id` bigint(20) NOT NULL AUTO_INCREMENT,
12385
`consumer_group_id` bigint(20) NOT NULL,
@@ -130,7 +92,7 @@ CREATE TABLE `consumer_group_topic` (
13092
`thread_size` int(11) DEFAULT '10',
13193
`max_lag` int(11) DEFAULT '1000' COMMENT '可以自定义此topic下topic 告警条数',
13294
`tag` varchar(100) DEFAULT NULL COMMENT '用来做消息tag 过滤,规则是只要包含在消息体tag中就算符合',
133-
`delay_process_time` int(11) DEFAULT '0' COMMENT '默认为0，秒为单位。延迟处理时间，相对于发送时间的延迟，例如希望发送一条消息后10秒后被订阅，就需要设置该参数为10000。',
95+
`delay_process_time` int(11) DEFAULT '0' COMMENT '默认为0，毫秒为单位。延迟处理时间，相对于发送时间的延迟，例如希望发送一条消息后10秒后被订阅，就需要设置该参数为10000。',
13496
`pull_batch_size` int(11) DEFAULT '50' COMMENT '批量拉取条数',
13597
`consumer_batch_size` int(11) DEFAULT '1' COMMENT '批量消费条数',
13698
`max_pull_time` int(11) DEFAULT '5' COMMENT '最大拉取等待时间，单位是秒默认5秒，最小值1秒',
@@ -146,10 +108,6 @@ CREATE TABLE `consumer_group_topic` (
146108
UNIQUE KEY `group_topic_id_uq` (`consumer_group_id`,`topic_id`)
147109
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
148110

149-
-- ----------------------------
150-
-- Table structure for db_node
151-
-- ----------------------------
152-
DROP TABLE IF EXISTS `db_node`;
153111
CREATE TABLE `db_node` (
154112
`id` bigint(20) NOT NULL AUTO_INCREMENT,
155113
`ip` varchar(45) DEFAULT NULL COMMENT '表示数据对应的ip',
@@ -171,34 +129,16 @@ CREATE TABLE `db_node` (
171129
`update_by` varchar(100) DEFAULT NULL COMMENT '操作人',
172130
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
173131
`is_active` tinyint(4) NOT NULL DEFAULT '1' COMMENT '逻辑删除',
132+
`ip_01` varchar(45) DEFAULT NULL,
133+
`port_01` smallint(11) DEFAULT NULL,
134+
`ip_bak_01` varchar(45) DEFAULT NULL,
135+
`port_bak_01` smallint(11) DEFAULT NULL,
136+
`con_str_01` varchar(500) DEFAULT NULL COMMENT '数据库账户名-备份',
174137
PRIMARY KEY (`id`),
175138
UNIQUE KEY `con_str_UNIQUE` (`con_str`),
176139
KEY `update_time_idx` (`update_time`)
177140
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='数据库节点';
178141

179-
-- ----------------------------
180-
-- Table structure for dic
181-
-- ----------------------------
182-
DROP TABLE IF EXISTS `dic`;
183-
CREATE TABLE `dic` (
184-
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
185-
`key1` varchar(50) NOT NULL COMMENT '键',
186-
`value1` varchar(100) NOT NULL COMMENT '值',
187-
`remark` varchar(100) DEFAULT NULL COMMENT '备注',
188-
`insert_by` varchar(100) DEFAULT NULL COMMENT '操作人',
189-
`insert_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
190-
`update_by` varchar(100) DEFAULT NULL COMMENT '操作人',
191-
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
192-
`is_active` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除',
193-
PRIMARY KEY (`id`),
194-
UNIQUE KEY `key_index` (`key1`)
195-
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
196-
197-
198-
-- ----------------------------
199-
-- Table structure for message_01
200-
-- ----------------------------
201-
DROP TABLE IF EXISTS `message_01`;
202142
CREATE TABLE `message_01` (
203143
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
204144
`busi_id` varchar(50) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '业务id',
@@ -213,10 +153,6 @@ CREATE TABLE `message_01` (
213153
PRIMARY KEY (`id`)
214154
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='消息';
215155

216-
-- ----------------------------
217-
-- Table structure for mq_lock
218-
-- ----------------------------
219-
DROP TABLE IF EXISTS `mq_lock`;
220156
CREATE TABLE `mq_lock` (
221157
`id` bigint(20) NOT NULL AUTO_INCREMENT,
222158
`ip` varchar(45) DEFAULT NULL,
@@ -233,10 +169,6 @@ CREATE TABLE `mq_lock` (
233169
KEY `key_idx` (`key1`)
234170
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
235171

236-
-- ----------------------------
237-
-- Table structure for notify_message
238-
-- ----------------------------
239-
DROP TABLE IF EXISTS `notify_message`;
240172
CREATE TABLE `notify_message` (
241173
`id` bigint(20) NOT NULL AUTO_INCREMENT,
242174
`consumer_group_id` bigint(20) NOT NULL,
@@ -249,10 +181,6 @@ CREATE TABLE `notify_message` (
249181
PRIMARY KEY (`id`)
250182
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='用来记录需要重平衡的consumer_group';
251183

252-
-- ----------------------------
253-
-- Table structure for notify_message_stat
254-
-- ----------------------------
255-
DROP TABLE IF EXISTS `notify_message_stat`;
256184
CREATE TABLE `notify_message_stat` (
257185
`id` bigint(20) NOT NULL AUTO_INCREMENT,
258186
`key1` varchar(45) NOT NULL COMMENT 'notifymessage标识，防止重复插入',
@@ -266,10 +194,6 @@ CREATE TABLE `notify_message_stat` (
266194
UNIQUE KEY `key1_UNIQUE` (`key1`)
267195
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='用来记录需要重平衡的消息id';
268196

269-
-- ----------------------------
270-
-- Table structure for queue
271-
-- ----------------------------
272-
DROP TABLE IF EXISTS `queue`;
273197
CREATE TABLE `queue` (
274198
`id` bigint(20) NOT NULL AUTO_INCREMENT,
275199
`topic_id` bigint(20) NOT NULL DEFAULT '0' COMMENT 'topic id',
@@ -293,10 +217,6 @@ CREATE TABLE `queue` (
293217
KEY `topic_id_idx` (`topic_id`)
294218
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='分区';
295219

296-
-- ----------------------------
297-
-- Table structure for queue_offset
298-
-- ----------------------------
299-
DROP TABLE IF EXISTS `queue_offset`;
300220
CREATE TABLE `queue_offset` (
301221
`id` bigint(20) NOT NULL AUTO_INCREMENT,
302222
`consumer_group_id` bigint(20) NOT NULL DEFAULT '0' COMMENT '订阅者组id',
@@ -321,17 +241,13 @@ CREATE TABLE `queue_offset` (
321241
`meta_update_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '元数据更新时间',
322242
`origin_consumer_group_name` varchar(50) DEFAULT NULL COMMENT '原始的消费者组名',
323243
`consumer_group_mode` int(11) NOT NULL DEFAULT '1' COMMENT '1，为集群模式，2，为广播模式,3，为代理模式',
324-
`sub_env` varchar(45) NOT NULL DEFAULT 'default' COMMENT '子环境名称',
244+
`sub_env` varchar(45) NOT NULL DEFAULT 'default',
325245
PRIMARY KEY (`id`),
326246
UNIQUE KEY `uq_group_id_topic_id` (`consumer_group_id`,`topic_id`,`queue_id`),
327247
KEY `consumer_group_id_idx` (`consumer_group_id`),
328248
KEY `consumer_idx` (`consumer_id`)
329249
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='客户端的topic信息';
330250

331-
-- ----------------------------
332-
-- Table structure for server
333-
-- ----------------------------
334-
DROP TABLE IF EXISTS `server`;
335251
CREATE TABLE `server` (
336252
`id` bigint(20) NOT NULL AUTO_INCREMENT,
337253
`ip` varchar(45) DEFAULT NULL,
@@ -345,15 +261,11 @@ CREATE TABLE `server` (
345261
`update_by` varchar(100) DEFAULT NULL COMMENT '操作人',
346262
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
347263
`is_active` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除',
348-
PRIMARY KEY (`id`),
264+
PRIMARY KEY (`id`),
349265
UNIQUE KEY `ip_port_uq` (`ip`,`port`),
350266
KEY `ip_port_idx` (`ip`,`port`)
351267
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
352268

353-
-- ----------------------------
354-
-- Table structure for topic
355-
-- ----------------------------
356-
DROP TABLE IF EXISTS `topic`;
357269
CREATE TABLE `topic` (
358270
`id` bigint(20) NOT NULL AUTO_INCREMENT,
359271
`name` varchar(100) NOT NULL COMMENT '名称',
@@ -385,3 +297,17 @@ CREATE TABLE `topic` (
385297
KEY `name_idx` (`name`),
386298
KEY `update_time_idex` (`update_time`)
387299
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='主题';
300+
301+
CREATE TABLE `dic` (
302+
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
303+
`key1` varchar(50) NOT NULL COMMENT '键',
304+
`value1` varchar(100) NOT NULL COMMENT '值',
305+
`remark` varchar(100) DEFAULT NULL COMMENT '备注',
306+
`insert_by` varchar(100) DEFAULT NULL COMMENT '操作人',
307+
`insert_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
308+
`update_by` varchar(100) DEFAULT NULL COMMENT '操作人',
309+
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
310+
`is_active` tinyint(4) NOT NULL DEFAULT '0' COMMENT '逻辑删除',
311+
PRIMARY KEY (`id`),
312+
UNIQUE KEY `key_index` (`key1`)
313+
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

0 commit comments

Comments
 (0)