supports multiple Kafka clusters and DBs
[dcaegen2/services.git] / components / datalake-handler / feeder / src / assembly / scripts / init_db.sql
1 drop DATABASE datalake;\r
2 create database datalake;\r
3 use datalake;\r
4 \r
5 CREATE TABLE `topic_name` (\r
6   `id` varchar(255) NOT NULL,\r
7   PRIMARY KEY (`id`)\r
8 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
9 \r
10 CREATE TABLE `db_type` (\r
11   `id` varchar(255) NOT NULL,\r
12   `default_port` int(11) DEFAULT NULL,\r
13   `name` varchar(255) NOT NULL,\r
14   `tool` bit(1) NOT NULL,\r
15   PRIMARY KEY (`id`)\r
16 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
17 \r
18 CREATE TABLE `db` (\r
19   `id` int(11) NOT NULL AUTO_INCREMENT,\r
20   `database_name` varchar(255) DEFAULT NULL,\r
21   `enabled` bit(1) NOT NULL,\r
22   `encrypt` bit(1) DEFAULT NULL,\r
23   `host` varchar(255) DEFAULT NULL,\r
24   `login` varchar(255) DEFAULT NULL,\r
25   `name` varchar(255) DEFAULT NULL,\r
26   `pass` varchar(255) DEFAULT NULL,\r
27   `port` int(11) DEFAULT NULL,\r
28   `property1` varchar(255) DEFAULT NULL,\r
29   `property2` varchar(255) DEFAULT NULL,\r
30   `property3` varchar(255) DEFAULT NULL,\r
31   `db_type_id` varchar(255) NOT NULL,\r
32   PRIMARY KEY (`id`),\r
33   KEY `FK3njadtw43ieph7ftt4kxdhcko` (`db_type_id`),\r
34   CONSTRAINT `FK3njadtw43ieph7ftt4kxdhcko` FOREIGN KEY (`db_type_id`) REFERENCES `db_type` (`id`)\r
35 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
36 \r
37 CREATE TABLE `portal` (\r
38   `name` varchar(255) NOT NULL,\r
39   `enabled` bit(1) DEFAULT NULL,\r
40   `host` varchar(255) DEFAULT NULL,\r
41   `login` varchar(255) DEFAULT NULL,\r
42   `pass` varchar(255) DEFAULT NULL,\r
43   `port` int(11) DEFAULT NULL,\r
44   `related_db` int(11) DEFAULT NULL,\r
45   PRIMARY KEY (`name`),\r
46   KEY `FKtl6e8ydm1k7k9r5ukv9j0bd0n` (`related_db`),\r
47   CONSTRAINT `FKtl6e8ydm1k7k9r5ukv9j0bd0n` FOREIGN KEY (`related_db`) REFERENCES `db` (`id`)\r
48 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
49 \r
50 CREATE TABLE `design_type` (\r
51   `id` varchar(255) NOT NULL,\r
52   `name` varchar(255) DEFAULT NULL,\r
53   `note` varchar(255) DEFAULT NULL,\r
54   `db_type_id` varchar(255) NOT NULL,\r
55   `portal` varchar(255) DEFAULT NULL,\r
56   PRIMARY KEY (`id`),\r
57   KEY `FKm8rkv2qkq01gsmeq1c3y4w02x` (`db_type_id`),\r
58   KEY `FKs2nspbhf5wv5d152l4j69yjhi` (`portal`),\r
59   CONSTRAINT `FKm8rkv2qkq01gsmeq1c3y4w02x` FOREIGN KEY (`db_type_id`) REFERENCES `db_type` (`id`),\r
60   CONSTRAINT `FKs2nspbhf5wv5d152l4j69yjhi` FOREIGN KEY (`portal`) REFERENCES `portal` (`name`)\r
61 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
62 \r
63 CREATE TABLE `design` (\r
64   `id` int(11) NOT NULL AUTO_INCREMENT,\r
65   `body` varchar(255) DEFAULT NULL,\r
66   `name` varchar(255) DEFAULT NULL,\r
67   `note` varchar(255) DEFAULT NULL,\r
68   `submitted` bit(1) DEFAULT NULL,\r
69   `design_type_id` varchar(255) NOT NULL,\r
70   `topic_name_id` varchar(255) NOT NULL,\r
71   PRIMARY KEY (`id`),\r
72   KEY `FKo43yi6aputq6kwqqu8eqbspm5` (`design_type_id`),\r
73   KEY `FKabb8e74230glxpaiai4aqsr34` (`topic_name_id`),\r
74   CONSTRAINT `FKabb8e74230glxpaiai4aqsr34` FOREIGN KEY (`topic_name_id`) REFERENCES `topic_name` (`id`),\r
75   CONSTRAINT `FKo43yi6aputq6kwqqu8eqbspm5` FOREIGN KEY (`design_type_id`) REFERENCES `design_type` (`id`)\r
76 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
77 \r
78 CREATE TABLE `kafka` (\r
79   `id` int(11) NOT NULL AUTO_INCREMENT,\r
80   `broker_list` varchar(255) NOT NULL,\r
81   `consumer_count` int(11) DEFAULT 3,\r
82   `enabled` bit(1) NOT NULL,\r
83   `excluded_topic` varchar(1023) DEFAULT '__consumer_offsets,__transaction_state',\r
84   `group` varchar(255) DEFAULT 'datalake',\r
85   `included_topic` varchar(255) DEFAULT NULL,\r
86   `login` varchar(255) DEFAULT NULL,\r
87   `name` varchar(255) NOT NULL,\r
88   `pass` varchar(255) DEFAULT NULL,\r
89   `secure` bit(1) DEFAULT b'0',\r
90   `security_protocol` varchar(255) DEFAULT NULL,\r
91   `timeout_sec` int(11) DEFAULT 10,\r
92   `zk` varchar(255) NOT NULL,\r
93   PRIMARY KEY (`id`)\r
94 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
95 \r
96 CREATE TABLE `topic` (\r
97   `id` int(11) NOT NULL,\r
98   `aggregate_array_path` varchar(255) DEFAULT NULL,\r
99   `correlate_cleared_message` bit(1) NOT NULL DEFAULT b'0',\r
100   `data_format` varchar(255) DEFAULT NULL,\r
101   `enabled` bit(1) NOT NULL,\r
102   `flatten_array_path` varchar(255) DEFAULT NULL,\r
103   `login` varchar(255) DEFAULT NULL,\r
104   `message_id_path` varchar(255) DEFAULT NULL,\r
105   `pass` varchar(255) DEFAULT NULL,\r
106   `save_raw` bit(1) NOT NULL DEFAULT b'0',\r
107   `ttl_day` int(11) DEFAULT NULL,\r
108   `topic_name_id` varchar(255) NOT NULL,\r
109   PRIMARY KEY (`id`),\r
110   KEY `FKj3pldlfaokdhqjfva8n3pkjca` (`topic_name_id`),\r
111   CONSTRAINT `FKj3pldlfaokdhqjfva8n3pkjca` FOREIGN KEY (`topic_name_id`) REFERENCES `topic_name` (`id`)\r
112 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
113 \r
114 CREATE TABLE `map_db_design` (\r
115   `design_id` int(11) NOT NULL,\r
116   `db_id` int(11) NOT NULL,\r
117   PRIMARY KEY (`design_id`,`db_id`),\r
118   KEY `FKhpn49r94k05mancjtn301m2p0` (`db_id`),\r
119   CONSTRAINT `FKfli240v96cfjbnmjqc0fvvd57` FOREIGN KEY (`design_id`) REFERENCES `design` (`id`),\r
120   CONSTRAINT `FKhpn49r94k05mancjtn301m2p0` FOREIGN KEY (`db_id`) REFERENCES `db` (`id`)\r
121 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
122 \r
123 CREATE TABLE `map_db_topic` (\r
124   `topic_id` int(11) NOT NULL,\r
125   `db_id` int(11) NOT NULL,\r
126   PRIMARY KEY (`db_id`,`topic_id`),\r
127   KEY `FKq1jon185jnrr7dv1dd8214uw0` (`topic_id`),\r
128   CONSTRAINT `FKirro29ojp7jmtqx9m1qxwixcc` FOREIGN KEY (`db_id`) REFERENCES `db` (`id`),\r
129   CONSTRAINT `FKq1jon185jnrr7dv1dd8214uw0` FOREIGN KEY (`topic_id`) REFERENCES `topic` (`id`)\r
130 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
131 \r
132 CREATE TABLE `map_kafka_topic` (\r
133   `kafka_id` int(11) NOT NULL,\r
134   `topic_id` int(11) NOT NULL,\r
135   PRIMARY KEY (`topic_id`,`kafka_id`),\r
136   KEY `FKtdrme4h7rxfh04u2i2wqu23g5` (`kafka_id`),\r
137   CONSTRAINT `FK5q7jdxy54au5rcrhwa4a5igqi` FOREIGN KEY (`topic_id`) REFERENCES `topic` (`id`),\r
138   CONSTRAINT `FKtdrme4h7rxfh04u2i2wqu23g5` FOREIGN KEY (`kafka_id`) REFERENCES `kafka` (`id`)\r
139 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r