]> git.openstreetmap.org Git - nominatim.git/blob - lib-sql/functions/place_triggers.sql
add type annotations to config module
[nominatim.git] / lib-sql / functions / place_triggers.sql
1 -- SPDX-License-Identifier: GPL-2.0-only
2 --
3 -- This file is part of Nominatim. (https://nominatim.org)
4 --
5 -- Copyright (C) 2022 by the Nominatim developer community.
6 -- For a full list of authors see the git log.
7
8 CREATE OR REPLACE FUNCTION place_insert()
9   RETURNS TRIGGER
10   AS $$
11 DECLARE
12   i INTEGER;
13   country RECORD;
14   existing RECORD;
15   existingplacex RECORD;
16   existingline BIGINT[];
17   interpol RECORD;
18 BEGIN
19   {% if debug %}
20     RAISE WARNING 'place_insert: % % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type,st_area(NEW.geometry);
21   {% endif %}
22
23   -- Filter tuples with bad geometries.
24   IF ST_IsEmpty(NEW.geometry) OR NOT ST_IsValid(NEW.geometry) THEN
25     INSERT INTO import_polygon_error (osm_type, osm_id, class, type, name,
26                                       country_code, updated, errormessage,
27                                       prevgeometry, newgeometry)
28       VALUES (NEW.osm_type, NEW.osm_id, NEW.class, NEW.type, NEW.name,
29               NEW.address->'country', now(), ST_IsValidReason(NEW.geometry),
30               null, NEW.geometry);
31     {% if debug %}
32       RAISE WARNING 'Invalid Geometry: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
33     {% endif %}
34     RETURN null;
35   END IF;
36
37   -- Have we already done this place?
38   SELECT * INTO existing
39     FROM place
40     WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
41           and class = NEW.class and type = NEW.type;
42
43   {% if debug %}RAISE WARNING 'Existing: %',existing.osm_id;{% endif %}
44
45   -- Handle a place changing type by removing the old data.
46   -- (This trigger is executed BEFORE INSERT of the NEW tuple.)
47   IF existing.osm_type IS NULL THEN
48     DELETE FROM place where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class;
49   END IF;
50
51   -- Remove any old logged data.
52   DELETE from import_polygon_error where osm_type = NEW.osm_type and osm_id = NEW.osm_id;
53   DELETE from import_polygon_delete where osm_type = NEW.osm_type and osm_id = NEW.osm_id;
54
55   -- ---- Interpolation Lines
56
57   IF NEW.class='place' and NEW.type='houses'
58      and NEW.osm_type='W' and ST_GeometryType(NEW.geometry) = 'ST_LineString'
59   THEN
60     PERFORM reinsert_interpolation(NEW.osm_id, NEW.address, NEW.geometry);
61
62     -- Now invalidate all address nodes on the line.
63     -- They get their parent from the interpolation.
64     UPDATE placex p SET indexed_status = 2
65       FROM planet_osm_ways w
66       WHERE w.id = NEW.osm_id and p.osm_type = 'N' and p.osm_id = any(w.nodes);
67
68     -- If there is already an entry in place, just update that, if necessary.
69     IF existing.osm_type is not null THEN
70       IF coalesce(existing.address, ''::hstore) != coalesce(NEW.address, ''::hstore)
71          OR existing.geometry::text != NEW.geometry::text
72       THEN
73         UPDATE place
74           SET name = NEW.name,
75               address = NEW.address,
76               extratags = NEW.extratags,
77               admin_level = NEW.admin_level,
78               geometry = NEW.geometry
79           WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
80                 and class = NEW.class and type = NEW.type;
81        END IF;
82
83        RETURN NULL;
84     END IF;
85
86     RETURN NEW;
87   END IF;
88
89   -- ---- Postcode points.
90
91   IF NEW.class = 'place' AND NEW.type = 'postcode' THEN
92     -- Pure postcodes are never queried from placex so we don't add them.
93     -- location_postcodes is filled from the place table directly.
94
95     -- Remove any old placex entry.
96     DELETE FROM placex WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id;
97
98     IF existing.osm_type IS NOT NULL THEN
99       IF coalesce(existing.address, ''::hstore) != coalesce(NEW.address, ''::hstore)
100          OR existing.geometry::text != NEW.geometry::text
101       THEN
102         UPDATE place
103           SET name = NEW.name,
104               address = NEW.address,
105               extratags = NEW.extratags,
106               admin_level = NEW.admin_level,
107               geometry = NEW.geometry
108           WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
109                 and class = NEW.class and type = NEW.type;
110       END IF;
111
112       RETURN NULL;
113     END IF;
114
115     RETURN NEW;
116   END IF;
117
118   -- ---- All other place types.
119
120   -- When an area is changed from large to small: log and discard change
121   IF existing.geometry is not null AND ST_IsValid(existing.geometry)
122     AND ST_Area(existing.geometry) > 0.02
123     AND ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon')
124     AND ST_Area(NEW.geometry) < ST_Area(existing.geometry) * 0.5
125   THEN
126     INSERT INTO import_polygon_error (osm_type, osm_id, class, type, name,
127                                       country_code, updated, errormessage,
128                                       prevgeometry, newgeometry)
129       VALUES (NEW.osm_type, NEW.osm_id, NEW.class, NEW.type, NEW.name,
130               NEW.address->'country', now(),
131               'Area reduced from '||st_area(existing.geometry)||' to '||st_area(NEW.geometry),
132               existing.geometry, NEW.geometry);
133
134     RETURN null;
135   END IF;
136
137   -- If an address node is part of a interpolation line and changes or is
138   -- newly inserted (happens when the node already existed but now gets address
139   -- information), then mark the interpolation line for reparenting.
140   -- (Already here, because interpolation lines are reindexed before nodes,
141   --  so in the second call it would be too late.)
142   IF NEW.osm_type='N'
143      and coalesce(existing.address, ''::hstore) != coalesce(NEW.address, ''::hstore)
144   THEN
145       FOR interpol IN
146         SELECT DISTINCT osm_id, address, geometry FROM place, planet_osm_ways w
147         WHERE NEW.geometry && place.geometry
148               and place.osm_type = 'W'
149               and place.address ? 'interpolation'
150               and exists (SELECT * FROM location_property_osmline
151                           WHERE osm_id = place.osm_id
152                                 and indexed_status in (0, 2))
153               and w.id = place.osm_id and NEW.osm_id = any (w.nodes)
154       LOOP
155         PERFORM reinsert_interpolation(interpol.osm_id, interpol.address,
156                                        interpol.geometry);
157       END LOOP;
158   END IF;
159
160   -- Get the existing placex entry.
161   SELECT * INTO existingplacex
162     FROM placex
163     WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
164           and class = NEW.class and type = NEW.type;
165
166   {% if debug %}RAISE WARNING 'Existing PlaceX: %',existingplacex.place_id;{% endif %}
167
168   -- To paraphrase: if there isn't an existing item, OR if the admin level has changed
169   IF existingplacex.osm_type IS NULL
170      or (existingplacex.class = 'boundary'
171          and ((coalesce(existingplacex.admin_level, 15) != coalesce(NEW.admin_level, 15)
172                and existingplacex.type = 'administrative')
173               or existingplacex.type != NEW.type))
174   THEN
175     {% if config.get_bool('LIMIT_REINDEXING') %}
176     -- sanity check: ignore admin_level changes on places with too many active children
177     -- or we end up reindexing entire countries because somebody accidentally deleted admin_level
178     IF existingplacex.osm_type IS NOT NULL THEN
179       SELECT count(*) INTO i FROM
180         (SELECT 'a' FROM placex, place_addressline
181           WHERE address_place_id = existingplacex.place_id
182                 and placex.place_id = place_addressline.place_id
183                 and indexed_status = 0 and place_addressline.isaddress LIMIT 100001) sub;
184       IF i > 100000 THEN
185         RETURN null;
186       END IF;
187     END IF;
188     {% endif %}
189
190     IF existing.osm_type IS NOT NULL THEN
191       -- Pathological case caused by the triggerless copy into place during initial import
192       -- force delete even for large areas, it will be reinserted later
193       UPDATE place SET geometry = ST_SetSRID(ST_Point(0,0), 4326)
194         WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
195               and class = NEW.class and type = NEW.type;
196       DELETE FROM place
197         WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
198               and class = NEW.class and type = NEW.type;
199     END IF;
200
201     -- Process it as a new insertion
202     INSERT INTO placex (osm_type, osm_id, class, type, name,
203                         admin_level, address, extratags, geometry)
204       VALUES (NEW.osm_type, NEW.osm_id, NEW.class, NEW.type, NEW.name,
205               NEW.admin_level, NEW.address, NEW.extratags, NEW.geometry);
206
207     {% if debug %}RAISE WARNING 'insert done % % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type,NEW.name;{% endif %}
208
209     RETURN NEW;
210   END IF;
211
212   -- Special case for polygon shape changes because they tend to be large
213   -- and we can be a bit clever about how we handle them
214   IF existing.geometry::text != NEW.geometry::text
215      AND ST_GeometryType(existing.geometry) in ('ST_Polygon','ST_MultiPolygon')
216      AND ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon')
217   THEN
218     -- Performance limit
219     IF ST_Area(NEW.geometry) < 0.000000001 AND ST_Area(existingplacex.geometry) < 1
220     THEN
221       -- re-index points that have moved in / out of the polygon.
222       -- Could be done as a single query but postgres gets the index usage wrong.
223       update placex set indexed_status = 2 where indexed_status = 0
224           AND ST_Intersects(NEW.geometry, placex.geometry)
225           AND NOT ST_Intersects(existingplacex.geometry, placex.geometry)
226           AND rank_search > existingplacex.rank_search AND (rank_search < 28 or name is not null);
227
228       update placex set indexed_status = 2 where indexed_status = 0
229           AND ST_Intersects(existingplacex.geometry, placex.geometry)
230           AND NOT ST_Intersects(NEW.geometry, placex.geometry)
231           AND rank_search > existingplacex.rank_search AND (rank_search < 28 or name is not null);
232     END IF;
233   END IF;
234
235
236   -- Has something relevant changed?
237   IF coalesce(existing.name::text, '') != coalesce(NEW.name::text, '')
238      OR coalesce(existing.extratags::text, '') != coalesce(NEW.extratags::text, '')
239      OR coalesce(existing.address, ''::hstore) != coalesce(NEW.address, ''::hstore)
240      OR coalesce(existing.admin_level, 15) != coalesce(NEW.admin_level, 15)
241      OR existing.geometry::text != NEW.geometry::text
242   THEN
243     UPDATE place
244       SET name = NEW.name,
245           address = NEW.address,
246           extratags = NEW.extratags,
247           admin_level = NEW.admin_level,
248           geometry = NEW.geometry
249       WHERE osm_type = NEW.osm_type and osm_id = NEW.osm_id
250             and class = NEW.class and type = NEW.type;
251
252     -- Postcode areas are only kept, when there is an actual postcode assigned.
253     IF NEW.class = 'boundary' AND NEW.type = 'postal_code' THEN
254       IF NEW.address is NULL OR NOT NEW.address ? 'postcode' THEN
255         -- postcode was deleted, no longer retain in placex
256         DELETE FROM placex where place_id = existingplacex.place_id;
257         RETURN NULL;
258       END IF;
259
260       NEW.name := hstore('ref', NEW.address->'postcode');
261     END IF;
262
263     -- Boundaries must be areas.
264     IF NEW.class in ('boundary')
265        AND ST_GeometryType(NEW.geometry) not in ('ST_Polygon','ST_MultiPolygon')
266     THEN
267       DELETE FROM placex where place_id = existingplacex.place_id;
268       RETURN NULL;
269     END IF;
270
271     -- Update the placex entry in-place.
272     UPDATE placex
273       SET name = NEW.name,
274           address = NEW.address,
275           parent_place_id = null,
276           extratags = NEW.extratags,
277           admin_level = NEW.admin_level,
278           indexed_status = 2,
279           geometry = NEW.geometry
280       WHERE place_id = existingplacex.place_id;
281
282     -- Invalidate linked places: they potentially get a new name and addresses.
283     IF existingplacex.linked_place_id is not NULL THEN
284       UPDATE placex x
285         SET name = p.name,
286             extratags = p.extratags,
287             indexed_status = 2
288         FROM place p
289         WHERE x.place_id = existingplacex.linked_place_id
290               and x.indexed_status = 0
291               and x.osm_type = p.osm_type
292               and x.osm_id = p.osm_id
293               and x.class = p.class;
294     END IF;
295
296     -- Invalidate dependent objects effected by name changes
297     IF coalesce(existing.name::text, '') != coalesce(NEW.name::text, '')
298     THEN
299       IF existingplacex.rank_address between 26 and 27 THEN
300         -- When streets change their name, this may have an effect on POI objects
301         -- with addr:street tags.
302         UPDATE placex SET indexed_status = 2
303           WHERE indexed_status = 0 and address ? 'street'
304                 and parent_place_id = existingplacex.place_id;
305         UPDATE placex SET indexed_status = 2
306           WHERE indexed_status = 0 and rank_search = 30 and address ? 'street'
307                 and ST_DWithin(NEW.geometry, geometry, 0.002);
308       ELSEIF existingplacex.rank_address between 16 and 25 THEN
309         -- When places change their name, this may have an effect on POI objects
310         -- with addr:place tags.
311         UPDATE placex SET indexed_status = 2
312           WHERE indexed_status = 0 and address ? 'place' and rank_search = 30
313                 and parent_place_id = existingplacex.place_id;
314         -- No update of surrounding objects, potentially too expensive.
315       END IF;
316     END IF;
317   END IF;
318
319   -- Abort the insertion (we modified the existing place instead)
320   RETURN NULL;
321 END;
322 $$ LANGUAGE plpgsql;
323
324
325 CREATE OR REPLACE FUNCTION place_delete()
326   RETURNS TRIGGER
327   AS $$
328 DECLARE
329   has_rank BOOLEAN;
330 BEGIN
331
332   {% if debug %}RAISE WARNING 'delete: % % % %',OLD.osm_type,OLD.osm_id,OLD.class,OLD.type;{% endif %}
333
334   -- deleting large polygons can have a massive effect on the system - require manual intervention to let them through
335   IF st_area(OLD.geometry) > 2 and st_isvalid(OLD.geometry) THEN
336     SELECT bool_or(not (rank_address = 0 or rank_address > 25)) as ranked FROM placex WHERE osm_type = OLD.osm_type and osm_id = OLD.osm_id and class = OLD.class and type = OLD.type INTO has_rank;
337     IF has_rank THEN
338       insert into import_polygon_delete (osm_type, osm_id, class, type) values (OLD.osm_type,OLD.osm_id,OLD.class,OLD.type);
339       RETURN NULL;
340     END IF;
341   END IF;
342
343   -- mark for delete
344   UPDATE placex set indexed_status = 100 where osm_type = OLD.osm_type and osm_id = OLD.osm_id and class = OLD.class and type = OLD.type;
345
346   -- interpolations are special
347   IF OLD.osm_type='W' and OLD.class = 'place' and OLD.type = 'houses' THEN
348     UPDATE location_property_osmline set indexed_status = 100 where osm_id = OLD.osm_id; -- osm_id = wayid (=old.osm_id)
349   END IF;
350
351   RETURN OLD;
352 END;
353 $$
354 LANGUAGE plpgsql;
355