1 create database datalake;
\r
4 CREATE TABLE `topic` (
\r
5 `name` varchar(255) NOT NULL,
\r
6 `correlate_cleared_message` bit(1) DEFAULT NULL,
\r
7 `enabled` bit(1) DEFAULT NULL,
\r
8 `login` varchar(255) DEFAULT NULL,
\r
9 `message_id_path` varchar(255) DEFAULT NULL,
\r
10 `pass` varchar(255) DEFAULT NULL,
\r
11 `save_raw` bit(1) DEFAULT NULL,
\r
12 `ttl` int(11) DEFAULT NULL,
\r
13 `data_format` varchar(255) DEFAULT NULL,
\r
14 `default_topic` varchar(255) DEFAULT NULL,
\r
15 PRIMARY KEY (`name`),
\r
16 KEY `FK_default_topic` (`default_topic`),
\r
17 CONSTRAINT `FK_default_topic` FOREIGN KEY (`default_topic`) REFERENCES `topic` (`name`)
\r
18 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
\r
22 `name` varchar(255) NOT NULL,
\r
23 `host` varchar(255) DEFAULT NULL,
\r
24 `port` int(11) DEFAULT NULL,
\r
25 `database` varchar(255) DEFAULT NULL,
\r
26 `encrypt` bit(1) DEFAULT NULL,
\r
27 `login` varchar(255) DEFAULT NULL,
\r
28 `pass` varchar(255) DEFAULT NULL,
\r
29 `property1` varchar(255) DEFAULT NULL,
\r
30 `property2` varchar(255) DEFAULT NULL,
\r
31 `property3` varchar(255) DEFAULT NULL,
\r
32 PRIMARY KEY (`name`)
\r
33 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
\r
36 CREATE TABLE `map_db_topic` (
\r
37 `db_name` varchar(255) NOT NULL,
\r
38 `topic_name` varchar(255) NOT NULL,
\r
39 PRIMARY KEY (`db_name`,`topic_name`),
\r
40 KEY `FK_topic_name` (`topic_name`),
\r
41 CONSTRAINT `FK_topic_name` FOREIGN KEY (`topic_name`) REFERENCES `topic` (`name`),
\r
42 CONSTRAINT `FK_db_name` FOREIGN KEY (`db_name`) REFERENCES `db` (`name`)
\r
43 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
\r
46 insert into db (name,host,login,pass,`database`) values ('Couchbase','dl_couchbase','dl','dl1234','datalake');
\r
47 insert into db (name,host) values ('Elasticsearch','dl_es');
\r
48 insert into db (name,host,port,`database`) values ('MongoDB','dl_mongodb',27017,'datalake');
\r
49 insert into db (name,host) values ('Druid','dl_druid');
\r
52 -- in production, default enabled should be off
\r
53 insert into `topic`(`name`,`enabled`,`save_raw`,`ttl`,`data_format`) values ('_DL_DEFAULT_',1,0,3650,'JSON');
\r
54 insert into `topic`(`name`,`enabled`) values ('__consumer_offsets',0);
\r
57 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Couchbase','_DL_DEFAULT_');
\r
58 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Elasticsearch','_DL_DEFAULT_');
\r
59 insert into `map_db_topic`(`db_name`,`topic_name`) values ('MongoDB','_DL_DEFAULT_');
\r
60 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Druid','_DL_DEFAULT_');
\r