DROP TRIGGER IF EXISTS trigger_flag ON osm_island_point; DROP TRIGGER IF EXISTS trigger_refresh ON place_island_point.updates; -- etldoc: osm_island_point -> osm_island_point CREATE OR REPLACE FUNCTION update_osm_island_point() RETURNS VOID AS $$ BEGIN UPDATE osm_island_point SET tags = update_tags(tags, geometry) WHERE COALESCE(tags->'name:latin', tags->'name:nonlatin', tags->'name_int') IS NULL; END; $$ LANGUAGE plpgsql; SELECT update_osm_island_point(); -- Handle updates CREATE SCHEMA IF NOT EXISTS place_island_point; CREATE TABLE IF NOT EXISTS place_island_point.updates(id serial primary key, t text, unique (t)); CREATE OR REPLACE FUNCTION place_island_point.flag() RETURNS trigger AS $$ BEGIN INSERT INTO place_island_point.updates(t) VALUES ('y') ON CONFLICT(t) DO NOTHING; RETURN null; END; $$ language plpgsql; CREATE OR REPLACE FUNCTION place_island_point.refresh() RETURNS trigger AS $BODY$ BEGIN RAISE LOG 'Refresh place_island_point'; PERFORM update_osm_island_point(); DELETE FROM place_island_point.updates; RETURN null; END; $BODY$ language plpgsql; CREATE TRIGGER trigger_flag AFTER INSERT OR UPDATE OR DELETE ON osm_island_point FOR EACH STATEMENT EXECUTE PROCEDURE place_island_point.flag(); CREATE CONSTRAINT TRIGGER trigger_refresh AFTER INSERT ON place_island_point.updates INITIALLY DEFERRED FOR EACH ROW EXECUTE PROCEDURE place_island_point.refresh();