]> git.openstreetmap.org Git - nominatim.git/blob - lib-sql/functions/placex_triggers.sql
e6f083c894aa1d3d517f4eddd96551eaec4de9dc
[nominatim.git] / lib-sql / functions / placex_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 -- Trigger functions for the placex table.
9
10 -- Information returned by update preparation.
11 DROP TYPE IF EXISTS prepare_update_info CASCADE;
12 CREATE TYPE prepare_update_info AS (
13   name HSTORE,
14   address HSTORE,
15   rank_address SMALLINT,
16   country_code TEXT,
17   class TEXT,
18   type TEXT,
19   linked_place_id BIGINT
20 );
21
22 -- Retrieve the data needed by the indexer for updating the place.
23 CREATE OR REPLACE FUNCTION placex_indexing_prepare(p placex)
24   RETURNS prepare_update_info
25   AS $$
26 DECLARE
27   location RECORD;
28   result prepare_update_info;
29   extra_names HSTORE;
30 BEGIN
31   -- For POI nodes, check if the address should be derived from a surrounding
32   -- building.
33   IF p.rank_search < 30 OR p.osm_type != 'N' THEN
34     result.address := p.address;
35   ELSEIF p.address is null THEN
36     -- The additional && condition works around the misguided query
37     -- planner of postgis 3.0.
38     SELECT placex.address || hstore('_inherited', '') INTO result.address
39       FROM placex
40      WHERE ST_Covers(geometry, p.centroid)
41            and geometry && p.centroid
42            and placex.address is not null
43            and (placex.address ? 'housenumber' or placex.address ? 'street' or placex.address ? 'place')
44            and rank_search = 30 AND ST_GeometryType(geometry) in ('ST_Polygon','ST_MultiPolygon')
45      LIMIT 1;
46   ELSE
47     result.address := p.address;
48     -- See if we can inherit addtional address tags from an interpolation.
49     -- These will become permanent.
50     FOR location IN
51       SELECT (address - 'interpolation'::text - 'housenumber'::text) as address
52         FROM place, planet_osm_ways w
53         WHERE place.osm_type = 'W' and place.address ? 'interpolation'
54               and place.geometry && p.geometry
55               and place.osm_id = w.id
56               and p.osm_id = any(w.nodes)
57     LOOP
58       result.address := location.address || result.address;
59     END LOOP;
60   END IF;
61
62   -- remove internal and derived names
63   result.address := result.address - '_unlisted_place'::TEXT;
64   SELECT hstore(array_agg(key), array_agg(value)) INTO result.name
65     FROM each(p.name) WHERE key not like '\_%';
66
67   result.class := p.class;
68   result.type := p.type;
69   result.country_code := p.country_code;
70   result.rank_address := p.rank_address;
71
72   -- Names of linked places need to be merged in, so search for a linkable
73   -- place already here.
74   SELECT * INTO location FROM find_linked_place(p);
75
76   IF location.place_id is not NULL THEN
77     result.linked_place_id := location.place_id;
78
79     IF location.name is not NULL THEN
80       {% if debug %}RAISE WARNING 'Names original: %, location: %', result.name, location.name;{% endif %}
81       -- Add all names from the place nodes that deviate from the name
82       -- in the relation with the prefix '_place_'. Deviation means that
83       -- either the value is different or a given key is missing completely
84       SELECT hstore(array_agg('_place_' || key), array_agg(value)) INTO extra_names
85         FROM each(location.name - result.name);
86       {% if debug %}RAISE WARNING 'Extra names: %', extra_names;{% endif %}
87
88       result.name := location.name || result.name || extra_names;
89       {% if debug %}RAISE WARNING 'Final names: %', result.name;{% endif %}
90     END IF;
91   END IF;
92
93   RETURN result;
94 END;
95 $$
96 LANGUAGE plpgsql STABLE;
97
98
99 CREATE OR REPLACE FUNCTION find_associated_street(poi_osm_type CHAR(1),
100                                                   poi_osm_id BIGINT)
101   RETURNS BIGINT
102   AS $$
103 DECLARE
104   location RECORD;
105   parent RECORD;
106 BEGIN
107   FOR location IN
108     SELECT members FROM planet_osm_rels
109     WHERE parts @> ARRAY[poi_osm_id]
110           and members @> ARRAY[lower(poi_osm_type) || poi_osm_id]
111           and tags @> ARRAY['associatedStreet']
112   LOOP
113     FOR i IN 1..array_upper(location.members, 1) BY 2 LOOP
114       IF location.members[i+1] = 'street' THEN
115         FOR parent IN
116           SELECT place_id from placex
117            WHERE osm_type = 'W' and osm_id = substring(location.members[i],2)::bigint
118                  and name is not null
119                  and rank_search between 26 and 27
120         LOOP
121           RETURN parent.place_id;
122         END LOOP;
123       END IF;
124     END LOOP;
125   END LOOP;
126
127   RETURN NULL;
128 END;
129 $$
130 LANGUAGE plpgsql STABLE;
131
132
133 -- Find the parent road of a POI.
134 --
135 -- \returns Place ID of parent object or NULL if none
136 --
137 -- Copy data from linked items (POIs on ways, addr:street links, relations).
138 --
139 CREATE OR REPLACE FUNCTION find_parent_for_poi(poi_osm_type CHAR(1),
140                                                poi_osm_id BIGINT,
141                                                poi_partition SMALLINT,
142                                                bbox GEOMETRY,
143                                                token_info JSONB,
144                                                is_place_addr BOOLEAN)
145   RETURNS BIGINT
146   AS $$
147 DECLARE
148   parent_place_id BIGINT DEFAULT NULL;
149   location RECORD;
150 BEGIN
151   {% if debug %}RAISE WARNING 'finding street for % %', poi_osm_type, poi_osm_id;{% endif %}
152
153   -- Is this object part of an associatedStreet relation?
154   parent_place_id := find_associated_street(poi_osm_type, poi_osm_id);
155
156   IF parent_place_id is null THEN
157     parent_place_id := find_parent_for_address(token_info, poi_partition, bbox);
158   END IF;
159
160   IF parent_place_id is null and poi_osm_type = 'N' THEN
161     FOR location IN
162       SELECT p.place_id, p.osm_id, p.rank_search, p.address,
163              coalesce(p.centroid, ST_Centroid(p.geometry)) as centroid
164         FROM placex p, planet_osm_ways w
165        WHERE p.osm_type = 'W' and p.rank_search >= 26
166              and p.geometry && bbox
167              and w.id = p.osm_id and poi_osm_id = any(w.nodes)
168     LOOP
169       {% if debug %}RAISE WARNING 'Node is part of way % ', location.osm_id;{% endif %}
170
171       -- Way IS a road then we are on it - that must be our road
172       IF location.rank_search < 28 THEN
173         {% if debug %}RAISE WARNING 'node in way that is a street %',location;{% endif %}
174         RETURN location.place_id;
175       END IF;
176
177       parent_place_id := find_associated_street('W', location.osm_id);
178     END LOOP;
179   END IF;
180
181   IF parent_place_id is NULL THEN
182     IF is_place_addr THEN
183       -- The address is attached to a place we don't know.
184       -- Instead simply use the containing area with the largest rank.
185       FOR location IN
186         SELECT place_id FROM placex
187          WHERE bbox && geometry AND _ST_Covers(geometry, ST_Centroid(bbox))
188                AND rank_address between 5 and 25
189          ORDER BY rank_address desc
190       LOOP
191         RETURN location.place_id;
192       END LOOP;
193     ELSEIF ST_Area(bbox) < 0.005 THEN
194       -- for smaller features get the nearest road
195       SELECT getNearestRoadPlaceId(poi_partition, bbox) INTO parent_place_id;
196       {% if debug %}RAISE WARNING 'Checked for nearest way (%)', parent_place_id;{% endif %}
197     ELSE
198       -- for larger features simply find the area with the largest rank that
199       -- contains the bbox, only use addressable features
200       FOR location IN
201         SELECT place_id FROM placex
202          WHERE bbox && geometry AND _ST_Covers(geometry, ST_Centroid(bbox))
203                AND rank_address between 5 and 25
204         ORDER BY rank_address desc
205       LOOP
206         RETURN location.place_id;
207       END LOOP;
208     END IF;
209   END IF;
210
211   RETURN parent_place_id;
212 END;
213 $$
214 LANGUAGE plpgsql STABLE;
215
216 -- Try to find a linked place for the given object.
217 CREATE OR REPLACE FUNCTION find_linked_place(bnd placex)
218   RETURNS placex
219   AS $$
220 DECLARE
221   relation_members TEXT[];
222   rel_member RECORD;
223   linked_placex placex%ROWTYPE;
224   bnd_name TEXT;
225 BEGIN
226   IF bnd.rank_search >= 26 or bnd.rank_address = 0
227      or ST_GeometryType(bnd.geometry) NOT IN ('ST_Polygon','ST_MultiPolygon')
228      or bnd.type IN ('postcode', 'postal_code')
229   THEN
230     RETURN NULL;
231   END IF;
232
233   IF bnd.osm_type = 'R' THEN
234     -- see if we have any special relation members
235     SELECT members FROM planet_osm_rels WHERE id = bnd.osm_id INTO relation_members;
236     {% if debug %}RAISE WARNING 'Got relation members';{% endif %}
237
238     -- Search for relation members with role 'lable'.
239     IF relation_members IS NOT NULL THEN
240       FOR rel_member IN
241         SELECT get_rel_node_members(relation_members, ARRAY['label']) as member
242       LOOP
243         {% if debug %}RAISE WARNING 'Found label member %', rel_member.member;{% endif %}
244
245         FOR linked_placex IN
246           SELECT * from placex
247           WHERE osm_type = 'N' and osm_id = rel_member.member
248             and class = 'place'
249         LOOP
250           {% if debug %}RAISE WARNING 'Linked label member';{% endif %}
251           RETURN linked_placex;
252         END LOOP;
253
254       END LOOP;
255     END IF;
256   END IF;
257
258   IF bnd.name ? 'name' THEN
259     bnd_name := lower(bnd.name->'name');
260     IF bnd_name = '' THEN
261       bnd_name := NULL;
262     END IF;
263   END IF;
264
265   -- If extratags has a place tag, look for linked nodes by their place type.
266   -- Area and node still have to have the same name.
267   IF bnd.extratags ? 'place' and bnd_name is not null THEN
268     FOR linked_placex IN
269       SELECT * FROM placex
270       WHERE (position(lower(name->'name') in bnd_name) > 0
271              OR position(bnd_name in lower(name->'name')) > 0)
272         AND placex.class = 'place' AND placex.type = bnd.extratags->'place'
273         AND placex.osm_type = 'N'
274         AND placex.linked_place_id is null
275         AND placex.rank_search < 26 -- needed to select the right index
276         AND placex.type != 'postcode'
277         AND ST_Covers(bnd.geometry, placex.geometry)
278     LOOP
279       {% if debug %}RAISE WARNING 'Found type-matching place node %', linked_placex.osm_id;{% endif %}
280       RETURN linked_placex;
281     END LOOP;
282   END IF;
283
284   IF bnd.extratags ? 'wikidata' THEN
285     FOR linked_placex IN
286       SELECT * FROM placex
287       WHERE placex.class = 'place' AND placex.osm_type = 'N'
288         AND placex.extratags ? 'wikidata' -- needed to select right index
289         AND placex.extratags->'wikidata' = bnd.extratags->'wikidata'
290         AND placex.linked_place_id is null
291         AND placex.rank_search < 26
292         AND _st_covers(bnd.geometry, placex.geometry)
293       ORDER BY lower(name->'name') = bnd_name desc
294     LOOP
295       {% if debug %}RAISE WARNING 'Found wikidata-matching place node %', linked_placex.osm_id;{% endif %}
296       RETURN linked_placex;
297     END LOOP;
298   END IF;
299
300   -- Name searches can be done for ways as well as relations
301   IF bnd_name is not null THEN
302     {% if debug %}RAISE WARNING 'Looking for nodes with matching names';{% endif %}
303     FOR linked_placex IN
304       SELECT placex.* from placex
305       WHERE lower(name->'name') = bnd_name
306         AND ((bnd.rank_address > 0
307               and bnd.rank_address = (compute_place_rank(placex.country_code,
308                                                          'N', placex.class,
309                                                          placex.type, 15::SMALLINT,
310                                                          false, placex.postcode)).address_rank)
311              OR (bnd.rank_address = 0 and placex.rank_search = bnd.rank_search))
312         AND placex.osm_type = 'N'
313         AND placex.class = 'place'
314         AND placex.linked_place_id is null
315         AND placex.rank_search < 26 -- needed to select the right index
316         AND placex.type != 'postcode'
317         AND ST_Covers(bnd.geometry, placex.geometry)
318     LOOP
319       {% if debug %}RAISE WARNING 'Found matching place node %', linked_placex.osm_id;{% endif %}
320       RETURN linked_placex;
321     END LOOP;
322   END IF;
323
324   RETURN NULL;
325 END;
326 $$
327 LANGUAGE plpgsql STABLE;
328
329
330 CREATE OR REPLACE FUNCTION create_poi_search_terms(obj_place_id BIGINT,
331                                                    in_partition SMALLINT,
332                                                    parent_place_id BIGINT,
333                                                    is_place_addr BOOLEAN,
334                                                    country TEXT,
335                                                    token_info JSONB,
336                                                    geometry GEOMETRY,
337                                                    OUT name_vector INTEGER[],
338                                                    OUT nameaddress_vector INTEGER[])
339   AS $$
340 DECLARE
341   parent_name_vector INTEGER[];
342   parent_address_vector INTEGER[];
343   addr_place_ids INTEGER[];
344   hnr_vector INTEGER[];
345
346   addr_item RECORD;
347   addr_place RECORD;
348   parent_address_place_ids BIGINT[];
349 BEGIN
350   nameaddress_vector := '{}'::INTEGER[];
351
352   SELECT s.name_vector, s.nameaddress_vector
353     INTO parent_name_vector, parent_address_vector
354     FROM search_name s
355     WHERE s.place_id = parent_place_id;
356
357   FOR addr_item IN
358     SELECT ranks.*, key,
359            token_get_address_search_tokens(token_info, key) as search_tokens
360       FROM token_get_address_keys(token_info) as key,
361            LATERAL get_addr_tag_rank(key, country) as ranks
362       WHERE not token_get_address_search_tokens(token_info, key) <@ parent_address_vector
363   LOOP
364     addr_place := get_address_place(in_partition, geometry,
365                                     addr_item.from_rank, addr_item.to_rank,
366                                     addr_item.extent, token_info, addr_item.key);
367
368     IF addr_place is null THEN
369       -- No place found in OSM that matches. Make it at least searchable.
370       nameaddress_vector := array_merge(nameaddress_vector, addr_item.search_tokens);
371     ELSE
372       IF parent_address_place_ids is null THEN
373         SELECT array_agg(parent_place_id) INTO parent_address_place_ids
374           FROM place_addressline
375           WHERE place_id = parent_place_id;
376       END IF;
377
378       -- If the parent already lists the place in place_address line, then we
379       -- are done. Otherwise, add its own place_address line.
380       IF not parent_address_place_ids @> ARRAY[addr_place.place_id] THEN
381         nameaddress_vector := array_merge(nameaddress_vector, addr_place.keywords);
382
383         INSERT INTO place_addressline (place_id, address_place_id, fromarea,
384                                        isaddress, distance, cached_rank_address)
385           VALUES (obj_place_id, addr_place.place_id, not addr_place.isguess,
386                     true, addr_place.distance, addr_place.rank_address);
387       END IF;
388     END IF;
389   END LOOP;
390
391   name_vector := token_get_name_search_tokens(token_info);
392
393   -- Check if the parent covers all address terms.
394   -- If not, create a search name entry with the house number as the name.
395   -- This is unusual for the search_name table but prevents that the place
396   -- is returned when we only search for the street/place.
397
398   hnr_vector := token_get_housenumber_search_tokens(token_info);
399
400   IF hnr_vector is not null and not nameaddress_vector <@ parent_address_vector THEN
401     name_vector := array_merge(name_vector, hnr_vector);
402   END IF;
403
404   IF is_place_addr THEN
405     addr_place_ids := token_addr_place_search_tokens(token_info);
406     IF not addr_place_ids <@ parent_name_vector THEN
407       -- make sure addr:place terms are always searchable
408       nameaddress_vector := array_merge(nameaddress_vector, addr_place_ids);
409       -- If there is a housenumber, also add the place name as a name,
410       -- so we can search it by the usual housenumber+place algorithms.
411       IF hnr_vector is not null THEN
412         name_vector := array_merge(name_vector, addr_place_ids);
413       END IF;
414     END IF;
415   END IF;
416
417   -- Cheating here by not recomputing all terms but simply using the ones
418   -- from the parent object.
419   nameaddress_vector := array_merge(nameaddress_vector, parent_name_vector);
420   nameaddress_vector := array_merge(nameaddress_vector, parent_address_vector);
421
422 END;
423 $$
424 LANGUAGE plpgsql;
425
426
427 -- Insert address of a place into the place_addressline table.
428 --
429 -- \param obj_place_id  Place_id of the place to compute the address for.
430 -- \param partition     Partition number where the place is in.
431 -- \param maxrank       Rank of the place. All address features must have
432 --                      a search rank lower than the given rank.
433 -- \param address       Address terms for the place.
434 -- \param geometry      Geometry to which the address objects should be close.
435 --
436 -- \retval parent_place_id  Place_id of the address object that is the direct
437 --                          ancestor.
438 -- \retval postcode         Postcode computed from the address. This is the
439 --                          addr:postcode of one of the address objects. If
440 --                          more than one of has a postcode, the highest ranking
441 --                          one is used. May be NULL.
442 -- \retval nameaddress_vector  Search terms for the address. This is the sum
443 --                             of name terms of all address objects.
444 CREATE OR REPLACE FUNCTION insert_addresslines(obj_place_id BIGINT,
445                                                partition SMALLINT,
446                                                maxrank SMALLINT,
447                                                token_info JSONB,
448                                                geometry GEOMETRY,
449                                                country TEXT,
450                                                OUT parent_place_id BIGINT,
451                                                OUT postcode TEXT,
452                                                OUT nameaddress_vector INT[])
453   AS $$
454 DECLARE
455   address_havelevel BOOLEAN[];
456
457   location_isaddress BOOLEAN;
458   current_boundary GEOMETRY := NULL;
459   current_node_area GEOMETRY := NULL;
460
461   parent_place_rank INT := 0;
462   addr_place_ids BIGINT[] := '{}'::int[];
463   new_address_vector INT[];
464
465   location RECORD;
466 BEGIN
467   parent_place_id := 0;
468   nameaddress_vector := '{}'::int[];
469
470   address_havelevel := array_fill(false, ARRAY[maxrank]);
471
472   FOR location IN
473     SELECT apl.*, key
474       FROM (SELECT extra.*, key
475               FROM token_get_address_keys(token_info) as key,
476                    LATERAL get_addr_tag_rank(key, country) as extra) x,
477            LATERAL get_address_place(partition, geometry, from_rank, to_rank,
478                               extent, token_info, key) as apl
479       ORDER BY rank_address, distance, isguess desc
480   LOOP
481     IF location.place_id is null THEN
482       {% if not db.reverse_only %}
483       nameaddress_vector := array_merge(nameaddress_vector,
484                                         token_get_address_search_tokens(token_info,
485                                                                         location.key));
486       {% endif %}
487     ELSE
488       {% if not db.reverse_only %}
489       nameaddress_vector := array_merge(nameaddress_vector, location.keywords::INTEGER[]);
490       {% endif %}
491
492       location_isaddress := not address_havelevel[location.rank_address];
493       IF not address_havelevel[location.rank_address] THEN
494         address_havelevel[location.rank_address] := true;
495         IF parent_place_rank < location.rank_address THEN
496           parent_place_id := location.place_id;
497           parent_place_rank := location.rank_address;
498         END IF;
499       END IF;
500
501       INSERT INTO place_addressline (place_id, address_place_id, fromarea,
502                                      isaddress, distance, cached_rank_address)
503         VALUES (obj_place_id, location.place_id, not location.isguess,
504                 true, location.distance, location.rank_address);
505
506       addr_place_ids := addr_place_ids || location.place_id;
507     END IF;
508   END LOOP;
509
510   FOR location IN
511     SELECT * FROM getNearFeatures(partition, geometry, maxrank)
512     WHERE not addr_place_ids @> ARRAY[place_id]
513     ORDER BY rank_address, isguess asc,
514              distance *
515                CASE WHEN rank_address = 16 AND rank_search = 15 THEN 0.2
516                     WHEN rank_address = 16 AND rank_search = 16 THEN 0.25
517                     WHEN rank_address = 16 AND rank_search = 18 THEN 0.5
518                     ELSE 1 END ASC
519   LOOP
520     -- Ignore all place nodes that do not fit in a lower level boundary.
521     CONTINUE WHEN location.isguess
522                   and current_boundary is not NULL
523                   and not ST_Contains(current_boundary, location.centroid);
524
525     -- If this is the first item in the rank, then assume it is the address.
526     location_isaddress := not address_havelevel[location.rank_address];
527
528     -- Further sanity checks to ensure that the address forms a sane hierarchy.
529     IF location_isaddress THEN
530       IF location.isguess and current_node_area is not NULL THEN
531         location_isaddress := ST_Contains(current_node_area, location.centroid);
532       END IF;
533       IF not location.isguess and current_boundary is not NULL
534          and location.rank_address != 11 AND location.rank_address != 5 THEN
535         location_isaddress := ST_Contains(current_boundary, location.centroid);
536       END IF;
537     END IF;
538
539     IF location_isaddress THEN
540       address_havelevel[location.rank_address] := true;
541       parent_place_id := location.place_id;
542
543       -- Set postcode if we have one.
544       -- (Returned will be the highest ranking one.)
545       IF location.postcode is not NULL THEN
546         postcode = location.postcode;
547       END IF;
548
549       -- Recompute the areas we need for hierarchy sanity checks.
550       IF location.rank_address != 11 AND location.rank_address != 5 THEN
551         IF location.isguess THEN
552           current_node_area := place_node_fuzzy_area(location.centroid,
553                                                      location.rank_search);
554         ELSE
555           current_node_area := NULL;
556           SELECT p.geometry FROM placex p
557               WHERE p.place_id = location.place_id INTO current_boundary;
558         END IF;
559       END IF;
560     END IF;
561
562     -- Add it to the list of search terms
563     {% if not db.reverse_only %}
564       nameaddress_vector := array_merge(nameaddress_vector,
565                                         location.keywords::integer[]);
566     {% endif %}
567
568     INSERT INTO place_addressline (place_id, address_place_id, fromarea,
569                                      isaddress, distance, cached_rank_address)
570         VALUES (obj_place_id, location.place_id, not location.isguess,
571                 location_isaddress, location.distance, location.rank_address);
572   END LOOP;
573 END;
574 $$
575 LANGUAGE plpgsql;
576
577
578 CREATE OR REPLACE FUNCTION placex_insert()
579   RETURNS TRIGGER
580   AS $$
581 DECLARE
582   postcode TEXT;
583   result BOOLEAN;
584   is_area BOOLEAN;
585   country_code VARCHAR(2);
586   diameter FLOAT;
587   classtable TEXT;
588 BEGIN
589   {% if debug %}RAISE WARNING '% % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;{% endif %}
590
591   NEW.place_id := nextval('seq_place');
592   NEW.indexed_status := 1; --STATUS_NEW
593
594   NEW.centroid := ST_PointOnSurface(NEW.geometry);
595   NEW.country_code := lower(get_country_code(NEW.centroid));
596
597   NEW.partition := get_partition(NEW.country_code);
598   NEW.geometry_sector := geometry_sector(NEW.partition, NEW.centroid);
599
600   IF NEW.osm_type = 'X' THEN
601     -- E'X'ternal records should already be in the right format so do nothing
602   ELSE
603     is_area := ST_GeometryType(NEW.geometry) IN ('ST_Polygon','ST_MultiPolygon');
604
605     IF NEW.class in ('place','boundary')
606        AND NEW.type in ('postcode','postal_code')
607     THEN
608       IF NEW.address IS NULL OR NOT NEW.address ? 'postcode' THEN
609           -- most likely just a part of a multipolygon postcode boundary, throw it away
610           RETURN NULL;
611       END IF;
612
613       NEW.name := hstore('ref', NEW.address->'postcode');
614
615     ELSEIF NEW.class = 'highway' AND is_area AND NEW.name is null
616            AND NEW.extratags ? 'area' AND NEW.extratags->'area' = 'yes'
617     THEN
618         RETURN NULL;
619     ELSEIF NEW.class = 'boundary' AND NOT is_area
620     THEN
621         RETURN NULL;
622     ELSEIF NEW.class = 'boundary' AND NEW.type = 'administrative'
623            AND NEW.admin_level <= 4 AND NEW.osm_type = 'W'
624     THEN
625         RETURN NULL;
626     END IF;
627
628     SELECT * INTO NEW.rank_search, NEW.rank_address
629       FROM compute_place_rank(NEW.country_code,
630                               CASE WHEN is_area THEN 'A' ELSE NEW.osm_type END,
631                               NEW.class, NEW.type, NEW.admin_level,
632                               (NEW.extratags->'capital') = 'yes',
633                               NEW.address->'postcode');
634
635     -- a country code make no sense below rank 4 (country)
636     IF NEW.rank_search < 4 THEN
637       NEW.country_code := NULL;
638     END IF;
639
640   END IF;
641
642   {% if debug %}RAISE WARNING 'placex_insert:END: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;{% endif %}
643
644 {% if not disable_diff_updates %}
645   -- The following is not needed until doing diff updates, and slows the main index process down
646
647   IF NEW.rank_address > 0 THEN
648     IF (ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon') AND ST_IsValid(NEW.geometry)) THEN
649       -- Performance: We just can't handle re-indexing for country level changes
650       IF st_area(NEW.geometry) < 1 THEN
651         -- mark items within the geometry for re-indexing
652   --    RAISE WARNING 'placex poly insert: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
653
654         UPDATE placex SET indexed_status = 2
655          WHERE ST_Intersects(NEW.geometry, placex.geometry)
656                and indexed_status = 0
657                and ((rank_address = 0 and rank_search > NEW.rank_address)
658                     or rank_address > NEW.rank_address
659                     or (class = 'place' and osm_type = 'N')
660                    )
661                and (rank_search < 28
662                     or name is not null
663                     or (NEW.rank_address >= 16 and address ? 'place'));
664       END IF;
665     ELSE
666       -- mark nearby items for re-indexing, where 'nearby' depends on the features rank_search and is a complete guess :(
667       diameter := update_place_diameter(NEW.rank_search);
668       IF diameter > 0 THEN
669   --      RAISE WARNING 'placex point insert: % % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type,diameter;
670         IF NEW.rank_search >= 26 THEN
671           -- roads may cause reparenting for >27 rank places
672           update placex set indexed_status = 2 where indexed_status = 0 and rank_search > NEW.rank_search and ST_DWithin(placex.geometry, NEW.geometry, diameter);
673           -- reparenting also for OSM Interpolation Lines (and for Tiger?)
674           update location_property_osmline set indexed_status = 2 where indexed_status = 0 and startnumber is not null and ST_DWithin(location_property_osmline.linegeo, NEW.geometry, diameter);
675         ELSEIF NEW.rank_search >= 16 THEN
676           -- up to rank 16, street-less addresses may need reparenting
677           update placex set indexed_status = 2 where indexed_status = 0 and rank_search > NEW.rank_search and ST_DWithin(placex.geometry, NEW.geometry, diameter) and (rank_search < 28 or name is not null or address ? 'place');
678         ELSE
679           -- for all other places the search terms may change as well
680           update placex set indexed_status = 2 where indexed_status = 0 and rank_search > NEW.rank_search and ST_DWithin(placex.geometry, NEW.geometry, diameter) and (rank_search < 28 or name is not null);
681         END IF;
682       END IF;
683     END IF;
684   END IF;
685
686
687    -- add to tables for special search
688    -- Note: won't work on initial import because the classtype tables
689    -- do not yet exist. It won't hurt either.
690   classtable := 'place_classtype_' || NEW.class || '_' || NEW.type;
691   SELECT count(*)>0 FROM pg_tables WHERE tablename = classtable and schemaname = current_schema() INTO result;
692   IF result THEN
693     EXECUTE 'INSERT INTO ' || classtable::regclass || ' (place_id, centroid) VALUES ($1,$2)' 
694     USING NEW.place_id, ST_Centroid(NEW.geometry);
695   END IF;
696
697 {% endif %} -- not disable_diff_updates
698
699   RETURN NEW;
700
701 END;
702 $$
703 LANGUAGE plpgsql;
704
705 CREATE OR REPLACE FUNCTION placex_update()
706   RETURNS TRIGGER
707   AS $$
708 DECLARE
709   i INTEGER;
710   location RECORD;
711   relation_members TEXT[];
712
713   geom GEOMETRY;
714   parent_address_level SMALLINT;
715   place_address_level SMALLINT;
716
717   max_rank SMALLINT;
718
719   name_vector INTEGER[];
720   nameaddress_vector INTEGER[];
721   addr_nameaddress_vector INTEGER[];
722
723   linked_place BIGINT;
724
725   linked_node_id BIGINT;
726   linked_importance FLOAT;
727   linked_wikipedia TEXT;
728
729   is_place_address BOOLEAN;
730   result BOOLEAN;
731 BEGIN
732   -- deferred delete
733   IF OLD.indexed_status = 100 THEN
734     {% if debug %}RAISE WARNING 'placex_update delete % %',NEW.osm_type,NEW.osm_id;{% endif %}
735     delete from placex where place_id = OLD.place_id;
736     RETURN NULL;
737   END IF;
738
739   IF NEW.indexed_status != 0 OR OLD.indexed_status = 0 THEN
740     RETURN NEW;
741   END IF;
742
743   {% if debug %}RAISE WARNING 'placex_update % % (%)',NEW.osm_type,NEW.osm_id,NEW.place_id;{% endif %}
744
745   NEW.indexed_date = now();
746
747   {% if 'search_name' in db.tables %}
748     DELETE from search_name WHERE place_id = NEW.place_id;
749   {% endif %}
750   result := deleteSearchName(NEW.partition, NEW.place_id);
751   DELETE FROM place_addressline WHERE place_id = NEW.place_id;
752   result := deleteRoad(NEW.partition, NEW.place_id);
753   result := deleteLocationArea(NEW.partition, NEW.place_id, NEW.rank_search);
754   UPDATE placex set linked_place_id = null, indexed_status = 2
755          where linked_place_id = NEW.place_id;
756   -- update not necessary for osmline, cause linked_place_id does not exist
757
758   NEW.extratags := NEW.extratags - 'linked_place'::TEXT;
759
760   -- NEW.linked_place_id contains the precomputed linkee. Save this and restore
761   -- the previous link status.
762   linked_place := NEW.linked_place_id;
763   NEW.linked_place_id := OLD.linked_place_id;
764
765   IF NEW.linked_place_id is not null THEN
766     NEW.token_info := null;
767     {% if debug %}RAISE WARNING 'place already linked to %', OLD.linked_place_id;{% endif %}
768     RETURN NEW;
769   END IF;
770
771   -- Postcodes are just here to compute the centroids. They are not searchable
772   -- unless they are a boundary=postal_code.
773   -- There was an error in the style so that boundary=postal_code used to be
774   -- imported as place=postcode. That's why relations are allowed to pass here.
775   -- This can go away in a couple of versions.
776   IF NEW.class = 'place'  and NEW.type = 'postcode' and NEW.osm_type != 'R' THEN
777     NEW.token_info := null;
778     RETURN NEW;
779   END IF;
780
781   -- Compute a preliminary centroid.
782   NEW.centroid := ST_PointOnSurface(NEW.geometry);
783
784     -- recalculate country and partition
785   IF NEW.rank_search = 4 AND NEW.address is not NULL AND NEW.address ? 'country' THEN
786     -- for countries, believe the mapped country code,
787     -- so that we remain in the right partition if the boundaries
788     -- suddenly expand.
789     NEW.country_code := lower(NEW.address->'country');
790     NEW.partition := get_partition(lower(NEW.country_code));
791     IF NEW.partition = 0 THEN
792       NEW.country_code := lower(get_country_code(NEW.centroid));
793       NEW.partition := get_partition(NEW.country_code);
794     END IF;
795   ELSE
796     IF NEW.rank_search >= 4 THEN
797       NEW.country_code := lower(get_country_code(NEW.centroid));
798     ELSE
799       NEW.country_code := NULL;
800     END IF;
801     NEW.partition := get_partition(NEW.country_code);
802   END IF;
803   {% if debug %}RAISE WARNING 'Country updated: "%"', NEW.country_code;{% endif %}
804
805
806   -- recompute the ranks, they might change when linking changes
807   SELECT * INTO NEW.rank_search, NEW.rank_address
808     FROM compute_place_rank(NEW.country_code,
809                             CASE WHEN ST_GeometryType(NEW.geometry)
810                                         IN ('ST_Polygon','ST_MultiPolygon')
811                             THEN 'A' ELSE NEW.osm_type END,
812                             NEW.class, NEW.type, NEW.admin_level,
813                             (NEW.extratags->'capital') = 'yes',
814                             NEW.address->'postcode');
815   -- We must always increase the address level relative to the admin boundary.
816   IF NEW.class = 'boundary' and NEW.type = 'administrative'
817      and NEW.osm_type = 'R' and NEW.rank_address > 0
818   THEN
819     -- First, check that admin boundaries do not overtake each other rank-wise.
820     parent_address_level := 3;
821     FOR location IN
822       SELECT rank_address,
823              (CASE WHEN extratags ? 'wikidata' and NEW.extratags ? 'wikidata'
824                         and extratags->'wikidata' = NEW.extratags->'wikidata'
825                    THEN ST_Equals(geometry, NEW.geometry)
826                    ELSE false END) as is_same
827       FROM placex
828       WHERE osm_type = 'R' and class = 'boundary' and type = 'administrative'
829             and admin_level < NEW.admin_level and admin_level > 3
830             and rank_address > 0
831             and geometry && NEW.centroid and _ST_Covers(geometry, NEW.centroid)
832       ORDER BY admin_level desc LIMIT 1
833     LOOP
834       IF location.is_same THEN
835         -- Looks like the same boundary is replicated on multiple admin_levels.
836         -- Usual tagging in Poland. Remove our boundary from addresses.
837         NEW.rank_address := 0;
838       ELSE
839         parent_address_level := location.rank_address;
840         IF location.rank_address >= NEW.rank_address THEN
841           IF location.rank_address >= 24 THEN
842             NEW.rank_address := 25;
843           ELSE
844             NEW.rank_address := location.rank_address + 2;
845           END IF;
846         END IF;
847       END IF;
848     END LOOP;
849
850     IF NEW.rank_address > 9 THEN
851         -- Second check that the boundary is not completely contained in a
852         -- place area with a higher address rank
853         FOR location IN
854           SELECT rank_address FROM placex
855           WHERE class = 'place' and rank_address < 24
856                 and rank_address > NEW.rank_address
857                 and geometry && NEW.geometry
858                 and geometry ~ NEW.geometry -- needed because ST_Relate does not do bbox cover test
859                 and ST_Relate(geometry, NEW.geometry, 'T*T***FF*') -- contains but not equal
860           ORDER BY rank_address desc LIMIT 1
861         LOOP
862           NEW.rank_address := location.rank_address + 2;
863         END LOOP;
864     END IF;
865   ELSEIF NEW.class = 'place' and NEW.osm_type = 'N'
866      and NEW.rank_address between 16 and 23
867   THEN
868     -- If a place node is contained in a admin boundary with the same address level
869     -- and has not been linked, then make the node a subpart by increasing the
870     -- address rank (city level and above).
871     FOR location IN
872         SELECT rank_address FROM placex
873         WHERE osm_type = 'R' and class = 'boundary' and type = 'administrative'
874               and rank_address = NEW.rank_address
875               and geometry && NEW.centroid and _ST_Covers(geometry, NEW.centroid)
876         LIMIT 1
877     LOOP
878       NEW.rank_address = NEW.rank_address + 2;
879     END LOOP;
880   ELSE
881     parent_address_level := 3;
882   END IF;
883
884   NEW.housenumber := token_normalized_housenumber(NEW.token_info);
885
886   NEW.postcode := null;
887
888   -- waterway ways are linked when they are part of a relation and have the same class/type
889   IF NEW.osm_type = 'R' and NEW.class = 'waterway' THEN
890       FOR relation_members IN select members from planet_osm_rels r where r.id = NEW.osm_id and r.parts != array[]::bigint[]
891       LOOP
892           FOR i IN 1..array_upper(relation_members, 1) BY 2 LOOP
893               IF relation_members[i+1] in ('', 'main_stream', 'side_stream') AND substring(relation_members[i],1,1) = 'w' THEN
894                 {% if debug %}RAISE WARNING 'waterway parent %, child %/%', NEW.osm_id, i, relation_members[i];{% endif %}
895                 FOR linked_node_id IN SELECT place_id FROM placex
896                   WHERE osm_type = 'W' and osm_id = substring(relation_members[i],2,200)::bigint
897                   and class = NEW.class and type in ('river', 'stream', 'canal', 'drain', 'ditch')
898                   and ( relation_members[i+1] != 'side_stream' or NEW.name->'name' = name->'name')
899                 LOOP
900                   UPDATE placex SET linked_place_id = NEW.place_id WHERE place_id = linked_node_id;
901                   {% if 'search_name' in db.tables %}
902                     DELETE FROM search_name WHERE place_id = linked_node_id;
903                   {% endif %}
904                 END LOOP;
905               END IF;
906           END LOOP;
907       END LOOP;
908       {% if debug %}RAISE WARNING 'Waterway processed';{% endif %}
909   END IF;
910
911   NEW.importance := null;
912   SELECT wikipedia, importance
913     FROM compute_importance(NEW.extratags, NEW.country_code, NEW.osm_type, NEW.osm_id)
914     INTO NEW.wikipedia,NEW.importance;
915
916 {% if debug %}RAISE WARNING 'Importance computed from wikipedia: %', NEW.importance;{% endif %}
917
918   -- ---------------------------------------------------------------------------
919   -- For low level elements we inherit from our parent road
920   IF NEW.rank_search > 27 THEN
921
922     {% if debug %}RAISE WARNING 'finding street for % %', NEW.osm_type, NEW.osm_id;{% endif %}
923     NEW.parent_place_id := null;
924     is_place_address := coalesce(not NEW.address ? 'street' and NEW.address ? 'place', FALSE);
925
926     -- We have to find our parent road.
927     NEW.parent_place_id := find_parent_for_poi(NEW.osm_type, NEW.osm_id,
928                                                NEW.partition,
929                                                ST_Envelope(NEW.geometry),
930                                                NEW.token_info,
931                                                is_place_address);
932
933     -- If we found the road take a shortcut here.
934     -- Otherwise fall back to the full address getting method below.
935     IF NEW.parent_place_id is not null THEN
936
937       -- Get the details of the parent road
938       SELECT p.country_code, p.postcode, p.name FROM placex p
939        WHERE p.place_id = NEW.parent_place_id INTO location;
940
941       IF is_place_address THEN
942         -- Check if the addr:place tag is part of the parent name
943         SELECT count(*) INTO i
944           FROM svals(location.name) AS pname WHERE pname = NEW.address->'place';
945         IF i = 0 THEN
946           NEW.address = NEW.address || hstore('_unlisted_place', NEW.address->'place');
947         END IF;
948       END IF;
949
950       NEW.country_code := location.country_code;
951       {% if debug %}RAISE WARNING 'Got parent details from search name';{% endif %}
952
953       -- determine postcode
954       NEW.postcode := coalesce(token_normalized_postcode(NEW.address->'postcode'),
955                                location.postcode,
956                                get_nearest_postcode(NEW.country_code, NEW.centroid));
957
958       IF NEW.name is not NULL THEN
959           NEW.name := add_default_place_name(NEW.country_code, NEW.name);
960       END IF;
961
962       {% if not db.reverse_only %}
963       IF NEW.name is not NULL OR NEW.address is not NULL THEN
964         SELECT * INTO name_vector, nameaddress_vector
965           FROM create_poi_search_terms(NEW.place_id,
966                                        NEW.partition, NEW.parent_place_id,
967                                        is_place_address, NEW.country_code,
968                                        NEW.token_info, NEW.centroid);
969
970         IF array_length(name_vector, 1) is not NULL THEN
971           INSERT INTO search_name (place_id, search_rank, address_rank,
972                                    importance, country_code, name_vector,
973                                    nameaddress_vector, centroid)
974                  VALUES (NEW.place_id, NEW.rank_search, NEW.rank_address,
975                          NEW.importance, NEW.country_code, name_vector,
976                          nameaddress_vector, NEW.centroid);
977           {% if debug %}RAISE WARNING 'Place added to search table';{% endif %}
978         END IF;
979       END IF;
980       {% endif %}
981
982       NEW.token_info := token_strip_info(NEW.token_info);
983       -- If the address was inherited from a surrounding building,
984       -- do not add it permanently to the table.
985       IF NEW.address ? '_inherited' THEN
986         IF NEW.address ? '_unlisted_place' THEN
987           NEW.address := hstore('_unlisted_place', NEW.address->'_unlisted_place');
988         ELSE
989           NEW.address := null;
990         END IF;
991       END IF;
992
993       RETURN NEW;
994     END IF;
995
996   END IF;
997
998   -- ---------------------------------------------------------------------------
999   -- Full indexing
1000   {% if debug %}RAISE WARNING 'Using full index mode for % %', NEW.osm_type, NEW.osm_id;{% endif %}
1001   IF linked_place is not null THEN
1002     SELECT * INTO location FROM placex WHERE place_id = linked_place;
1003
1004     {% if debug %}RAISE WARNING 'Linked %', location;{% endif %}
1005
1006     -- Use the linked point as the centre point of the geometry,
1007     -- but only if it is within the area of the boundary.
1008     geom := coalesce(location.centroid, ST_Centroid(location.geometry));
1009     IF geom is not NULL AND ST_Within(geom, NEW.geometry) THEN
1010         NEW.centroid := geom;
1011     END IF;
1012
1013     {% if debug %}RAISE WARNING 'parent address: % rank address: %', parent_address_level, location.rank_address;{% endif %}
1014     IF location.rank_address > parent_address_level
1015        and location.rank_address < 26
1016     THEN
1017       NEW.rank_address := location.rank_address;
1018     END IF;
1019
1020     -- merge in extra tags
1021     NEW.extratags := hstore('linked_' || location.class, location.type)
1022                      || coalesce(location.extratags, ''::hstore)
1023                      || coalesce(NEW.extratags, ''::hstore);
1024
1025     -- mark the linked place (excludes from search results)
1026     UPDATE placex set linked_place_id = NEW.place_id
1027       WHERE place_id = location.place_id;
1028     -- ensure that those places are not found anymore
1029     {% if 'search_name' in db.tables %}
1030       DELETE FROM search_name WHERE place_id = location.place_id;
1031     {% endif %}
1032     PERFORM deleteLocationArea(NEW.partition, location.place_id, NEW.rank_search);
1033
1034     SELECT wikipedia, importance
1035       FROM compute_importance(location.extratags, NEW.country_code,
1036                               'N', location.osm_id)
1037       INTO linked_wikipedia,linked_importance;
1038
1039     -- Use the maximum importance if one could be computed from the linked object.
1040     IF linked_importance is not null AND
1041        (NEW.importance is null or NEW.importance < linked_importance)
1042     THEN
1043       NEW.importance = linked_importance;
1044     END IF;
1045   ELSE
1046     -- No linked place? As a last resort check if the boundary is tagged with
1047     -- a place type and adapt the rank address.
1048     IF NEW.rank_address > 0 and NEW.extratags ? 'place' THEN
1049       SELECT address_rank INTO place_address_level
1050         FROM compute_place_rank(NEW.country_code, 'A', 'place',
1051                                 NEW.extratags->'place', 0::SMALLINT, False, null);
1052       IF place_address_level > parent_address_level and
1053          place_address_level < 26 THEN
1054         NEW.rank_address := place_address_level;
1055       END IF;
1056     END IF;
1057   END IF;
1058
1059   IF NEW.admin_level = 2
1060      AND NEW.class = 'boundary' AND NEW.type = 'administrative'
1061      AND NEW.country_code IS NOT NULL AND NEW.osm_type = 'R'
1062   THEN
1063     -- Update the list of country names.
1064     -- Only take the name from the largest area for the given country code
1065     -- in the hope that this is the authoritive one.
1066     -- Also replace any old names so that all mapping mistakes can
1067     -- be fixed through regular OSM updates.
1068     FOR location IN
1069       SELECT osm_id FROM placex
1070        WHERE rank_search = 4 and osm_type = 'R'
1071              and country_code = NEW.country_code
1072        ORDER BY ST_Area(geometry) desc
1073        LIMIT 1
1074     LOOP
1075       IF location.osm_id = NEW.osm_id THEN
1076         {% if debug %}RAISE WARNING 'Updating names for country '%' with: %', NEW.country_code, NEW.name;{% endif %}
1077         UPDATE country_name SET derived_name = NEW.name WHERE country_code = NEW.country_code;
1078       END IF;
1079     END LOOP;
1080   END IF;
1081
1082   -- For linear features we need the full geometry for determining the address
1083   -- because they may go through several administrative entities. Otherwise use
1084   -- the centroid for performance reasons.
1085   IF ST_GeometryType(NEW.geometry) in ('ST_LineString', 'ST_MultiLineString') THEN
1086     geom := NEW.geometry;
1087   ELSE
1088     geom := NEW.centroid;
1089   END IF;
1090
1091   IF NEW.rank_address = 0 THEN
1092     max_rank := geometry_to_rank(NEW.rank_search, NEW.geometry, NEW.country_code);
1093     -- Rank 0 features may also span multiple administrative areas (e.g. lakes)
1094     -- so use the geometry here too. Just make sure the areas don't become too
1095     -- large.
1096     IF NEW.class = 'natural' or max_rank > 10 THEN
1097       geom := NEW.geometry;
1098     END IF;
1099   ELSEIF NEW.rank_address > 25 THEN
1100     max_rank := 25;
1101   ELSE
1102     max_rank := NEW.rank_address;
1103   END IF;
1104
1105   SELECT * FROM insert_addresslines(NEW.place_id, NEW.partition, max_rank,
1106                                     NEW.token_info, geom, NEW.country_code)
1107     INTO NEW.parent_place_id, NEW.postcode, nameaddress_vector;
1108
1109   {% if debug %}RAISE WARNING 'RETURN insert_addresslines: %, %, %', NEW.parent_place_id, NEW.postcode, nameaddress_vector;{% endif %}
1110
1111   NEW.postcode := coalesce(token_normalized_postcode(NEW.address->'postcode'),
1112                            NEW.postcode);
1113
1114   -- if we have a name add this to the name search table
1115   IF NEW.name IS NOT NULL THEN
1116     -- Initialise the name vector using our name
1117     NEW.name := add_default_place_name(NEW.country_code, NEW.name);
1118     name_vector := token_get_name_search_tokens(NEW.token_info);
1119
1120     IF NEW.rank_search <= 25 and NEW.rank_address > 0 THEN
1121       result := add_location(NEW.place_id, NEW.country_code, NEW.partition,
1122                              name_vector, NEW.rank_search, NEW.rank_address,
1123                              NEW.postcode, NEW.geometry, NEW.centroid);
1124       {% if debug %}RAISE WARNING 'added to location (full)';{% endif %}
1125     END IF;
1126
1127     IF NEW.rank_search between 26 and 27 and NEW.class = 'highway' THEN
1128       result := insertLocationRoad(NEW.partition, NEW.place_id, NEW.country_code, NEW.geometry);
1129       {% if debug %}RAISE WARNING 'insert into road location table (full)';{% endif %}
1130     END IF;
1131
1132     IF NEW.rank_address between 16 and 27 THEN
1133       result := insertSearchName(NEW.partition, NEW.place_id,
1134                                  token_get_name_match_tokens(NEW.token_info),
1135                                  NEW.rank_search, NEW.rank_address, NEW.geometry);
1136     END IF;
1137     {% if debug %}RAISE WARNING 'added to search name (full)';{% endif %}
1138
1139     {% if not db.reverse_only %}
1140         INSERT INTO search_name (place_id, search_rank, address_rank,
1141                                  importance, country_code, name_vector,
1142                                  nameaddress_vector, centroid)
1143                VALUES (NEW.place_id, NEW.rank_search, NEW.rank_address,
1144                        NEW.importance, NEW.country_code, name_vector,
1145                        nameaddress_vector, NEW.centroid);
1146     {% endif %}
1147   END IF;
1148
1149   IF NEW.postcode is null AND NEW.rank_search > 8 THEN
1150     NEW.postcode := get_nearest_postcode(NEW.country_code, NEW.geometry);
1151   END IF;
1152
1153   {% if debug %}RAISE WARNING 'place update % % finsihed.', NEW.osm_type, NEW.osm_id;{% endif %}
1154
1155   NEW.token_info := token_strip_info(NEW.token_info);
1156   RETURN NEW;
1157 END;
1158 $$
1159 LANGUAGE plpgsql;
1160
1161
1162 CREATE OR REPLACE FUNCTION placex_delete()
1163   RETURNS TRIGGER
1164   AS $$
1165 DECLARE
1166   b BOOLEAN;
1167   classtable TEXT;
1168 BEGIN
1169   -- RAISE WARNING 'placex_delete % %',OLD.osm_type,OLD.osm_id;
1170
1171   IF OLD.linked_place_id is null THEN
1172     update placex set linked_place_id = null, indexed_status = 2 where linked_place_id = OLD.place_id and indexed_status = 0;
1173     {% if debug %}RAISE WARNING 'placex_delete:01 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1174     update placex set linked_place_id = null where linked_place_id = OLD.place_id;
1175     {% if debug %}RAISE WARNING 'placex_delete:02 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1176   ELSE
1177     update placex set indexed_status = 2 where place_id = OLD.linked_place_id and indexed_status = 0;
1178   END IF;
1179
1180   IF OLD.rank_address < 30 THEN
1181
1182     -- mark everything linked to this place for re-indexing
1183     {% if debug %}RAISE WARNING 'placex_delete:03 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1184     UPDATE placex set indexed_status = 2 from place_addressline where address_place_id = OLD.place_id 
1185       and placex.place_id = place_addressline.place_id and indexed_status = 0 and place_addressline.isaddress;
1186
1187     {% if debug %}RAISE WARNING 'placex_delete:04 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1188     DELETE FROM place_addressline where address_place_id = OLD.place_id;
1189
1190     {% if debug %}RAISE WARNING 'placex_delete:05 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1191     b := deleteRoad(OLD.partition, OLD.place_id);
1192
1193     {% if debug %}RAISE WARNING 'placex_delete:06 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1194     update placex set indexed_status = 2 where parent_place_id = OLD.place_id and indexed_status = 0;
1195     {% if debug %}RAISE WARNING 'placex_delete:07 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1196     -- reparenting also for OSM Interpolation Lines (and for Tiger?)
1197     update location_property_osmline set indexed_status = 2 where indexed_status = 0 and parent_place_id = OLD.place_id;
1198
1199   END IF;
1200
1201   {% if debug %}RAISE WARNING 'placex_delete:08 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1202
1203   IF OLD.rank_address < 26 THEN
1204     b := deleteLocationArea(OLD.partition, OLD.place_id, OLD.rank_search);
1205   END IF;
1206
1207   {% if debug %}RAISE WARNING 'placex_delete:09 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1208
1209   IF OLD.name is not null THEN
1210     {% if 'search_name' in db.tables %}
1211       DELETE from search_name WHERE place_id = OLD.place_id;
1212     {% endif %}
1213     b := deleteSearchName(OLD.partition, OLD.place_id);
1214   END IF;
1215
1216   {% if debug %}RAISE WARNING 'placex_delete:10 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1217
1218   DELETE FROM place_addressline where place_id = OLD.place_id;
1219
1220   {% if debug %}RAISE WARNING 'placex_delete:11 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1221
1222   -- remove from tables for special search
1223   classtable := 'place_classtype_' || OLD.class || '_' || OLD.type;
1224   SELECT count(*)>0 FROM pg_tables WHERE tablename = classtable and schemaname = current_schema() INTO b;
1225   IF b THEN
1226     EXECUTE 'DELETE FROM ' || classtable::regclass || ' WHERE place_id = $1' USING OLD.place_id;
1227   END IF;
1228
1229   {% if debug %}RAISE WARNING 'placex_delete:12 % %',OLD.osm_type,OLD.osm_id;{% endif %}
1230
1231   RETURN OLD;
1232
1233 END;
1234 $$
1235 LANGUAGE plpgsql;