Flatten and Aggregate features in JSON array processing
[dcaegen2/services.git] / components / datalake-handler / feeder / src / assembly / scripts / init_db.sql
1 create database datalake;\r
2 use datalake;\r
3 \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 0,\r
8   `login` varchar(255) DEFAULT NULL,\r
9   `message_id_path` varchar(255) DEFAULT NULL,\r
10   `aggregate_array_path` varchar(2000) DEFAULT NULL,\r
11   `flatten_array_path` varchar(2000) DEFAULT NULL,\r
12   `pass` varchar(255) DEFAULT NULL,\r
13   `save_raw` bit(1) DEFAULT NULL,\r
14   `ttl` int(11) DEFAULT NULL,\r
15   `data_format` varchar(255) DEFAULT NULL,\r
16   PRIMARY KEY (`name`)\r
17 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
18 \r
19 \r
20 CREATE TABLE `db` (\r
21   `name` varchar(255) NOT NULL,\r
22   `enabled` bit(1) DEFAULT 0,\r
23   `host` varchar(255) DEFAULT NULL,\r
24   `port` int(11) DEFAULT NULL,\r
25   `database_name` 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
34 \r
35 \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
44 \r
45 CREATE TABLE `portal` (\r
46   `name` varchar(255) NOT NULL DEFAULT '',\r
47   `enabled` bit(1) DEFAULT 0,\r
48   `host` varchar(500) DEFAULT NULL,\r
49   `port` int(5) unsigned DEFAULT NULL,\r
50   `login` varchar(255) DEFAULT NULL,\r
51   `pass` varchar(255) DEFAULT NULL,\r
52   `related_db` varchar(255) DEFAULT NULL,\r
53   PRIMARY KEY (`name`),\r
54   KEY `FK_related_db` (`related_db`),\r
55   CONSTRAINT `FK_related_db` FOREIGN KEY (`related_db`) REFERENCES `db` (`name`) ON DELETE SET NULL\r
56 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
57 \r
58 CREATE TABLE `design_type` (\r
59   `name` varchar(255) NOT NULL,\r
60   `portal` varchar(255) DEFAULT NULL,\r
61   `note` text DEFAULT NULL,\r
62   PRIMARY KEY (`name`),\r
63   KEY `FK_portal` (`portal`),\r
64   CONSTRAINT `FK_portal` FOREIGN KEY (`portal`) REFERENCES `portal` (`name`) ON DELETE SET NULL\r
65 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
66 \r
67 CREATE TABLE `portal_design` (\r
68   `id` int(11) unsigned NOT NULL AUTO_INCREMENT,\r
69   `name` varchar(255) NOT NULL,\r
70   `submitted` bit(1) DEFAULT 0,\r
71   `body` text DEFAULT NULL,\r
72   `note` text DEFAULT NULL,\r
73   `topic` varchar(255) DEFAULT NULL,\r
74   `type` varchar(255) DEFAULT NULL,\r
75   PRIMARY KEY (`id`),\r
76   KEY `FK_topic` (`topic`),\r
77   KEY `FK_type` (`type`),\r
78   CONSTRAINT `FK_topic` FOREIGN KEY (`topic`) REFERENCES `topic` (`name`) ON DELETE SET NULL,\r
79   CONSTRAINT `FK_type` FOREIGN KEY (`type`) REFERENCES `design_type` (`name`) ON DELETE SET NULL\r
80 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;\r
81 \r
82 insert into db (`name`,`host`,`login`,`pass`,`database_name`) values ('Couchbase','dl_couchbase','dl','dl1234','datalake');\r
83 insert into db (`name`,`host`) values ('Elasticsearch','dl_es');\r
84 insert into db (`name`,`host`,`port`,`database_name`) values ('MongoDB','dl_mongodb',27017,'datalake');\r
85 insert into db (`name`,`host`) values ('Druid','dl_druid');\r
86 insert into db (`name`,`host`,`login`) values ('HDFS','dlhdfs','dl');\r
87 \r
88 \r
89 -- in production, default enabled should be off\r
90 insert into `topic`(`name`,`enabled`,`save_raw`,`ttl`,`data_format`) values ('_DL_DEFAULT_',1,0,3650,'JSON');\r
91 insert into `topic`(`name`,correlate_cleared_message,`enabled`, message_id_path,`data_format`) values ('unauthenticated.SEC_FAULT_OUTPUT',1,1,'/event/commonEventHeader/eventName,/event/commonEventHeader/reportingEntityName,/event/faultFields/specificProblem,/event/commonEventHeader/eventId','JSON');\r
92 insert into `topic`(`name`,`enabled`, aggregate_array_path,flatten_array_path,`data_format`) \r
93 values ('unauthenticated.VES_MEASUREMENT_OUTPUT',1,\r
94 '/event/measurementsForVfScalingFields/diskUsageArray,/event/measurementsForVfScalingFields/cpuUsageArray,/event/measurementsForVfScalingFields/vNicPerformanceArray',\r
95 '/event/measurementsForVfScalingFields/astriMeasurement/astriDPMeasurementArray/astriInterface',\r
96 'JSON');\r
97 \r
98 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Couchbase','_DL_DEFAULT_');\r
99 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Elasticsearch','_DL_DEFAULT_');\r
100 insert into `map_db_topic`(`db_name`,`topic_name`) values ('MongoDB','_DL_DEFAULT_');\r
101 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Druid','_DL_DEFAULT_');\r
102 insert into `map_db_topic`(`db_name`,`topic_name`) values ('HDFS','_DL_DEFAULT_');\r
103 \r
104 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Couchbase','unauthenticated.SEC_FAULT_OUTPUT');\r
105 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Elasticsearch','unauthenticated.SEC_FAULT_OUTPUT');\r
106 insert into `map_db_topic`(`db_name`,`topic_name`) values ('MongoDB','unauthenticated.SEC_FAULT_OUTPUT');\r
107 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Druid','unauthenticated.SEC_FAULT_OUTPUT');\r
108 insert into `map_db_topic`(`db_name`,`topic_name`) values ('HDFS','unauthenticated.SEC_FAULT_OUTPUT');\r
109 \r
110 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Couchbase','unauthenticated.VES_MEASUREMENT_OUTPUT');\r
111 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Elasticsearch','unauthenticated.VES_MEASUREMENT_OUTPUT');\r
112 insert into `map_db_topic`(`db_name`,`topic_name`) values ('MongoDB','unauthenticated.VES_MEASUREMENT_OUTPUT');\r
113 insert into `map_db_topic`(`db_name`,`topic_name`) values ('Druid','unauthenticated.VES_MEASUREMENT_OUTPUT');\r
114 insert into `map_db_topic`(`db_name`,`topic_name`) values ('HDFS','unauthenticated.VES_MEASUREMENT_OUTPUT');\r
115 \r
116 insert into portal (`name`,`related_db`, host) values ('Kibana', 'Elasticsearch', 'dl_es');\r
117 insert into portal (`name`,`related_db`) values ('Elasticsearch', 'Elasticsearch');\r
118 insert into portal (`name`,`related_db`) values ('Druid', 'Druid');\r
119 \r
120 insert into design_type (`name`,`portal`) values ('Kibana Dashboard', 'Kibana');\r
121 insert into design_type (`name`,`portal`) values ('Kibana Search', 'Kibana');\r
122 insert into design_type (`name`,`portal`) values ('Kibana Visualization', 'Kibana');\r
123 insert into design_type (`name`,`portal`) values ('Elasticsearch Field Mapping Template', 'Elasticsearch');\r
124 insert into design_type (`name`,`portal`) values ('Druid Kafka Indexing Service Supervisor', 'Druid');\r
125 \r