From 1df806ba44f85df74aa1361f91dfac120d2f2d21 Mon Sep 17 00:00:00 2001
From: Lukas Martinelli <me@lukasmartinelli.ch>
Date: Mon, 16 Jan 2017 16:23:22 +0100
Subject: [PATCH] Merge NE marine rank

---
 layers/water_name/mapping.yaml          |  3 ++
 layers/water_name/merge_marine_rank.sql | 61 +++++++++++++++++++++++++
 layers/water_name/water_name.yaml       |  1 +
 3 files changed, 65 insertions(+)
 create mode 100644 layers/water_name/merge_marine_rank.sql

diff --git a/layers/water_name/mapping.yaml b/layers/water_name/mapping.yaml
index c1d35cc..15476d8 100644
--- a/layers/water_name/mapping.yaml
+++ b/layers/water_name/mapping.yaml
@@ -16,6 +16,9 @@ tables:
     - name: place
       key: place
       type: string
+    - name: rank
+      key: rank
+      type: integer
     filters:
       exclude_tags:
       - [ "name", "__nil__" ]
diff --git a/layers/water_name/merge_marine_rank.sql b/layers/water_name/merge_marine_rank.sql
new file mode 100644
index 0000000..45566cf
--- /dev/null
+++ b/layers/water_name/merge_marine_rank.sql
@@ -0,0 +1,61 @@
+DROP TRIGGER IF EXISTS trigger_flag ON osm_marine_point;
+DROP TRIGGER IF EXISTS trigger_refresh ON water_name_marine.updates;
+
+CREATE EXTENSION IF NOT EXISTS unaccent;
+
+CREATE OR REPLACE FUNCTION update_osm_marine_point() RETURNS VOID AS $$
+BEGIN
+  -- etldoc: osm_marine_point          -> osm_marine_point 
+  UPDATE osm_marine_point AS osm SET "rank" = NULL WHERE "rank" IS NOT NULL;
+
+  -- etldoc: ne_10m_geography_marine_polys -> osm_marine_point
+  -- etldoc: osm_marine_point              -> osm_marine_point
+
+  WITH important_marine_point AS (
+      SELECT osm.geometry, osm.osm_id, osm.name, osm.name_en, ne.scalerank
+      FROM ne_10m_geography_marine_polys AS ne, osm_marine_point AS osm
+      WHERE ne.name ILIKE osm.name
+  )
+  UPDATE osm_marine_point AS osm
+  SET "rank" = scalerank
+  FROM important_marine_point AS ne
+  WHERE osm.osm_id = ne.osm_id;
+END;
+$$ LANGUAGE plpgsql;
+
+SELECT update_osm_marine_point();
+
+CREATE INDEX IF NOT EXISTS osm_marine_point_rank_idx ON osm_marine_point("rank");
+
+-- Handle updates
+CREATE SCHEMA IF NOT EXISTS water_name_marine;
+
+CREATE TABLE IF NOT EXISTS water_name_marine.updates(id serial primary key, t text, unique (t));
+CREATE OR REPLACE FUNCTION water_name_marine.flag() RETURNS trigger AS $$
+BEGIN
+    INSERT INTO water_name_marine.updates(t) VALUES ('y')  ON CONFLICT(t) DO NOTHING;
+    RETURN null;
+END;    
+$$ language plpgsql;
+
+CREATE OR REPLACE FUNCTION water_name_marine.refresh() RETURNS trigger AS
+  $BODY$
+  BEGIN
+    RAISE LOG 'Refresh water_name_marine rank';
+    PERFORM update_osm_marine_point();
+    DELETE FROM water_name_marine.updates;
+    RETURN null;
+  END;
+  $BODY$
+language plpgsql;
+
+CREATE TRIGGER trigger_flag
+    AFTER INSERT OR UPDATE OR DELETE ON osm_marine_point
+    FOR EACH STATEMENT
+    EXECUTE PROCEDURE water_name_marine.flag();
+
+CREATE CONSTRAINT TRIGGER trigger_refresh
+    AFTER INSERT ON water_name_marine.updates
+    INITIALLY DEFERRED
+    FOR EACH ROW
+    EXECUTE PROCEDURE water_name_marine.refresh();
diff --git a/layers/water_name/water_name.yaml b/layers/water_name/water_name.yaml
index 33bff0b..ab9da59 100644
--- a/layers/water_name/water_name.yaml
+++ b/layers/water_name/water_name.yaml
@@ -19,6 +19,7 @@ layer:
     srid: 900913
     query: (SELECT geometry, name, name_en, class FROM layer_water_name(!bbox!, z(!scale_denominator!))) AS t
 schema:
+  - ./merge_marine_rank.sql
   - ./water_lakeline.sql
   - ./water_point.sql
   - ./layer.sql