Changeset 5366a70920df98ecf37fed906dfe718d250c4ec1
- Timestamp:
- 07/02/08 18:29:43
(5 years ago)
- Author:
- Denish Patel <denish@omniti.com>
- git-committer:
- Denish Patel <denish@omniti.com> 1215023383 +0000
- git-parent:
[deeaea617276c3961438854251d49f293af8dd6d]
- git-author:
- Denish Patel <denish@omniti.com> 1215023383 +0000
- Message:
Exported Latest DDL dump
-
Files:
-
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
| r6390014 |
r5366a70 |
|
| 23 | 23 | |
|---|
| 24 | 24 | SET default_with_oids = false; |
|---|
| | 25 | |
|---|
| | 26 | -- |
|---|
| | 27 | -- Name: current_node_config; Type: TABLE; Schema: stratcon; Owner: stratcon; Tablespace: |
|---|
| | 28 | -- |
|---|
| | 29 | |
|---|
| | 30 | CREATE TABLE current_node_config ( |
|---|
| | 31 | remote_address inet NOT NULL, |
|---|
| | 32 | node_type text NOT NULL, |
|---|
| | 33 | whence timestamp with time zone NOT NULL, |
|---|
| | 34 | config xml NOT NULL |
|---|
| | 35 | ); |
|---|
| | 36 | |
|---|
| | 37 | |
|---|
| | 38 | ALTER TABLE stratcon.current_node_config OWNER TO stratcon; |
|---|
| | 39 | |
|---|
| | 40 | -- |
|---|
| | 41 | -- Name: current_node_config_changelog; Type: TABLE; Schema: stratcon; Owner: stratcon; Tablespace: |
|---|
| | 42 | -- |
|---|
| | 43 | |
|---|
| | 44 | CREATE TABLE current_node_config_changelog ( |
|---|
| | 45 | remote_address inet NOT NULL, |
|---|
| | 46 | node_type text NOT NULL, |
|---|
| | 47 | whence timestamp with time zone NOT NULL, |
|---|
| | 48 | config xml NOT NULL |
|---|
| | 49 | ); |
|---|
| | 50 | |
|---|
| | 51 | |
|---|
| | 52 | ALTER TABLE stratcon.current_node_config_changelog OWNER TO stratcon; |
|---|
| 25 | 53 | |
|---|
| 26 | 54 | -- |
|---|
| … | … | |
| 162 | 190 | rollup_time timestamp with time zone NOT NULL, |
|---|
| 163 | 191 | count_rows integer, |
|---|
| 164 | | avg_value numeric, |
|---|
| 165 | | min_value numeric, |
|---|
| 166 | | max_value numeric |
|---|
| | 192 | avg_value numeric |
|---|
| 167 | 193 | ); |
|---|
| 168 | 194 | |
|---|
| … | … | |
| 179 | 205 | rollup_time timestamp with time zone NOT NULL, |
|---|
| 180 | 206 | count_rows integer, |
|---|
| 181 | | avg_value numeric, |
|---|
| 182 | | min_value numeric, |
|---|
| 183 | | max_value numeric |
|---|
| | 207 | avg_value numeric |
|---|
| 184 | 208 | ); |
|---|
| 185 | 209 | |
|---|
| … | … | |
| 196 | 220 | rollup_time timestamp with time zone NOT NULL, |
|---|
| 197 | 221 | count_rows integer, |
|---|
| 198 | | avg_value numeric, |
|---|
| 199 | | min_value numeric, |
|---|
| 200 | | max_value numeric |
|---|
| | 222 | avg_value numeric |
|---|
| 201 | 223 | ); |
|---|
| 202 | 224 | |
|---|
| … | … | |
| 213 | 235 | rollup_time timestamp with time zone NOT NULL, |
|---|
| 214 | 236 | count_rows integer, |
|---|
| 215 | | avg_value numeric, |
|---|
| 216 | | min_value numeric, |
|---|
| 217 | | max_value numeric |
|---|
| | 237 | avg_value numeric |
|---|
| 218 | 238 | ); |
|---|
| 219 | 239 | |
|---|
| … | … | |
| 230 | 250 | rollup_time timestamp with time zone NOT NULL, |
|---|
| 231 | 251 | count_rows integer, |
|---|
| 232 | | avg_value numeric, |
|---|
| 233 | | min_value numeric, |
|---|
| 234 | | max_value numeric |
|---|
| | 252 | avg_value numeric |
|---|
| 235 | 253 | ); |
|---|
| 236 | 254 | |
|---|
| … | … | |
| 411 | 429 | |
|---|
| 412 | 430 | v_sql := 'select ' || v_sid || ' as sid, ' || quote_literal(in_name) || ' as name, ' || |
|---|
| 413 | | 's.rollup_time, d.count_rows, d.avg_value, ' || |
|---|
| 414 | | 'd.min_value, d.max_value ' || |
|---|
| | 431 | 's.rollup_time, d.count_rows, d.avg_value ' || |
|---|
| 415 | 432 | ' from ' || |
|---|
| 416 | 433 | '(select ' || quote_literal(v_start_adj) || '::timestamp' || |
|---|
| … | … | |
| 435 | 452 | v_r_rollup_row.avg_value := |
|---|
| 436 | 453 | (v_rollup_row.avg_value - v_l_rollup_row.avg_value) / v_interval; |
|---|
| 437 | | v_r_rollup_row.min_value := |
|---|
| 438 | | (v_rollup_row.min_value - v_l_rollup_row.min_value) / v_interval; |
|---|
| 439 | | v_r_rollup_row.max_value := |
|---|
| 440 | | (v_rollup_row.max_value - v_l_rollup_row.max_value) / v_interval; |
|---|
| 441 | 454 | else |
|---|
| 442 | 455 | v_r_rollup_row.count_rows = NULL; |
|---|
| 443 | 456 | v_r_rollup_row.avg_value = NULL; |
|---|
| 444 | | v_r_rollup_row.min_value = NULL; |
|---|
| 445 | | v_r_rollup_row.max_value = NULL; |
|---|
| | 457 | |
|---|
| 446 | 458 | end if; |
|---|
| 447 | 459 | else |
|---|
| … | … | |
| 594 | 606 | DECLARE |
|---|
| 595 | 607 | v_whence timestamptz; |
|---|
| | 608 | v_whence_5 timestamptz; |
|---|
| 596 | 609 | v_sid integer; |
|---|
| 597 | 610 | v_name text; |
|---|
| 598 | 611 | BEGIN |
|---|
| 599 | 612 | IF TG_OP = 'INSERT' THEN |
|---|
| 600 | | SELECT whence FROM stratcon.log_whence_s WHERE whence=date_trunc('H',NEW.WHENCE) + (round(extract('minute' from NEW.WHENCE)/5)*5) * '1 minute'::interval and interval='5 minutes' |
|---|
| | 613 | |
|---|
| | 614 | v_whence_5:=date_trunc('H',NEW.WHENCE) + (round(extract('minute' from NEW.WHENCE)/5)*5) * '1 minute'::interval; |
|---|
| | 615 | |
|---|
| | 616 | SELECT whence FROM stratcon.log_whence_s WHERE whence=v_whence_5 and interval='5 minutes' |
|---|
| 601 | 617 | INTO v_whence; |
|---|
| | 618 | |
|---|
| 602 | 619 | IF NOT FOUND THEN |
|---|
| 603 | | INSERT INTO stratcon.log_whence_s VALUES(date_trunc('H',NEW.WHENCE) + (round(extract('minute' from NEW.WHENCE)/5)*5) * '1 minute'::interval,'5 minutes'); |
|---|
| | 620 | BEGIN |
|---|
| | 621 | INSERT INTO stratcon.log_whence_s VALUES(v_whence_5,'5 minutes'); |
|---|
| | 622 | EXCEPTION |
|---|
| | 623 | WHEN UNIQUE_VIOLATION THEN |
|---|
| | 624 | -- do nothing |
|---|
| | 625 | END; |
|---|
| 604 | 626 | END IF; |
|---|
| 605 | 627 | |
|---|
| … | … | |
| 611 | 633 | |
|---|
| 612 | 634 | END IF; |
|---|
| 613 | | |
|---|
| 614 | 635 | RETURN NULL; |
|---|
| 615 | 636 | END |
|---|
| … | … | |
| 916 | 937 | |
|---|
| 917 | 938 | FOR rec IN |
|---|
| 918 | | SELECT sid,name,v_min_whence as rollup_time,SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value, |
|---|
| 919 | | MIN(min_value) as min_value ,MAX(max_value) as max_value |
|---|
| | 939 | SELECT sid,name,v_min_whence as rollup_time,SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value |
|---|
| 920 | 940 | FROM stratcon.rollup_matrix_numeric_6hours |
|---|
| 921 | 941 | WHERE rollup_time<= v_min_whence and rollup_time> v_min_whence-'12 hour'::interval |
|---|
| … | … | |
| 925 | 945 | |
|---|
| 926 | 946 | INSERT INTO stratcon.rollup_matrix_numeric_12hours |
|---|
| 927 | | (sid,name,rollup_time,count_rows,avg_value,min_value,max_value) VALUES |
|---|
| 928 | | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value,rec.min_value,rec.max_value); |
|---|
| | 947 | (sid,name,rollup_time,count_rows,avg_value) VALUES |
|---|
| | 948 | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value); |
|---|
| 929 | 949 | |
|---|
| 930 | 950 | END LOOP; |
|---|
| … | … | |
| 941 | 961 | |
|---|
| 942 | 962 | RETURN; |
|---|
| 943 | | |
|---|
| 944 | 963 | EXCEPTION |
|---|
| 945 | 964 | WHEN RAISE_EXCEPTION THEN |
|---|
| … | … | |
| 1021 | 1040 | FOR rec IN |
|---|
| 1022 | 1041 | SELECT sid , name,v_min_whence as rollup_time, |
|---|
| 1023 | | SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value, |
|---|
| 1024 | | MIN(min_value) as min_value ,MAX(max_value) as max_value |
|---|
| | 1042 | SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value |
|---|
| 1025 | 1043 | FROM stratcon.rollup_matrix_numeric_5m |
|---|
| 1026 | 1044 | WHERE rollup_time<= v_min_whence AND rollup_time > v_min_whence -'20 minutes'::interval |
|---|
| … | … | |
| 1031 | 1049 | |
|---|
| 1032 | 1050 | INSERT INTO stratcon.rollup_matrix_numeric_20m |
|---|
| 1033 | | (sid,name,rollup_time,count_rows,avg_value,min_value,max_value) VALUES |
|---|
| 1034 | | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value,rec.min_value,rec.max_value); |
|---|
| | 1051 | (sid,name,rollup_time,count_rows,avg_value) VALUES |
|---|
| | 1052 | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value); |
|---|
| 1035 | 1053 | |
|---|
| 1036 | 1054 | END LOOP; |
|---|
| … | … | |
| 1119 | 1137 | INSERT INTO stratcon.log_whence_s VALUES(date_trunc('H',v_min_whence) + (round(extract('minute' from v_min_whence)/20)*20) * '1 minute'::interval,'20 minutes'); |
|---|
| 1120 | 1138 | END IF; |
|---|
| 1121 | | |
|---|
| 1122 | 1139 | IF v_min_whence <= v_max_rollup_5 THEN |
|---|
| 1123 | 1140 | |
|---|
| … | … | |
| 1129 | 1146 | FOR rec IN |
|---|
| 1130 | 1147 | SELECT sid , name,v_min_whence as rollup_time, |
|---|
| 1131 | | COUNT(1) as count_rows ,AVG(value) as avg_value,MIN(value) as min_value ,MAX(value) as max_value |
|---|
| | 1148 | COUNT(1) as count_rows ,AVG(value) as avg_value |
|---|
| 1132 | 1149 | FROM stratcon.loading_dock_metric_numeric_s |
|---|
| 1133 | 1150 | WHERE WHENCE <= v_min_whence AND WHENCE > v_min_whence -'5 minutes'::interval |
|---|
| … | … | |
| 1138 | 1155 | |
|---|
| 1139 | 1156 | INSERT INTO stratcon.rollup_matrix_numeric_5m |
|---|
| 1140 | | (sid,name,rollup_time,count_rows,avg_value,min_value,max_value) VALUES |
|---|
| 1141 | | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value,rec.min_value,rec.max_value); |
|---|
| | 1157 | (sid,name,rollup_time,count_rows,avg_value) VALUES |
|---|
| | 1158 | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value); |
|---|
| 1142 | 1159 | |
|---|
| 1143 | 1160 | END LOOP; |
|---|
| … | … | |
| 1233 | 1250 | |
|---|
| 1234 | 1251 | FOR rec IN |
|---|
| 1235 | | SELECT sid,name,date_hour(rollup_time) as rollup_time,SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value, |
|---|
| 1236 | | MIN(min_value) as min_value ,MAX(max_value) as max_value |
|---|
| | 1252 | SELECT sid,name,date_hour(rollup_time) as rollup_time,SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value |
|---|
| 1237 | 1253 | FROM stratcon.rollup_matrix_numeric_20m |
|---|
| 1238 | 1254 | WHERE date_hour(rollup_time)= v_min_whence |
|---|
| … | … | |
| 1241 | 1257 | |
|---|
| 1242 | 1258 | INSERT INTO stratcon.rollup_matrix_numeric_60m |
|---|
| 1243 | | (sid,name,rollup_time,count_rows,avg_value,min_value,max_value) VALUES |
|---|
| 1244 | | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value,rec.min_value,rec.max_value); |
|---|
| | 1259 | (sid,name,rollup_time,count_rows,avg_value) VALUES |
|---|
| | 1260 | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value); |
|---|
| 1245 | 1261 | |
|---|
| 1246 | 1262 | END LOOP; |
|---|
| … | … | |
| 1260 | 1276 | EXCEPTION |
|---|
| 1261 | 1277 | WHEN RAISE_EXCEPTION THEN |
|---|
| 1262 | | UPDATE stratcon.rollup_runner SET RUNNER = '' WHERE ROLLUP_TABLE= 'rollup_matrix_numeric_60m'; |
|---|
| 1263 | 1278 | RAISE EXCEPTION '%', SQLERRM; |
|---|
| 1264 | 1279 | WHEN OTHERS THEN |
|---|
| … | … | |
| 1335 | 1350 | |
|---|
| 1336 | 1351 | FOR rec IN |
|---|
| 1337 | | SELECT sid,name,v_min_whence as rollup_time,SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value, |
|---|
| 1338 | | MIN(min_value) as min_value ,MAX(max_value) as max_value |
|---|
| | 1352 | SELECT sid,name,v_min_whence as rollup_time,SUM(count_rows) as count_rows ,(SUM(avg_value*count_rows)/SUM(count_rows)) as avg_value |
|---|
| 1339 | 1353 | FROM stratcon.rollup_matrix_numeric_60m |
|---|
| 1340 | 1354 | WHERE rollup_time<= v_min_whence and rollup_time> v_min_whence-'6 hour'::interval |
|---|
| … | … | |
| 1344 | 1358 | |
|---|
| 1345 | 1359 | INSERT INTO stratcon.rollup_matrix_numeric_6hours |
|---|
| 1346 | | (sid,name,rollup_time,count_rows,avg_value,min_value,max_value) VALUES |
|---|
| 1347 | | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value,rec.min_value,rec.max_value); |
|---|
| | 1360 | (sid,name,rollup_time,count_rows,avg_value) VALUES |
|---|
| | 1361 | (rec.sid,rec.name,rec.rollup_time,rec.count_rows,rec.avg_value); |
|---|
| | 1362 | |
|---|
| 1348 | 1363 | END LOOP; |
|---|
| 1349 | 1364 | |
|---|
| … | … | |
| 1361 | 1376 | EXCEPTION |
|---|
| 1362 | 1377 | WHEN RAISE_EXCEPTION THEN |
|---|
| 1363 | | UPDATE stratcon.rollup_runner SET RUNNER = '' WHERE ROLLUP_TABLE= 'rollup_matrix_numeric_6hours'; |
|---|
| 1364 | 1378 | RAISE EXCEPTION '%', SQLERRM; |
|---|
| 1365 | 1379 | WHEN OTHERS THEN |
|---|
| … | … | |
| 1373 | 1387 | |
|---|
| 1374 | 1388 | -- |
|---|
| | 1389 | -- Name: update_config(inet, text, timestamp with time zone, xml); Type: FUNCTION; Schema: stratcon; Owner: stratcon |
|---|
| | 1390 | -- |
|---|
| | 1391 | |
|---|
| | 1392 | CREATE FUNCTION update_config(v_remote_address_in inet, v_node_type_in text, v_whence_in timestamp with time zone, v_config_in xml) RETURNS void |
|---|
| | 1393 | AS $$ |
|---|
| | 1394 | DECLARE |
|---|
| | 1395 | v_config xml; |
|---|
| | 1396 | BEGIN |
|---|
| | 1397 | select config into v_config from stratcon.current_node_config |
|---|
| | 1398 | where remote_address = v_remote_address_in |
|---|
| | 1399 | and node_type = v_node_type_in; |
|---|
| | 1400 | IF FOUND THEN |
|---|
| | 1401 | IF v_config::text = v_config_in::text THEN |
|---|
| | 1402 | RETURN; |
|---|
| | 1403 | END IF; |
|---|
| | 1404 | delete from stratcon.current_node_config |
|---|
| | 1405 | where _address = v_remote_address_in |
|---|
| | 1406 | and node_type = v_node_type_in; |
|---|
| | 1407 | END IF; |
|---|
| | 1408 | insert into stratcon.current_node_config |
|---|
| | 1409 | (remote_address, node_type, whence, config) |
|---|
| | 1410 | values (v_remote_address_in, v_node_type_in, v_whence_in, v_config_in); |
|---|
| | 1411 | insert into stratcon.current_node_config_changelog |
|---|
| | 1412 | (remote_address, node_type, whence, config) |
|---|
| | 1413 | values (v_remote_address_in, v_node_type_in, v_whence_in, v_config_in); |
|---|
| | 1414 | END |
|---|
| | 1415 | $$ |
|---|
| | 1416 | LANGUAGE plpgsql; |
|---|
| | 1417 | |
|---|
| | 1418 | |
|---|
| | 1419 | ALTER FUNCTION stratcon.update_config(v_remote_address_in inet, v_node_type_in text, v_whence_in timestamp with time zone, v_config_in xml) OWNER TO stratcon; |
|---|
| | 1420 | |
|---|
| | 1421 | -- |
|---|
| 1375 | 1422 | -- Name: seq_sid; Type: SEQUENCE; Schema: stratcon; Owner: stratcon |
|---|
| 1376 | 1423 | -- |
|---|
| … | … | |
| 1386 | 1433 | |
|---|
| 1387 | 1434 | -- |
|---|
| | 1435 | -- Name: current_node_config_changelog_pkey; Type: CONSTRAINT; Schema: stratcon; Owner: stratcon; Tablespace: |
|---|
| | 1436 | -- |
|---|
| | 1437 | |
|---|
| | 1438 | ALTER TABLE ONLY current_node_config_changelog |
|---|
| | 1439 | ADD CONSTRAINT current_node_config_changelog_pkey PRIMARY KEY (remote_address, node_type, whence); |
|---|
| | 1440 | |
|---|
| | 1441 | |
|---|
| | 1442 | -- |
|---|
| | 1443 | -- Name: current_node_config_pkey; Type: CONSTRAINT; Schema: stratcon; Owner: stratcon; Tablespace: |
|---|
| | 1444 | -- |
|---|
| | 1445 | |
|---|
| | 1446 | ALTER TABLE ONLY current_node_config |
|---|
| | 1447 | ADD CONSTRAINT current_node_config_pkey PRIMARY KEY (remote_address, node_type); |
|---|
| | 1448 | |
|---|
| | 1449 | |
|---|
| | 1450 | -- |
|---|
| 1388 | 1451 | -- Name: loading_dock_check_s_pkey; Type: CONSTRAINT; Schema: stratcon; Owner: omniti; Tablespace: |
|---|
| 1389 | 1452 | -- |
|---|
| … | … | |
| 1464 | 1527 | ADD CONSTRAINT rollup_matrix_numeric_12hours_pkey PRIMARY KEY (rollup_time, sid, name); |
|---|
| 1465 | 1528 | |
|---|
| | 1529 | ALTER TABLE rollup_matrix_numeric_12hours CLUSTER ON rollup_matrix_numeric_12hours_pkey; |
|---|
| | 1530 | |
|---|
| 1466 | 1531 | |
|---|
| 1467 | 1532 | -- |
|---|
| … | … | |
| 1472 | 1537 | ADD CONSTRAINT rollup_matrix_numeric_20m_new_pkey PRIMARY KEY (rollup_time, sid, name); |
|---|
| 1473 | 1538 | |
|---|
| | 1539 | ALTER TABLE rollup_matrix_numeric_20m CLUSTER ON rollup_matrix_numeric_20m_new_pkey; |
|---|
| | 1540 | |
|---|
| 1474 | 1541 | |
|---|
| 1475 | 1542 | -- |
|---|
| … | … | |
| 1480 | 1547 | ADD CONSTRAINT rollup_matrix_numeric_5m_pkey PRIMARY KEY (rollup_time, sid, name); |
|---|
| 1481 | 1548 | |
|---|
| | 1549 | ALTER TABLE rollup_matrix_numeric_5m CLUSTER ON rollup_matrix_numeric_5m_pkey; |
|---|
| | 1550 | |
|---|
| 1482 | 1551 | |
|---|
| 1483 | 1552 | -- |
|---|
| … | … | |
| 1488 | 1557 | ADD CONSTRAINT rollup_matrix_numeric_60m_pkey PRIMARY KEY (rollup_time, sid, name); |
|---|
| 1489 | 1558 | |
|---|
| | 1559 | ALTER TABLE rollup_matrix_numeric_60m CLUSTER ON rollup_matrix_numeric_60m_pkey; |
|---|
| | 1560 | |
|---|
| 1490 | 1561 | |
|---|
| 1491 | 1562 | -- |
|---|
| … | … | |
| 1495 | 1566 | ALTER TABLE ONLY rollup_matrix_numeric_6hours |
|---|
| 1496 | 1567 | ADD CONSTRAINT rollup_matrix_numeric_6hours_pkey PRIMARY KEY (rollup_time, sid, name); |
|---|
| | 1568 | |
|---|
| | 1569 | ALTER TABLE rollup_matrix_numeric_6hours CLUSTER ON rollup_matrix_numeric_6hours_pkey; |
|---|
| 1497 | 1570 | |
|---|
| 1498 | 1571 | |
|---|