Merge pull request #326 from akrherz/taf_domain

260305

Author: akrherz

.sqlfluff

@@ -1,3 +1,5 @@
 [sqlfluff]
-dialect = "postgres"
+dialect = postgres
 large_file_skip_byte_limit = 0
+exclude_rules = RF04, LT05
+ignore = data/*, upgrade/*

.sqlfluffignore

@@ -1,25 +1,25 @@
-
 -- Boilerplate IEM schema_manager_version, the version gets incremented each
 -- time we make an upgrade script
-CREATE TABLE iem_schema_manager_version(
+CREATE TABLE iem_schema_manager_version (
     version int,
-    updated timestamptz);
-INSERT into iem_schema_manager_version values (10, now());
+    updated timestamptz
+);
+INSERT INTO iem_schema_manager_version VALUES (10, now());
 
-CREATE TABLE products(
+CREATE TABLE products (
     data text,
-    pil char(6) not null,
+    pil char(6) NOT NULL,
     entered timestamptz,
     source char(4),
     wmo char(6),
     bbb varchar(3)
-) PARTITION by RANGE (entered);
-ALTER TABLE products OWNER to mesonet;
-GRANT ALL on products to ldm;
-GRANT SELECT on products to nobody;
+) PARTITION BY RANGE (entered);
+ALTER TABLE products OWNER TO mesonet;
+GRANT ALL ON products TO ldm;
+GRANT SELECT ON products TO nobody;
 
 
-do
+DO
 $do$
 declare
      year int;

init/afos.sql

@@ -240,7 +240,9 @@ $do$;
 CREATE TABLE taf (
     id serial UNIQUE,
     station char(4),
-    valid timestamptz, -- noqa
+    valid timestamptz,
+    issue timestamptz,
+    expire timestamptz,
     product_id varchar(35),
     is_amendment boolean
 );

init/asos.sql

@@ -1,95 +1,104 @@
 CREATE EXTENSION postgis;
 
 -- bandaid
-insert into spatial_ref_sys select 9311, 'EPSG', 9311, srtext, proj4text from spatial_ref_sys where srid = 2163;
+INSERT INTO spatial_ref_sys
+SELECT
+    9311 AS srid,
+    'EPSG' AS auth_name,
+    9311 AS auth_srid,
+    srtext,
+    proj4text
+FROM spatial_ref_sys
+WHERE srid = 2163;
 
 -- Boilerplate IEM schema_manager_version, the version gets incremented each
 -- time we make an upgrade script
-CREATE TABLE iem_schema_manager_version(
-	version int,
-	updated timestamptz);
-INSERT into iem_schema_manager_version values (1, now());
+CREATE TABLE iem_schema_manager_version (
+    version int,
+    updated timestamptz
+);
+INSERT INTO iem_schema_manager_version VALUES (1, now());
 
 
 ---
 --- Quasi synced from mesosite database
 ---
-CREATE TABLE stations(
-	id varchar(64),
-	synop int,
-	name varchar(64),
-	state char(2),
-	country char(2),
-	elevation real,
-	network varchar(20),
-	online boolean,
-	params varchar(300),
-	county varchar(50),
-	plot_name varchar(64),
-	climate_site varchar(6),
-	remote_id int,
-	nwn_id int,
-	spri smallint,
-	wfo varchar(3),
-	archive_begin date,
-	archive_end date,
-	modified timestamp with time zone,
-	tzname varchar(32),
-	iemid SERIAL,
-	metasite boolean,
-	sigstage_low real,
-	sigstage_action real,
-	sigstage_bankfull real,
-	sigstage_flood real,
-	sigstage_moderate real,
-	sigstage_major real,
-	sigstage_record real,
-	ugc_county char(6),
-	ugc_zone char(6),
-	ncdc81 varchar(11),
+CREATE TABLE stations (
+    id varchar(64),
+    synop int,
+    name varchar(64),
+    state char(2),
+    country char(2),
+    elevation real,
+    network varchar(20),
+    online boolean,
+    params varchar(300),
+    county varchar(50),
+    plot_name varchar(64),
+    climate_site varchar(6),
+    remote_id int,
+    nwn_id int,
+    spri smallint,
+    wfo varchar(3),
+    archive_begin date,
+    archive_end date,
+    modified timestamp with time zone,
+    tzname varchar(32),
+    iemid serial,
+    metasite boolean,
+    sigstage_low real,
+    sigstage_action real,
+    sigstage_bankfull real,
+    sigstage_flood real,
+    sigstage_moderate real,
+    sigstage_major real,
+    sigstage_record real,
+    ugc_county char(6),
+    ugc_zone char(6),
+    ncdc81 varchar(11),
     ncei91 varchar(11),
-	temp24_hour smallint,
-	precip24_hour smallint,
-	wigos varchar(64)
+    temp24_hour smallint,
+    precip24_hour smallint,
+    wigos varchar(64)
 );
-ALTER TABLE stations OWNER to mesonet;
-CREATE UNIQUE index stations_idx on stations(id, network);
-create UNIQUE index stations_iemid_idx on stations(iemid);
-SELECT AddGeometryColumn('stations', 'geom', 4326, 'POINT', 2);
-GRANT SELECT on stations to nobody;
-grant all on stations_iemid_seq to nobody;
-GRANT ALL on stations to mesonet,ldm;
-GRANT ALL on stations_iemid_seq to mesonet,ldm;
+ALTER TABLE stations OWNER TO mesonet;
+CREATE UNIQUE INDEX stations_idx ON stations (id, network);
+CREATE UNIQUE INDEX stations_iemid_idx ON stations (iemid);
+SELECT addgeometrycolumn('stations', 'geom', 4326, 'POINT', 2);
+GRANT SELECT ON stations TO nobody;
+GRANT ALL ON stations_iemid_seq TO nobody;
+GRANT ALL ON stations TO mesonet, ldm;
+GRANT ALL ON stations_iemid_seq TO mesonet, ldm;
 
 ---
 --- One Minute ASOS data
 ---
-CREATE TABLE alldata_1minute(
-  station varchar(4),
-  valid timestamptz,
-  vis1_coeff real,
-  vis1_nd char(1),
-  vis2_coeff real,
-  vis2_nd char(1),
-  vis3_coeff real,
-  vis3_nd char(1),
-  drct smallint,
-  sknt smallint,
-  gust_drct smallint,
-  gust_sknt smallint,
-  ptype char(2),
-  precip real,
-  pres1 real,
-  pres2 real,
-  pres3 real,
-  tmpf smallint,
-  dwpf smallint
-) PARTITION by range(valid);
-ALTER TABLE alldata_1minute OWNER to mesonet;
-GRANT ALL on alldata_1minute to ldm;
-GRANT SELECT on alldata_1minute to nobody;
+CREATE TABLE alldata_1minute (
+    station varchar(4),
+    valid timestamptz,
+    vis1_coeff real,
+    vis1_nd char(1),
+    vis2_coeff real,
+    vis2_nd char(1),
+    vis3_coeff real,
+    vis3_nd char(1),
+    drct smallint,
+    sknt smallint,
+    gust_drct smallint,
+    gust_sknt smallint,
+    ptype char(2),
+    precip real,
+    pres1 real,
+    pres2 real,
+    pres3 real,
+    tmpf smallint,
+    dwpf smallint
+) PARTITION BY RANGE (valid);
+ALTER TABLE alldata_1minute OWNER TO mesonet;
+GRANT ALL ON alldata_1minute TO ldm;
+GRANT SELECT ON alldata_1minute TO nobody;
 
-do
+DO
 $do$
 declare
      year int;

init/asos1min.sql

@@ -1,15 +1,15 @@
-
 -- Boilerplate IEM schema_manager_version, the version gets incremented each
 -- time we make an upgrade script
-CREATE TABLE iem_schema_manager_version(
+CREATE TABLE iem_schema_manager_version (
     version int,
-    updated timestamptz);
-INSERT into iem_schema_manager_version values (0, now());
+    updated timestamptz
+);
+INSERT INTO iem_schema_manager_version VALUES (0, now());
 
 ---
 --- Main table that all children inherit from
 ---
-CREATE TABLE alldata(
+CREATE TABLE alldata (
     station varchar(5),
     valid timestamptz,
     tmpf smallint,
@@ -27,12 +27,12 @@ CREATE TABLE alldata(
     vsby real,
     alti real,
     qc varchar(5)
-) PARTITION by range(valid);
-ALTER TABLE alldata OWNER to mesonet;
-GRANT ALL on alldata to ldm;
-GRANT SELECT on alldata to nobody;
+) PARTITION BY RANGE (valid);
+ALTER TABLE alldata OWNER TO mesonet;
+GRANT ALL ON alldata TO ldm;
+GRANT SELECT ON alldata TO nobody;
 
-do
+DO
 $do$
 declare
      year int;