]> git.openstreetmap.org Git - nominatim.git/blob - sql/functions.sql
Merge remote-tracking branch 'upstream/master'
[nominatim.git] / sql / functions.sql
1 --DROP TRIGGER IF EXISTS place_before_insert on placex;
2 --DROP TRIGGER IF EXISTS place_before_update on placex;
3 --CREATE TYPE addresscalculationtype AS (
4 --  word text,
5 --  score integer
6 --);
7
8 CREATE OR REPLACE FUNCTION getclasstypekey(c text, t text) RETURNS TEXT
9   AS $$
10 DECLARE
11 BEGIN
12   RETURN c||'|'||t;
13 END;
14 $$
15 LANGUAGE plpgsql IMMUTABLE;
16
17 CREATE OR REPLACE FUNCTION isbrokengeometry(place geometry) RETURNS BOOLEAN
18   AS $$
19 DECLARE
20   NEWgeometry geometry;
21 BEGIN
22   NEWgeometry := place;
23   IF ST_IsEmpty(NEWgeometry) OR NOT ST_IsValid(NEWgeometry) OR ST_X(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') THEN  
24     RETURN true;
25   END IF;
26   RETURN false;
27 END;
28 $$
29 LANGUAGE plpgsql IMMUTABLE;
30
31 CREATE OR REPLACE FUNCTION clean_geometry(place geometry) RETURNS geometry
32   AS $$
33 DECLARE
34   NEWgeometry geometry;
35 BEGIN
36   NEWgeometry := place;
37   IF ST_X(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') THEN  
38     NEWgeometry := ST_buffer(NEWgeometry,0);
39     IF ST_X(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') THEN  
40       RETURN ST_SetSRID(ST_Point(0,0),4326);
41     END IF;
42   END IF;
43   RETURN NEWgeometry;
44 END;
45 $$
46 LANGUAGE plpgsql IMMUTABLE;
47
48 CREATE OR REPLACE FUNCTION geometry_sector(partition INTEGER, place geometry) RETURNS INTEGER
49   AS $$
50 DECLARE
51   NEWgeometry geometry;
52 BEGIN
53 --  RAISE WARNING '%',place;
54   NEWgeometry := ST_PointOnSurface(place);
55 --  IF ST_IsEmpty(NEWgeometry) OR NOT ST_IsValid(NEWgeometry) OR ST_X(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') THEN  
56 --    NEWgeometry := ST_buffer(NEWgeometry,0);
57 --    IF ST_IsEmpty(NEWgeometry) OR NOT ST_IsValid(NEWgeometry) OR ST_X(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEWgeometry))::text in ('NaN','Infinity','-Infinity') THEN  
58 --      RETURN 0;
59 --    END IF;
60 --  END IF;
61   RETURN (partition*1000000) + (500-ST_X(NEWgeometry)::integer)*1000 + (500-ST_Y(NEWgeometry)::integer);
62 END;
63 $$
64 LANGUAGE plpgsql IMMUTABLE;
65
66 CREATE OR REPLACE FUNCTION transliteration(text) RETURNS text
67   AS '{modulepath}/nominatim.so', 'transliteration'
68 LANGUAGE c IMMUTABLE STRICT;
69
70 CREATE OR REPLACE FUNCTION gettokenstring(text) RETURNS text
71   AS '{modulepath}/nominatim.so', 'gettokenstring'
72 LANGUAGE c IMMUTABLE STRICT;
73
74 CREATE OR REPLACE FUNCTION make_standard_name(name TEXT) RETURNS TEXT
75   AS $$
76 DECLARE
77   o TEXT;
78 BEGIN
79   o := gettokenstring(transliteration(name));
80   RETURN trim(substr(o,1,length(o)));
81 END;
82 $$
83 LANGUAGE 'plpgsql' IMMUTABLE;
84
85 -- returns NULL if the word is too common
86 CREATE OR REPLACE FUNCTION getorcreate_word_id(lookup_word TEXT) 
87   RETURNS INTEGER
88   AS $$
89 DECLARE
90   lookup_token TEXT;
91   return_word_id INTEGER;
92   count INTEGER;
93 BEGIN
94   lookup_token := trim(lookup_word);
95   SELECT min(word_id), max(search_name_count) FROM word WHERE word_token = lookup_token and class is null and type is null into return_word_id, count;
96   IF return_word_id IS NULL THEN
97     return_word_id := nextval('seq_word');
98     INSERT INTO word VALUES (return_word_id, lookup_token, null, null, null, null, 0);
99   ELSE
100     IF count > get_maxwordfreq() THEN
101       return_word_id := NULL;
102     END IF;
103   END IF;
104   RETURN return_word_id;
105 END;
106 $$
107 LANGUAGE plpgsql;
108
109 CREATE OR REPLACE FUNCTION getorcreate_housenumber_id(lookup_word TEXT)
110   RETURNS INTEGER
111   AS $$
112 DECLARE
113   lookup_token TEXT;
114   return_word_id INTEGER;
115 BEGIN
116   lookup_token := ' '||trim(lookup_word);
117   SELECT min(word_id) FROM word WHERE word_token = lookup_token and class='place' and type='house' into return_word_id;
118   IF return_word_id IS NULL THEN
119     return_word_id := nextval('seq_word');
120     INSERT INTO word VALUES (return_word_id, lookup_token, null, 'place', 'house', null, 0);
121   END IF;
122   RETURN return_word_id;
123 END;
124 $$
125 LANGUAGE plpgsql;
126
127 CREATE OR REPLACE FUNCTION getorcreate_country(lookup_word TEXT, lookup_country_code varchar(2))
128   RETURNS INTEGER
129   AS $$
130 DECLARE
131   lookup_token TEXT;
132   return_word_id INTEGER;
133 BEGIN
134   lookup_token := ' '||trim(lookup_word);
135   SELECT min(word_id) FROM word WHERE word_token = lookup_token and country_code=lookup_country_code into return_word_id;
136   IF return_word_id IS NULL THEN
137     return_word_id := nextval('seq_word');
138     INSERT INTO word VALUES (return_word_id, lookup_token, null, null, null, lookup_country_code, 0);
139   END IF;
140   RETURN return_word_id;
141 END;
142 $$
143 LANGUAGE plpgsql;
144
145 CREATE OR REPLACE FUNCTION getorcreate_amenity(lookup_word TEXT, lookup_class text, lookup_type text)
146   RETURNS INTEGER
147   AS $$
148 DECLARE
149   lookup_token TEXT;
150   return_word_id INTEGER;
151 BEGIN
152   lookup_token := ' '||trim(lookup_word);
153   SELECT min(word_id) FROM word WHERE word_token = lookup_token and class=lookup_class and type = lookup_type into return_word_id;
154   IF return_word_id IS NULL THEN
155     return_word_id := nextval('seq_word');
156     INSERT INTO word VALUES (return_word_id, lookup_token, null, lookup_class, lookup_type, null, 0);
157   END IF;
158   RETURN return_word_id;
159 END;
160 $$
161 LANGUAGE plpgsql;
162
163 CREATE OR REPLACE FUNCTION getorcreate_tagpair(lookup_class text, lookup_type text)
164   RETURNS INTEGER
165   AS $$
166 DECLARE
167   lookup_token TEXT;
168   return_word_id INTEGER;
169 BEGIN
170   lookup_token := lookup_class||'='||lookup_type;
171   SELECT min(word_id) FROM word WHERE word_token = lookup_token into return_word_id;
172   IF return_word_id IS NULL THEN
173     return_word_id := nextval('seq_word');
174     INSERT INTO word VALUES (return_word_id, lookup_token, null, null, null, null, 0);
175   END IF;
176   RETURN return_word_id;
177 END;
178 $$
179 LANGUAGE plpgsql;
180
181 CREATE OR REPLACE FUNCTION get_tagpair(lookup_class text, lookup_type text)
182   RETURNS INTEGER
183   AS $$
184 DECLARE
185   lookup_token TEXT;
186   return_word_id INTEGER;
187 BEGIN
188   lookup_token := lookup_class||'='||lookup_type;
189   SELECT min(word_id) FROM word WHERE word_token = lookup_token into return_word_id;
190   RETURN return_word_id;
191 END;
192 $$
193 LANGUAGE plpgsql;
194
195 CREATE OR REPLACE FUNCTION getorcreate_amenityoperator(lookup_word TEXT, lookup_class text, lookup_type text, op text)
196   RETURNS INTEGER
197   AS $$
198 DECLARE
199   lookup_token TEXT;
200   return_word_id INTEGER;
201 BEGIN
202   lookup_token := ' '||trim(lookup_word);
203   SELECT min(word_id) FROM word WHERE word_token = lookup_token and class=lookup_class and type = lookup_type and operator = op into return_word_id;
204   IF return_word_id IS NULL THEN
205     return_word_id := nextval('seq_word');
206     INSERT INTO word VALUES (return_word_id, lookup_token, null, lookup_class, lookup_type, null, 0, op);
207   END IF;
208   RETURN return_word_id;
209 END;
210 $$
211 LANGUAGE plpgsql;
212
213 CREATE OR REPLACE FUNCTION getorcreate_name_id(lookup_word TEXT, src_word TEXT) 
214   RETURNS INTEGER
215   AS $$
216 DECLARE
217   lookup_token TEXT;
218   nospace_lookup_token TEXT;
219   return_word_id INTEGER;
220 BEGIN
221   lookup_token := ' '||trim(lookup_word);
222   SELECT min(word_id) FROM word WHERE word_token = lookup_token and class is null and type is null into return_word_id;
223   IF return_word_id IS NULL THEN
224     return_word_id := nextval('seq_word');
225     INSERT INTO word VALUES (return_word_id, lookup_token, src_word, null, null, null, 0);
226 --    nospace_lookup_token := replace(replace(lookup_token, '-',''), ' ','');
227 --    IF ' '||nospace_lookup_token != lookup_token THEN
228 --      INSERT INTO word VALUES (return_word_id, '-'||nospace_lookup_token, null, src_word, null, null, null, 0, null);
229 --    END IF;
230   END IF;
231   RETURN return_word_id;
232 END;
233 $$
234 LANGUAGE plpgsql;
235
236 CREATE OR REPLACE FUNCTION getorcreate_name_id(lookup_word TEXT) 
237   RETURNS INTEGER
238   AS $$
239 DECLARE
240 BEGIN
241   RETURN getorcreate_name_id(lookup_word, '');
242 END;
243 $$
244 LANGUAGE plpgsql;
245
246 CREATE OR REPLACE FUNCTION get_word_id(lookup_word TEXT) 
247   RETURNS INTEGER
248   AS $$
249 DECLARE
250   lookup_token TEXT;
251   return_word_id INTEGER;
252 BEGIN
253   lookup_token := trim(lookup_word);
254   SELECT min(word_id) FROM word WHERE word_token = lookup_token and class is null and type is null into return_word_id;
255   RETURN return_word_id;
256 END;
257 $$
258 LANGUAGE plpgsql IMMUTABLE;
259
260 CREATE OR REPLACE FUNCTION get_name_id(lookup_word TEXT) 
261   RETURNS INTEGER
262   AS $$
263 DECLARE
264   lookup_token TEXT;
265   return_word_id INTEGER;
266 BEGIN
267   lookup_token := ' '||trim(lookup_word);
268   SELECT min(word_id) FROM word WHERE word_token = lookup_token and class is null and type is null into return_word_id;
269   RETURN return_word_id;
270 END;
271 $$
272 LANGUAGE plpgsql IMMUTABLE;
273
274 CREATE OR REPLACE FUNCTION array_merge(a INTEGER[], b INTEGER[])
275   RETURNS INTEGER[]
276   AS $$
277 DECLARE
278   i INTEGER;
279   r INTEGER[];
280 BEGIN
281   IF array_upper(a, 1) IS NULL THEN
282     RETURN b;
283   END IF;
284   IF array_upper(b, 1) IS NULL THEN
285     RETURN a;
286   END IF;
287   r := a;
288   FOR i IN 1..array_upper(b, 1) LOOP  
289     IF NOT (ARRAY[b[i]] <@ r) THEN
290       r := r || b[i];
291     END IF;
292   END LOOP;
293   RETURN r;
294 END;
295 $$
296 LANGUAGE plpgsql IMMUTABLE;
297
298 CREATE OR REPLACE FUNCTION create_country(src HSTORE, lookup_country_code varchar(2)) RETURNS VOID
299   AS $$
300 DECLARE
301   s TEXT;
302   w INTEGER;
303   words TEXT[];
304   item RECORD;
305   j INTEGER;
306 BEGIN
307   FOR item IN SELECT (each(src)).* LOOP
308
309     s := make_standard_name(item.value);
310     w := getorcreate_country(s, lookup_country_code);
311
312     words := regexp_split_to_array(item.value, E'[,;()]');
313     IF array_upper(words, 1) != 1 THEN
314       FOR j IN 1..array_upper(words, 1) LOOP
315         s := make_standard_name(words[j]);
316         IF s != '' THEN
317           w := getorcreate_country(s, lookup_country_code);
318         END IF;
319       END LOOP;
320     END IF;
321   END LOOP;
322 END;
323 $$
324 LANGUAGE plpgsql;
325
326 CREATE OR REPLACE FUNCTION make_keywords(src HSTORE) RETURNS INTEGER[]
327   AS $$
328 DECLARE
329   result INTEGER[];
330   s TEXT;
331   w INTEGER;
332   words TEXT[];
333   item RECORD;
334   j INTEGER;
335 BEGIN
336   result := '{}'::INTEGER[];
337
338   FOR item IN SELECT (each(src)).* LOOP
339
340     s := make_standard_name(item.value);
341
342     w := getorcreate_name_id(s, item.value);
343
344     IF not(ARRAY[w] <@ result) THEN
345       result := result || w;
346     END IF;
347
348     w := getorcreate_word_id(s);
349
350     IF w IS NOT NULL AND NOT (ARRAY[w] <@ result) THEN
351       result := result || w;
352     END IF;
353
354     words := string_to_array(s, ' ');
355     IF array_upper(words, 1) IS NOT NULL THEN
356       FOR j IN 1..array_upper(words, 1) LOOP
357         IF (words[j] != '') THEN
358           w = getorcreate_word_id(words[j]);
359           IF w IS NOT NULL AND NOT (ARRAY[w] <@ result) THEN
360             result := result || w;
361           END IF;
362         END IF;
363       END LOOP;
364     END IF;
365
366     words := regexp_split_to_array(item.value, E'[,;()]');
367     IF array_upper(words, 1) != 1 THEN
368       FOR j IN 1..array_upper(words, 1) LOOP
369         s := make_standard_name(words[j]);
370         IF s != '' THEN
371           w := getorcreate_word_id(s);
372           IF w IS NOT NULL AND NOT (ARRAY[w] <@ result) THEN
373             result := result || w;
374           END IF;
375         END IF;
376       END LOOP;
377     END IF;
378
379     s := regexp_replace(item.value, '市$', '');
380     IF s != item.value THEN
381       s := make_standard_name(s);
382       IF s != '' THEN
383         w := getorcreate_name_id(s, item.value);
384         IF NOT (ARRAY[w] <@ result) THEN
385           result := result || w;
386         END IF;
387       END IF;
388     END IF;
389
390   END LOOP;
391
392   RETURN result;
393 END;
394 $$
395 LANGUAGE plpgsql IMMUTABLE;
396
397 CREATE OR REPLACE FUNCTION make_keywords(src TEXT) RETURNS INTEGER[]
398   AS $$
399 DECLARE
400   result INTEGER[];
401   s TEXT;
402   w INTEGER;
403   words TEXT[];
404   i INTEGER;
405   j INTEGER;
406 BEGIN
407   result := '{}'::INTEGER[];
408
409   s := make_standard_name(src);
410   w := getorcreate_name_id(s, src);
411
412   IF NOT (ARRAY[w] <@ result) THEN
413     result := result || w;
414   END IF;
415
416   w := getorcreate_word_id(s);
417
418   IF w IS NOT NULL AND NOT (ARRAY[w] <@ result) THEN
419     result := result || w;
420   END IF;
421
422   words := string_to_array(s, ' ');
423   IF array_upper(words, 1) IS NOT NULL THEN
424     FOR j IN 1..array_upper(words, 1) LOOP
425       IF (words[j] != '') THEN
426         w = getorcreate_word_id(words[j]);
427         IF w IS NOT NULL AND NOT (ARRAY[w] <@ result) THEN
428           result := result || w;
429         END IF;
430       END IF;
431     END LOOP;
432   END IF;
433
434   words := regexp_split_to_array(src, E'[,;()]');
435   IF array_upper(words, 1) != 1 THEN
436     FOR j IN 1..array_upper(words, 1) LOOP
437       s := make_standard_name(words[j]);
438       IF s != '' THEN
439         w := getorcreate_word_id(s);
440         IF w IS NOT NULL AND NOT (ARRAY[w] <@ result) THEN
441           result := result || w;
442         END IF;
443       END IF;
444     END LOOP;
445   END IF;
446
447   s := regexp_replace(src, '市$', '');
448   IF s != src THEN
449     s := make_standard_name(s);
450     IF s != '' THEN
451       w := getorcreate_name_id(s, src);
452       IF NOT (ARRAY[w] <@ result) THEN
453         result := result || w;
454       END IF;
455     END IF;
456   END IF;
457
458   RETURN result;
459 END;
460 $$
461 LANGUAGE plpgsql IMMUTABLE;
462
463 CREATE OR REPLACE FUNCTION get_word_score(wordscores wordscore[], words text[]) RETURNS integer
464   AS $$
465 DECLARE
466   idxword integer;
467   idxscores integer;
468   result integer;
469 BEGIN
470   IF (wordscores is null OR words is null) THEN
471     RETURN 0;
472   END IF;
473
474   result := 0;
475   FOR idxword in 1 .. array_upper(words, 1) LOOP
476     FOR idxscores in 1 .. array_upper(wordscores, 1) LOOP
477       IF wordscores[idxscores].word = words[idxword] THEN
478         result := result + wordscores[idxscores].score;
479       END IF;
480     END LOOP;
481   END LOOP;
482
483   RETURN result;
484 END;
485 $$
486 LANGUAGE plpgsql IMMUTABLE;
487
488 CREATE OR REPLACE FUNCTION get_country_code(place geometry) RETURNS TEXT
489   AS $$
490 DECLARE
491   place_centre GEOMETRY;
492   nearcountry RECORD;
493 BEGIN
494   place_centre := ST_PointOnSurface(place);
495
496 --DEBUG: RAISE WARNING 'get_country_code, start: %', ST_AsText(place_centre);
497
498   -- Try for a OSM polygon
499   FOR nearcountry IN select country_code from location_area_country where country_code is not null and not isguess and st_covers(geometry, place_centre) limit 1
500   LOOP
501     RETURN nearcountry.country_code;
502   END LOOP;
503
504 --DEBUG: RAISE WARNING 'osm fallback: %', ST_AsText(place_centre);
505
506   -- Try for OSM fallback data
507   -- The order is to deal with places like HongKong that are 'states' within another polygon
508   FOR nearcountry IN select country_code from country_osm_grid where st_covers(geometry, place_centre) order by area asc limit 1
509   LOOP
510     RETURN nearcountry.country_code;
511   END LOOP;
512
513 --DEBUG: RAISE WARNING 'natural earth: %', ST_AsText(place_centre);
514
515   -- Natural earth data
516   FOR nearcountry IN select country_code from country_naturalearthdata where st_covers(geometry, place_centre) limit 1
517   LOOP
518     RETURN nearcountry.country_code;
519   END LOOP;
520
521 --DEBUG: RAISE WARNING 'near osm fallback: %', ST_AsText(place_centre);
522
523   -- 
524   FOR nearcountry IN select country_code from country_osm_grid where st_dwithin(geometry, place_centre, 0.5) order by st_distance(geometry, place_centre) asc, area asc limit 1
525   LOOP
526     RETURN nearcountry.country_code;
527   END LOOP;
528
529 --DEBUG: RAISE WARNING 'near natural earth: %', ST_AsText(place_centre);
530
531   -- Natural earth data 
532   FOR nearcountry IN select country_code from country_naturalearthdata where st_dwithin(geometry, place_centre, 0.5) limit 1
533   LOOP
534     RETURN nearcountry.country_code;
535   END LOOP;
536
537   -- WorldBoundaries data (second fallback - think there might be something broken in this data)
538 --  FOR nearcountry IN select country_code from country where st_covers(geometry, place_centre) limit 1
539 --  LOOP
540 --    RETURN nearcountry.country_code;
541 --  END LOOP;
542
543 --RAISE WARNING 'near country: %', ST_AsText(place_centre);
544
545   -- Still not in a country - try nearest within ~12 miles of a country
546 --  FOR nearcountry IN select country_code from country where st_distance(geometry, place_centre) < 0.5 
547 --    order by st_distance(geometry, place) limit 1
548 --  LOOP
549 --    RETURN nearcountry.country_code;
550 --  END LOOP;
551
552   RETURN NULL;
553 END;
554 $$
555 LANGUAGE plpgsql IMMUTABLE;
556
557 CREATE OR REPLACE FUNCTION get_country_language_code(search_country_code VARCHAR(2)) RETURNS TEXT
558   AS $$
559 DECLARE
560   nearcountry RECORD;
561 BEGIN
562   FOR nearcountry IN select distinct country_default_language_code from country_name where country_code = search_country_code limit 1
563   LOOP
564     RETURN lower(nearcountry.country_default_language_code);
565   END LOOP;
566   RETURN NULL;
567 END;
568 $$
569 LANGUAGE plpgsql IMMUTABLE;
570
571 CREATE OR REPLACE FUNCTION get_country_language_codes(search_country_code VARCHAR(2)) RETURNS TEXT[]
572   AS $$
573 DECLARE
574   nearcountry RECORD;
575 BEGIN
576   FOR nearcountry IN select country_default_language_codes from country_name where country_code = search_country_code limit 1
577   LOOP
578     RETURN lower(nearcountry.country_default_language_codes);
579   END LOOP;
580   RETURN NULL;
581 END;
582 $$
583 LANGUAGE plpgsql IMMUTABLE;
584
585 CREATE OR REPLACE FUNCTION get_partition(in_country_code VARCHAR(10)) RETURNS INTEGER
586   AS $$
587 DECLARE
588   nearcountry RECORD;
589 BEGIN
590   FOR nearcountry IN select partition from country_name where country_code = in_country_code
591   LOOP
592     RETURN nearcountry.partition;
593   END LOOP;
594   RETURN 0;
595 END;
596 $$
597 LANGUAGE plpgsql IMMUTABLE;
598
599 CREATE OR REPLACE FUNCTION delete_location(OLD_place_id BIGINT) RETURNS BOOLEAN
600   AS $$
601 DECLARE
602 BEGIN
603   DELETE FROM location_area where place_id = OLD_place_id;
604 -- TODO:location_area
605   RETURN true;
606 END;
607 $$
608 LANGUAGE plpgsql;
609
610 CREATE OR REPLACE FUNCTION add_location(
611     place_id BIGINT,
612     country_code varchar(2),
613     partition INTEGER,
614     keywords INTEGER[],
615     rank_search INTEGER,
616     rank_address INTEGER,
617     geometry GEOMETRY
618   ) 
619   RETURNS BOOLEAN
620   AS $$
621 DECLARE
622   locationid INTEGER;
623   isarea BOOLEAN;
624   centroid GEOMETRY;
625   diameter FLOAT;
626   x BOOLEAN;
627   splitGeom RECORD;
628   secgeo GEOMETRY;
629 BEGIN
630
631   IF rank_search > 25 THEN
632     RAISE EXCEPTION 'Adding location with rank > 25 (% rank %)', place_id, rank_search;
633   END IF;
634
635 --  RAISE WARNING 'Adding location with rank > 25 (% rank %)', place_id, rank_search;
636
637   x := deleteLocationArea(partition, place_id, rank_search);
638
639   isarea := false;
640   IF (ST_GeometryType(geometry) in ('ST_Polygon','ST_MultiPolygon') AND ST_IsValid(geometry)) THEN
641
642     isArea := true;
643     centroid := ST_Centroid(geometry);
644
645     FOR secgeo IN select split_geometry(geometry) AS geom LOOP
646       x := insertLocationAreaLarge(partition, place_id, country_code, keywords, rank_search, rank_address, false, centroid, secgeo);
647     END LOOP;
648
649   ELSEIF rank_search < 26 THEN
650
651     diameter := 0.02;
652     IF rank_address = 0 THEN
653       diameter := 0.02;
654     ELSEIF rank_search <= 14 THEN
655       diameter := 1.2;
656     ELSEIF rank_search <= 15 THEN
657       diameter := 1;
658     ELSEIF rank_search <= 16 THEN
659       diameter := 0.5;
660     ELSEIF rank_search <= 17 THEN
661       diameter := 0.2;
662     ELSEIF rank_search <= 21 THEN
663       diameter := 0.05;
664     ELSEIF rank_search = 25 THEN
665       diameter := 0.005;
666     END IF;
667
668 --    RAISE WARNING 'adding % diameter %', place_id, diameter;
669
670     secgeo := ST_Buffer(geometry, diameter);
671     x := insertLocationAreaLarge(partition, place_id, country_code, keywords, rank_search, rank_address, true, ST_Centroid(geometry), secgeo);
672
673   ELSE
674
675     -- ~ 20meters
676     secgeo := ST_Buffer(geometry, 0.0002);
677     x := insertLocationAreaRoadNear(partition, place_id, country_code, keywords, rank_search, rank_address, true, ST_Centroid(geometry), secgeo);
678
679     -- ~ 100meters
680     secgeo := ST_Buffer(geometry, 0.001);
681     x := insertLocationAreaRoadFar(partition, place_id, country_code, keywords, rank_search, rank_address, true, ST_Centroid(geometry), secgeo);
682
683   END IF;
684
685   RETURN true;
686 END;
687 $$
688 LANGUAGE plpgsql;
689
690 CREATE OR REPLACE FUNCTION update_location(
691     partition INTEGER,
692     place_id BIGINT,
693     place_country_code varchar(2),
694     name hstore,
695     rank_search INTEGER,
696     rank_address INTEGER,
697     geometry GEOMETRY
698   ) 
699   RETURNS BOOLEAN
700   AS $$
701 DECLARE
702   b BOOLEAN;
703 BEGIN
704   b := deleteLocationArea(partition, place_id, rank_search);
705 --  result := add_location(NEW.place_id, NEW.country_code, NEW.partition, name_vector, NEW.rank_search, NEW.rank_address, NEW.geometry);
706   RETURN add_location(place_id, place_country_code, name, rank_search, rank_address, geometry);
707 END;
708 $$
709 LANGUAGE plpgsql;
710
711 CREATE OR REPLACE FUNCTION search_name_add_words(parent_place_id BIGINT, to_add INTEGER[])
712   RETURNS BOOLEAN
713   AS $$
714 DECLARE
715   childplace RECORD;
716 BEGIN
717
718   IF #to_add = 0 THEN
719     RETURN true;
720   END IF;
721
722   -- this should just be an update, but it seems to do insane things to the index size (delete and insert doesn't)
723   FOR childplace IN select * from search_name,place_addressline 
724     where  address_place_id = parent_place_id
725       and search_name.place_id = place_addressline.place_id
726   LOOP
727     delete from search_name where place_id = childplace.place_id;
728     IF not (ARRAY[to_add] <@ childplace.nameaddress_vector) THEN
729       childplace.nameaddress_vector := childplace.nameaddress_vector || to_add;
730     END IF;
731     IF childplace.place_id = parent_place_id and not (ARRAY[to_add] <@ childplace.name_vector) THEN
732       childplace.name_vector := childplace.name_vector || to_add;
733     END IF;
734     insert into search_name (place_id, search_rank, address_rank, country_code, name_vector, nameaddress_vector, centroid) 
735       values (childplace.place_id, childplace.search_rank, childplace.address_rank, childplace.country_code, 
736         childplace.name_vector, childplace.nameaddress_vector, childplace.centroid);
737   END LOOP;
738
739   RETURN true;
740 END;
741 $$
742 LANGUAGE plpgsql;
743
744 CREATE OR REPLACE FUNCTION update_location_nameonly(partition INTEGER, OLD_place_id BIGINT, name hstore) RETURNS BOOLEAN
745   AS $$
746 DECLARE
747   newkeywords INTEGER[];
748   addedkeywords INTEGER[];
749   removedkeywords INTEGER[];
750 BEGIN
751
752   -- what has changed?
753   newkeywords := make_keywords(name);
754   select coalesce(newkeywords,'{}'::INTEGER[]) - coalesce(location_point.keywords,'{}'::INTEGER[]), 
755     coalesce(location_point.keywords,'{}'::INTEGER[]) - coalesce(newkeywords,'{}'::INTEGER[]) from location_point 
756     where place_id = OLD_place_id into addedkeywords, removedkeywords;
757
758 --  RAISE WARNING 'update_location_nameonly for %: new:% added:% removed:%', OLD_place_id, newkeywords, addedkeywords, removedkeywords;
759
760   IF #removedkeywords > 0 THEN
761     -- abort due to tokens removed
762     RETURN false;
763   END IF;
764   
765   IF #addedkeywords > 0 THEN
766     -- short circuit - no changes
767     RETURN true;
768   END IF;
769
770   UPDATE location_area set keywords = newkeywords where place_id = OLD_place_id;
771   RETURN search_name_add_words(OLD_place_id, addedkeywords);
772 END;
773 $$
774 LANGUAGE plpgsql;
775
776
777 CREATE OR REPLACE FUNCTION create_interpolation(wayid BIGINT, interpolationtype TEXT) RETURNS INTEGER
778   AS $$
779 DECLARE
780   
781   newpoints INTEGER;
782   waynodes BIGINT[];
783   nodeid BIGINT;
784   prevnode RECORD;
785   nextnode RECORD;
786   startnumber INTEGER;
787   endnumber INTEGER;
788   stepsize INTEGER;
789   orginalstartnumber INTEGER;
790   originalnumberrange INTEGER;
791   housenum INTEGER;
792   linegeo GEOMETRY;
793   search_place_id BIGINT;
794   defpostalcode TEXT;
795
796   havefirstpoint BOOLEAN;
797   linestr TEXT;
798 BEGIN
799   newpoints := 0;
800   IF interpolationtype = 'odd' OR interpolationtype = 'even' OR interpolationtype = 'all' THEN
801
802     select postcode from placex where osm_type = 'W' and osm_id = wayid INTO defpostalcode;
803     select nodes from planet_osm_ways where id = wayid INTO waynodes;
804 --RAISE WARNING 'interpolation % % %',wayid,interpolationtype,waynodes;
805     IF array_upper(waynodes, 1) IS NOT NULL THEN
806
807       havefirstpoint := false;
808
809       FOR nodeidpos in 1..array_upper(waynodes, 1) LOOP
810
811         -- If there is a place of a type other than place/house, use that because
812         -- it is guaranteed to be the original node. For place/house types use the
813         -- one with the smallest id because the original node was created first.
814         -- Ignore all nodes marked for deletion. (Might happen when the type changes.)
815         select place_id from placex where osm_type = 'N' and osm_id = waynodes[nodeidpos]::BIGINT and indexed_status < 100 order by (type = 'house'),place_id limit 1 INTO search_place_id;
816         IF search_place_id IS NULL THEN
817           -- if no such node exists, create a record of the right type
818           select * from placex where osm_type = 'N' and osm_id = waynodes[nodeidpos]::BIGINT and type = 'house' limit 1 INTO nextnode;
819           select ST_SetSRID(ST_Point(lon::float/10000000,lat::float/10000000),4326) from planet_osm_nodes where id = waynodes[nodeidpos] INTO nextnode.geometry;
820           IF nextnode.geometry IS NULL THEN
821             -- we don't have any information about this point, most likely
822             -- because an excerpt was updated and the node never imported
823             -- because the interpolation is outside the region of the excerpt.
824             -- Give up.
825             RETURN newpoints;
826           END IF;
827         ELSE
828           select * from placex where place_id = search_place_id INTO nextnode;
829         END IF;
830
831 --RAISE WARNING 'interpolation node % % % ',nextnode.housenumber,ST_X(nextnode.geometry),ST_Y(nextnode.geometry);
832       
833         IF havefirstpoint THEN
834
835           -- add point to the line string
836           linestr := linestr||','||ST_X(nextnode.geometry)||' '||ST_Y(nextnode.geometry);
837           endnumber := ('0'||substring(nextnode.housenumber,'[0-9]+'))::integer;
838
839           IF startnumber IS NOT NULL and startnumber > 0 AND endnumber IS NOT NULL and endnumber > 0 AND @(startnumber - endnumber) < 1000 THEN
840
841 --RAISE WARNING 'interpolation end % % ',nextnode.place_id,endnumber;
842
843             IF startnumber != endnumber THEN
844
845               linestr := linestr || ')';
846 --RAISE WARNING 'linestr %',linestr;
847               linegeo := ST_GeomFromText(linestr,4326);
848               linestr := 'LINESTRING('||ST_X(nextnode.geometry)||' '||ST_Y(nextnode.geometry);
849               IF (startnumber > endnumber) THEN
850                 housenum := endnumber;
851                 endnumber := startnumber;
852                 startnumber := housenum;
853                 linegeo := ST_Reverse(linegeo);
854               END IF;
855               orginalstartnumber := startnumber;
856               originalnumberrange := endnumber - startnumber;
857
858 -- Too much broken data worldwide for this test to be worth using
859 --              IF originalnumberrange > 500 THEN
860 --                RAISE WARNING 'Number block of % while processing % %', originalnumberrange, prevnode, nextnode;
861 --              END IF;
862
863               IF (interpolationtype = 'odd' AND startnumber%2 = 0) OR (interpolationtype = 'even' AND startnumber%2 = 1) THEN
864                 startnumber := startnumber + 1;
865                 stepsize := 2;
866               ELSE
867                 IF (interpolationtype = 'odd' OR interpolationtype = 'even') THEN
868                   startnumber := startnumber + 2;
869                   stepsize := 2;
870                 ELSE -- everything else assumed to be 'all'
871                   startnumber := startnumber + 1;
872                   stepsize := 1;
873                 END IF;
874               END IF;
875               endnumber := endnumber - 1;
876               delete from placex where osm_type = 'N' and osm_id = prevnode.osm_id and type = 'house' and place_id != prevnode.place_id;
877               FOR housenum IN startnumber..endnumber BY stepsize LOOP
878                 -- this should really copy postcodes but it puts a huge burdon on the system for no big benefit
879                 -- ideally postcodes should move up to the way
880                 insert into placex (osm_type, osm_id, class, type, admin_level, housenumber, street, addr_place, isin, postcode,
881                   country_code, parent_place_id, rank_address, rank_search, indexed_status, geometry)
882                   values ('N',prevnode.osm_id, 'place', 'house', prevnode.admin_level, housenum, prevnode.street, prevnode.addr_place, prevnode.isin, coalesce(prevnode.postcode, defpostalcode),
883                   prevnode.country_code, prevnode.parent_place_id, prevnode.rank_address, prevnode.rank_search, 1, ST_LineInterpolatePoint(linegeo, (housenum::float-orginalstartnumber::float)/originalnumberrange::float));
884                 newpoints := newpoints + 1;
885 --RAISE WARNING 'interpolation number % % ',prevnode.place_id,housenum;
886               END LOOP;
887             END IF;
888             havefirstpoint := false;
889           END IF;
890         END IF;
891
892         IF NOT havefirstpoint THEN
893           startnumber := ('0'||substring(nextnode.housenumber,'[0-9]+'))::integer;
894           IF startnumber IS NOT NULL AND startnumber > 0 THEN
895             havefirstpoint := true;
896             linestr := 'LINESTRING('||ST_X(nextnode.geometry)||' '||ST_Y(nextnode.geometry);
897             prevnode := nextnode;
898           END IF;
899 --RAISE WARNING 'interpolation start % % ',nextnode.place_id,startnumber;
900         END IF;
901       END LOOP;
902     END IF;
903   END IF;
904
905 --RAISE WARNING 'interpolation points % ',newpoints;
906
907   RETURN newpoints;
908 END;
909 $$
910 LANGUAGE plpgsql;
911
912 CREATE OR REPLACE FUNCTION placex_insert() RETURNS TRIGGER
913   AS $$
914 DECLARE
915   i INTEGER;
916   postcode TEXT;
917   result BOOLEAN;
918   country_code VARCHAR(2);
919   default_language VARCHAR(10);
920   diameter FLOAT;
921   classtable TEXT;
922 BEGIN
923   --DEBUG: RAISE WARNING '% %',NEW.osm_type,NEW.osm_id;
924
925   -- remove operator tag for most places, messes too much with search_name indexes
926   IF NEW.class not in ('amenity', 'shop') THEN
927     NEW.name := delete(NEW.name, 'operator');
928   END IF;
929
930   -- just block these
931   IF NEW.class in ('landuse','natural') and NEW.name is null THEN
932 --    RAISE WARNING 'empty landuse %',NEW.osm_id;
933     RETURN null;
934   END IF;
935
936   IF ST_IsEmpty(NEW.geometry) OR NOT ST_IsValid(NEW.geometry) OR ST_X(ST_Centroid(NEW.geometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEW.geometry))::text in ('NaN','Infinity','-Infinity') THEN  
937     -- block all invalid geometary - just not worth the risk.  seg faults are causing serious problems.
938     RAISE WARNING 'invalid geometry %',NEW.osm_id;
939     RETURN NULL;
940
941     -- Dead code
942     IF NEW.osm_type = 'R' THEN
943       -- invalid multipolygons can crash postgis, don't even bother to try!
944       RETURN NULL;
945     END IF;
946     NEW.geometry := ST_buffer(NEW.geometry,0);
947     IF ST_IsEmpty(NEW.geometry) OR NOT ST_IsValid(NEW.geometry) OR ST_X(ST_Centroid(NEW.geometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEW.geometry))::text in ('NaN','Infinity','-Infinity') THEN  
948       RAISE WARNING 'Invalid geometary, rejecting: % %', NEW.osm_type, NEW.osm_id;
949       RETURN NULL;
950     END IF;
951   END IF;
952
953   --DEBUG: RAISE WARNING '% % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
954
955   NEW.place_id := nextval('seq_place');
956   NEW.indexed_status := 1; --STATUS_NEW
957
958   NEW.calculated_country_code := lower(get_country_code(NEW.geometry));
959
960   NEW.partition := get_partition(NEW.calculated_country_code);
961   NEW.geometry_sector := geometry_sector(NEW.partition, NEW.geometry);
962
963   -- copy 'name' to or from the default language (if there is a default language)
964   IF NEW.name is not null AND array_upper(akeys(NEW.name),1) > 1 THEN
965     default_language := get_country_language_code(NEW.calculated_country_code);
966     IF default_language IS NOT NULL THEN
967       IF NEW.name ? 'name' AND NOT NEW.name ? ('name:'||default_language) THEN
968         NEW.name := NEW.name || hstore(('name:'||default_language), (NEW.name -> 'name'));
969       ELSEIF NEW.name ? ('name:'||default_language) AND NOT NEW.name ? 'name' THEN
970         NEW.name := NEW.name || hstore('name', (NEW.name -> ('name:'||default_language)));
971       END IF;
972     END IF;
973   END IF;
974
975   IF NEW.admin_level > 15 THEN
976     NEW.admin_level := 15;
977   END IF;
978
979   IF NEW.housenumber IS NOT NULL THEN
980     i := getorcreate_housenumber_id(make_standard_name(NEW.housenumber));
981   END IF;
982
983   IF NEW.osm_type = 'X' THEN
984     -- E'X'ternal records should already be in the right format so do nothing
985   ELSE
986     NEW.rank_search := 30;
987     NEW.rank_address := NEW.rank_search;
988
989     -- By doing in postgres we have the country available to us - currently only used for postcode
990     IF NEW.class in ('place','boundary') AND NEW.type in ('postcode','postal_code') THEN
991
992         IF NEW.postcode IS NULL THEN
993             -- most likely just a part of a multipolygon postcode boundary, throw it away
994             RETURN NULL;
995         END IF;
996
997         NEW.name := hstore('ref', NEW.postcode);
998
999         IF NEW.calculated_country_code = 'gb' THEN
1000
1001           IF NEW.postcode ~ '^([A-Z][A-Z]?[0-9][0-9A-Z]? [0-9][A-Z][A-Z])$' THEN
1002             NEW.rank_search := 25;
1003             NEW.rank_address := 5;
1004           ELSEIF NEW.postcode ~ '^([A-Z][A-Z]?[0-9][0-9A-Z]? [0-9])$' THEN
1005             NEW.rank_search := 23;
1006             NEW.rank_address := 5;
1007           ELSEIF NEW.postcode ~ '^([A-Z][A-Z]?[0-9][0-9A-Z])$' THEN
1008             NEW.rank_search := 21;
1009             NEW.rank_address := 5;
1010           END IF;
1011
1012         ELSEIF NEW.calculated_country_code = 'de' THEN
1013
1014           IF NEW.postcode ~ '^([0-9]{5})$' THEN
1015             NEW.rank_search := 21;
1016             NEW.rank_address := 11;
1017           END IF;
1018
1019         ELSE
1020           -- Guess at the postcode format and coverage (!)
1021           IF upper(NEW.postcode) ~ '^[A-Z0-9]{1,5}$' THEN -- Probably too short to be very local
1022             NEW.rank_search := 21;
1023             NEW.rank_address := 11;
1024           ELSE
1025             -- Does it look splitable into and area and local code?
1026             postcode := substring(upper(NEW.postcode) from '^([- :A-Z0-9]+)([- :][A-Z0-9]+)$');
1027
1028             IF postcode IS NOT NULL THEN
1029               NEW.rank_search := 25;
1030               NEW.rank_address := 11;
1031             ELSEIF NEW.postcode ~ '^[- :A-Z0-9]{6,}$' THEN
1032               NEW.rank_search := 21;
1033               NEW.rank_address := 11;
1034             END IF;
1035           END IF;
1036         END IF;
1037
1038     ELSEIF NEW.class = 'place' THEN
1039       IF NEW.type in ('continent') THEN
1040         NEW.rank_search := 2;
1041         NEW.rank_address := NEW.rank_search;
1042         NEW.calculated_country_code := NULL;
1043       ELSEIF NEW.type in ('sea') THEN
1044         NEW.rank_search := 2;
1045         NEW.rank_address := 0;
1046         NEW.calculated_country_code := NULL;
1047       ELSEIF NEW.type in ('country') THEN
1048         NEW.rank_search := 4;
1049         NEW.rank_address := NEW.rank_search;
1050       ELSEIF NEW.type in ('state') THEN
1051         NEW.rank_search := 8;
1052         NEW.rank_address := NEW.rank_search;
1053       ELSEIF NEW.type in ('region') THEN
1054         NEW.rank_search := 18; -- dropped from previous value of 10
1055         NEW.rank_address := 0; -- So badly miss-used that better to just drop it!
1056       ELSEIF NEW.type in ('county') THEN
1057         NEW.rank_search := 12;
1058         NEW.rank_address := NEW.rank_search;
1059       ELSEIF NEW.type in ('city') THEN
1060         NEW.rank_search := 16;
1061         NEW.rank_address := NEW.rank_search;
1062       ELSEIF NEW.type in ('island') THEN
1063         NEW.rank_search := 17;
1064         NEW.rank_address := 0;
1065       ELSEIF NEW.type in ('town') THEN
1066         NEW.rank_search := 18;
1067         NEW.rank_address := 16;
1068       ELSEIF NEW.type in ('village','hamlet','municipality','district','unincorporated_area','borough') THEN
1069         NEW.rank_search := 19;
1070         NEW.rank_address := 16;
1071       ELSEIF NEW.type in ('suburb','croft','subdivision','isolated_dwelling') THEN
1072         NEW.rank_search := 20;
1073         NEW.rank_address := NEW.rank_search;
1074       ELSEIF NEW.type in ('farm','locality','islet','mountain_pass') THEN
1075         NEW.rank_search := 20;
1076         NEW.rank_address := 0;
1077         -- Irish townlands, tagged as place=locality and locality=townland
1078         IF (NEW.extratags -> 'locality') = 'townland' THEN
1079           NEW.rank_address := 20;
1080         END IF;
1081       ELSEIF NEW.type in ('neighbourhood') THEN
1082         NEW.rank_search := 22;
1083         NEW.rank_address := 22;
1084       ELSEIF NEW.type in ('house','building') THEN
1085         NEW.rank_search := 30;
1086         NEW.rank_address := NEW.rank_search;
1087       ELSEIF NEW.type in ('houses') THEN
1088         -- can't guarantee all required nodes loaded yet due to caching in osm2pgsql
1089         -- insert new point into place for each derived building
1090         --i := create_interpolation(NEW.osm_id, NEW.housenumber);
1091         NEW.rank_search := 28;
1092         NEW.rank_address := 0;
1093       END IF;
1094
1095     ELSEIF NEW.class = 'boundary' THEN
1096       IF ST_GeometryType(NEW.geometry) NOT IN ('ST_Polygon','ST_MultiPolygon') THEN
1097 --        RAISE WARNING 'invalid boundary %',NEW.osm_id;
1098         return NULL;
1099       END IF;
1100       NEW.rank_search := NEW.admin_level * 2;
1101       IF NEW.type = 'administrative' THEN
1102         NEW.rank_address := NEW.rank_search;
1103       ELSE
1104         NEW.rank_address := 0;
1105       END IF;
1106     ELSEIF NEW.class = 'landuse' AND ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon') THEN
1107       NEW.rank_search := 22;
1108       NEW.rank_address := NEW.rank_search;
1109     ELSEIF NEW.class = 'natural' and NEW.type in ('peak','volcano','mountain_range') THEN
1110       NEW.rank_search := 18;
1111       NEW.rank_address := 0;
1112     -- any feature more than 5 square miles is probably worth indexing
1113     ELSEIF ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon') AND ST_Area(NEW.geometry) > 0.1 THEN
1114       NEW.rank_search := 22;
1115       NEW.rank_address := NEW.rank_search;
1116     ELSEIF NEW.class = 'highway' AND NEW.name is NULL AND 
1117            NEW.type in ('service','cycleway','path','footway','steps','bridleway','track','byway','motorway_link','primary_link','trunk_link','secondary_link','tertiary_link') THEN
1118 --      RAISE WARNING 'unnamed minor feature %',NEW.osm_id;
1119       RETURN NULL;
1120     ELSEIF NEW.class = 'railway' AND NEW.type in ('rail') THEN
1121       RETURN NULL;
1122     ELSEIF NEW.class = 'waterway' AND NEW.name is NULL THEN
1123       RETURN NULL;
1124     ELSEIF NEW.class = 'waterway' THEN
1125       NEW.rank_search := 17;
1126       NEW.rank_address := 0;
1127     ELSEIF NEW.class = 'highway' AND NEW.osm_type != 'N' AND NEW.type in ('service','cycleway','path','footway','steps','bridleway','motorway_link','primary_link','trunk_link','secondary_link','tertiary_link') THEN
1128       NEW.rank_search := 27;
1129       NEW.rank_address := NEW.rank_search;
1130     ELSEIF NEW.class = 'highway' AND NEW.osm_type != 'N' THEN
1131       NEW.rank_search := 26;
1132       NEW.rank_address := NEW.rank_search;
1133     ELSEIF NEW.class = 'natural' and NEW.type = 'sea' THEN
1134       NEW.rank_search := 4;
1135       NEW.rank_address := NEW.rank_search;
1136     ELSEIF NEW.class = 'natural' and NEW.type in ('coastline') THEN
1137       RETURN NULL;
1138     ELSEIF NEW.class = 'mountain_pass' THEN
1139         NEW.rank_search := 20;
1140         NEW.rank_address := 0;
1141     END IF;
1142
1143   END IF;
1144
1145   IF NEW.rank_search > 30 THEN
1146     NEW.rank_search := 30;
1147   END IF;
1148
1149   IF NEW.rank_address > 30 THEN
1150     NEW.rank_address := 30;
1151   END IF;
1152
1153   IF (NEW.extratags -> 'capital') = 'yes' THEN
1154     NEW.rank_search := NEW.rank_search - 1;
1155   END IF;
1156
1157   -- a country code make no sense below rank 4 (country)
1158   IF NEW.rank_search < 4 THEN
1159     NEW.calculated_country_code := NULL;
1160   END IF;
1161
1162 -- Block import below rank 22
1163 --  IF NEW.rank_search > 22 THEN
1164 --    RETURN NULL;
1165 --  END IF;
1166
1167   --DEBUG: RAISE WARNING 'placex_insert:END: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
1168
1169   RETURN NEW; -- @DIFFUPDATES@ The following is not needed until doing diff updates, and slows the main index process down
1170
1171   IF NEW.rank_address > 0 THEN
1172     IF (ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon') AND ST_IsValid(NEW.geometry)) THEN
1173       -- Performance: We just can't handle re-indexing for country level changes
1174       IF st_area(NEW.geometry) < 1 THEN
1175         -- mark items within the geometry for re-indexing
1176   --    RAISE WARNING 'placex poly insert: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
1177
1178         -- work around bug in postgis, this may have been fixed in 2.0.0 (see http://trac.osgeo.org/postgis/ticket/547)
1179         update placex set indexed_status = 2 where (st_covers(NEW.geometry, placex.geometry) OR ST_Intersects(NEW.geometry, placex.geometry)) 
1180          AND rank_search > NEW.rank_search and indexed_status = 0 and ST_geometrytype(placex.geometry) = 'ST_Point' and (rank_search < 28 or name is not null or (NEW.rank_search >= 16 and addr_place is not null));
1181         update placex set indexed_status = 2 where (st_covers(NEW.geometry, placex.geometry) OR ST_Intersects(NEW.geometry, placex.geometry)) 
1182          AND rank_search > NEW.rank_search and indexed_status = 0 and ST_geometrytype(placex.geometry) != 'ST_Point' and (rank_search < 28 or name is not null or (NEW.rank_search >= 16 and addr_place is not null));
1183       END IF;
1184     ELSE
1185       -- mark nearby items for re-indexing, where 'nearby' depends on the features rank_search and is a complete guess :(
1186       diameter := 0;
1187       -- 16 = city, anything higher than city is effectively ignored (polygon required!)
1188       IF NEW.type='postcode' THEN
1189         diameter := 0.05;
1190       ELSEIF NEW.rank_search < 16 THEN
1191         diameter := 0;
1192       ELSEIF NEW.rank_search < 18 THEN
1193         diameter := 0.1;
1194       ELSEIF NEW.rank_search < 20 THEN
1195         diameter := 0.05;
1196       ELSEIF NEW.rank_search = 21 THEN
1197         diameter := 0.001;
1198       ELSEIF NEW.rank_search < 24 THEN
1199         diameter := 0.02;
1200       ELSEIF NEW.rank_search < 26 THEN
1201         diameter := 0.002; -- 100 to 200 meters
1202       ELSEIF NEW.rank_search < 28 THEN
1203         diameter := 0.001; -- 50 to 100 meters
1204       END IF;
1205       IF diameter > 0 THEN
1206   --      RAISE WARNING 'placex point insert: % % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type,diameter;
1207         IF NEW.rank_search >= 26 THEN
1208           -- roads may cause reparenting for >27 rank places
1209           update placex set indexed_status = 2 where indexed_status = 0 and rank_search > NEW.rank_search and ST_DWithin(placex.geometry, NEW.geometry, diameter);
1210         ELSEIF NEW.rank_search >= 16 THEN
1211           -- up to rank 16, street-less addresses may need reparenting
1212           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 addr_place is not null);
1213         ELSE
1214           -- for all other places the search terms may change as well
1215           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);
1216         END IF;
1217       END IF;
1218     END IF;
1219   END IF;
1220
1221    -- add to tables for special search
1222    -- Note: won't work on initial import because the classtype tables
1223    -- do not yet exist. It won't hurt either.
1224   classtable := 'place_classtype_' || NEW.class || '_' || NEW.type;
1225   SELECT count(*)>0 FROM pg_tables WHERE tablename = classtable and schemaname = current_schema() INTO result;
1226   IF result THEN
1227     EXECUTE 'INSERT INTO ' || classtable::regclass || ' (place_id, centroid) VALUES ($1,$2)' 
1228     USING NEW.place_id, ST_Centroid(NEW.geometry);
1229   END IF;
1230
1231
1232 --  IF NEW.rank_search < 26 THEN
1233 --    RAISE WARNING 'placex insert: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
1234 --  END IF;
1235
1236   RETURN NEW;
1237
1238 END;
1239 $$
1240 LANGUAGE plpgsql;
1241
1242 CREATE OR REPLACE FUNCTION placex_update() RETURNS 
1243 TRIGGER
1244   AS $$
1245 DECLARE
1246
1247   place_centroid GEOMETRY;
1248
1249   search_maxdistance FLOAT[];
1250   search_mindistance FLOAT[];
1251   address_havelevel BOOLEAN[];
1252 --  search_scores wordscore[];
1253 --  search_scores_pos INTEGER;
1254
1255   i INTEGER;
1256   iMax FLOAT;
1257   location RECORD;
1258   way RECORD;
1259   relation RECORD;
1260   relation_members TEXT[];
1261   relMember RECORD;
1262   linkedplacex RECORD;
1263   search_diameter FLOAT;
1264   search_prevdiameter FLOAT;
1265   search_maxrank INTEGER;
1266   address_maxrank INTEGER;
1267   address_street_word_id INTEGER;
1268   parent_place_id_rank BIGINT;
1269   
1270   isin TEXT[];
1271   isin_tokens INT[];
1272
1273   location_rank_search INTEGER;
1274   location_distance FLOAT;
1275   location_parent GEOMETRY;
1276   location_isaddress BOOLEAN;
1277
1278   tagpairid INTEGER;
1279
1280   default_language TEXT;
1281   name_vector INTEGER[];
1282   nameaddress_vector INTEGER[];
1283
1284   linked_node_id BIGINT;
1285
1286   result BOOLEAN;
1287 BEGIN
1288
1289   -- deferred delete
1290   IF OLD.indexed_status = 100 THEN
1291     --DEBUG: RAISE WARNING 'placex_update_delete % %',NEW.osm_type,NEW.osm_id;
1292     delete from placex where place_id = OLD.place_id;
1293     RETURN NULL;
1294   END IF;
1295
1296   IF NEW.indexed_status != 0 OR OLD.indexed_status = 0 THEN
1297     RETURN NEW;
1298   END IF;
1299
1300   --DEBUG: RAISE WARNING 'placex_update % %',NEW.osm_type,NEW.osm_id;
1301
1302 --RAISE WARNING '%',NEW.place_id;
1303 --RAISE WARNING '%', NEW;
1304
1305   IF NEW.class = 'place' AND NEW.type = 'postcodearea' THEN
1306     -- Silently do nothing
1307     RETURN NEW;
1308   END IF;
1309
1310   -- TODO: this test is now redundant?
1311   IF OLD.indexed_status != 0 THEN
1312
1313     NEW.indexed_date = now();
1314
1315     result := deleteSearchName(NEW.partition, NEW.place_id);
1316     DELETE FROM place_addressline WHERE place_id = NEW.place_id;
1317     DELETE FROM place_boundingbox where place_id = NEW.place_id;
1318     result := deleteRoad(NEW.partition, NEW.place_id);
1319     result := deleteLocationArea(NEW.partition, NEW.place_id, NEW.rank_search);
1320     UPDATE placex set linked_place_id = null where linked_place_id = NEW.place_id;
1321
1322     IF NEW.linked_place_id is not null THEN
1323       RETURN NEW;
1324     END IF;
1325
1326     IF NEW.class = 'place' AND NEW.type = 'houses' THEN
1327       i := create_interpolation(NEW.osm_id, NEW.housenumber);
1328       RETURN NEW;
1329     END IF;
1330
1331     -- Speed up searches - just use the centroid of the feature
1332     -- cheaper but less acurate
1333     place_centroid := ST_PointOnSurface(NEW.geometry);
1334     NEW.centroid := null;
1335
1336     -- reclaculate country and partition
1337     IF NEW.rank_search = 4 THEN
1338       -- for countries, believe the mapped country code,
1339       -- so that we remain in the right partition if the boundaries
1340       -- suddenly expand.
1341       NEW.partition := get_partition(lower(NEW.country_code));
1342       IF NEW.partition = 0 THEN
1343         NEW.calculated_country_code := lower(get_country_code(place_centroid));
1344         NEW.partition := get_partition(NEW.calculated_country_code);
1345       ELSE
1346         NEW.calculated_country_code := lower(NEW.country_code);
1347       END IF;
1348     ELSE
1349       IF NEW.rank_search > 4 THEN
1350         --NEW.calculated_country_code := lower(get_country_code(NEW.geometry, NEW.country_code));
1351         NEW.calculated_country_code := lower(get_country_code(place_centroid));
1352       ELSE
1353         NEW.calculated_country_code := NULL;
1354       END IF;
1355       NEW.partition := get_partition(NEW.calculated_country_code);
1356     END IF;
1357     NEW.geometry_sector := geometry_sector(NEW.partition, place_centroid);
1358
1359     -- Adding ourselves to the list simplifies address calculations later
1360     INSERT INTO place_addressline VALUES (NEW.place_id, NEW.place_id, true, true, 0, NEW.rank_address); 
1361
1362     -- What level are we searching from
1363     search_maxrank := NEW.rank_search;
1364
1365     -- Thought this wasn't needed but when we add new languages to the country_name table
1366     -- we need to update the existing names
1367     IF NEW.name is not null AND array_upper(akeys(NEW.name),1) > 1 THEN
1368       default_language := get_country_language_code(NEW.calculated_country_code);
1369       IF default_language IS NOT NULL THEN
1370         IF NEW.name ? 'name' AND NOT NEW.name ? ('name:'||default_language) THEN
1371           NEW.name := NEW.name || hstore(('name:'||default_language), (NEW.name -> 'name'));
1372         ELSEIF NEW.name ? ('name:'||default_language) AND NOT NEW.name ? 'name' THEN
1373           NEW.name := NEW.name || hstore('name', (NEW.name -> ('name:'||default_language)));
1374         END IF;
1375       END IF;
1376     END IF;
1377
1378     -- Initialise the name vector using our name
1379     name_vector := make_keywords(NEW.name);
1380     nameaddress_vector := '{}'::int[];
1381
1382     -- some tag combinations add a special id for search
1383     tagpairid := get_tagpair(NEW.class,NEW.type);
1384     IF tagpairid IS NOT NULL THEN
1385       name_vector := name_vector + tagpairid;
1386     END IF;
1387
1388     FOR i IN 1..28 LOOP
1389       address_havelevel[i] := false;
1390     END LOOP;
1391
1392     NEW.importance := null;
1393     select language||':'||title,importance from get_wikipedia_match(NEW.extratags, NEW.calculated_country_code) INTO NEW.wikipedia,NEW.importance;
1394     IF NEW.importance IS NULL THEN
1395       select language||':'||title,importance from wikipedia_article where osm_type = NEW.osm_type and osm_id = NEW.osm_id order by importance desc limit 1 INTO NEW.wikipedia,NEW.importance;
1396     END IF;
1397
1398 --RAISE WARNING 'before low level% %', NEW.place_id, NEW.rank_search;
1399
1400     -- For low level elements we inherit from our parent road
1401     IF (NEW.rank_search > 27 OR (NEW.type = 'postcode' AND NEW.rank_search = 25)) THEN
1402
1403 --RAISE WARNING 'finding street for %', NEW;
1404
1405       -- We won't get a better centroid, besides these places are too small to care
1406       NEW.centroid := place_centroid;
1407
1408       NEW.parent_place_id := null;
1409
1410       -- to do that we have to find our parent road
1411       -- Copy data from linked items (points on ways, addr:street links, relations)
1412       -- Note that addr:street links can only be indexed once the street itself is indexed
1413       IF NEW.parent_place_id IS NULL AND NEW.osm_type = 'N' THEN
1414
1415         -- Is this node part of a relation?
1416         FOR relation IN select * from planet_osm_rels where parts @> ARRAY[NEW.osm_id] and members @> ARRAY['n'||NEW.osm_id]
1417         LOOP
1418           -- At the moment we only process one type of relation - associatedStreet
1419           IF relation.tags @> ARRAY['associatedStreet'] AND array_upper(relation.members, 1) IS NOT NULL THEN
1420             FOR i IN 1..array_upper(relation.members, 1) BY 2 LOOP
1421               IF NEW.parent_place_id IS NULL AND relation.members[i+1] = 'street' THEN
1422 --RAISE WARNING 'node in relation %',relation;
1423                 SELECT place_id from placex where osm_type='W' and osm_id = substring(relation.members[i],2,200)::bigint 
1424                   and rank_search = 26 INTO NEW.parent_place_id;
1425               END IF;
1426             END LOOP;
1427           END IF;
1428         END LOOP;      
1429
1430 --RAISE WARNING 'x1';
1431         -- Is this node part of a way?
1432         FOR way IN select id from planet_osm_ways where nodes @> ARRAY[NEW.osm_id] LOOP
1433 --RAISE WARNING '%', way;
1434         FOR location IN select * from placex where osm_type = 'W' and osm_id = way.id
1435         LOOP
1436 --RAISE WARNING '%', location;
1437           -- Way IS a road then we are on it - that must be our road
1438           IF location.rank_search = 26 AND NEW.parent_place_id IS NULL THEN
1439 --RAISE WARNING 'node in way that is a street %',location;
1440             NEW.parent_place_id := location.place_id;
1441           END IF;
1442
1443           -- Is the WAY part of a relation
1444           IF NEW.parent_place_id IS NULL THEN
1445               FOR relation IN select * from planet_osm_rels where parts @> ARRAY[location.osm_id] and members @> ARRAY['w'||location.osm_id]
1446               LOOP
1447                 -- At the moment we only process one type of relation - associatedStreet
1448                 IF relation.tags @> ARRAY['associatedStreet'] AND array_upper(relation.members, 1) IS NOT NULL THEN
1449                   FOR i IN 1..array_upper(relation.members, 1) BY 2 LOOP
1450                     IF NEW.parent_place_id IS NULL AND relation.members[i+1] = 'street' THEN
1451     --RAISE WARNING 'node in way that is in a relation %',relation;
1452                       SELECT place_id from placex where osm_type='W' and osm_id = substring(relation.members[i],2,200)::bigint 
1453                         and rank_search = 26 INTO NEW.parent_place_id;
1454                     END IF;
1455                   END LOOP;
1456                 END IF;
1457               END LOOP;
1458           END IF;    
1459           
1460           -- If the way contains an explicit name of a street copy it
1461           IF NEW.street IS NULL AND NEW.addr_place IS NULL AND location.street IS NOT NULL THEN
1462 --RAISE WARNING 'node in way that has a streetname %',location;
1463             NEW.street := location.street;
1464           END IF;
1465
1466           -- IF the way contains an explicit name of a place copy it
1467           IF NEW.addr_place IS NULL AND NEW.street IS NULL AND location.addr_place IS NOT NULL THEN
1468             NEW.addr_place := location.addr_place;
1469           END IF;
1470
1471           -- If this way is a street interpolation line then it is probably as good as we are going to get
1472           IF NEW.parent_place_id IS NULL AND NEW.street IS NULL AND NEW.addr_place IS NULL AND location.class = 'place' and location.type='houses' THEN
1473             -- Try and find a way that is close roughly parellel to this line
1474             FOR relation IN SELECT place_id FROM placex
1475               WHERE ST_DWithin(location.geometry, placex.geometry, 0.001) and placex.rank_search = 26
1476                 and st_geometrytype(location.geometry) in ('ST_LineString')
1477               ORDER BY (ST_distance(placex.geometry, ST_LineInterpolatePoint(location.geometry,0))+
1478                         ST_distance(placex.geometry, ST_LineInterpolatePoint(location.geometry,0.5))+
1479                         ST_distance(placex.geometry, ST_LineInterpolatePoint(location.geometry,1))) ASC limit 1
1480             LOOP
1481 --RAISE WARNING 'using nearest street to address interpolation line,0.001 %',relation;
1482               NEW.parent_place_id := relation.place_id;
1483             END LOOP;
1484           END IF;
1485
1486         END LOOP;
1487         END LOOP;
1488                 
1489       END IF;
1490
1491 --RAISE WARNING 'x2';
1492
1493       IF NEW.parent_place_id IS NULL AND NEW.osm_type = 'W' THEN
1494         -- Is this way part of a relation?
1495         FOR relation IN select * from planet_osm_rels where parts @> ARRAY[NEW.osm_id] and members @> ARRAY['w'||NEW.osm_id]
1496         LOOP
1497           -- At the moment we only process one type of relation - associatedStreet
1498           IF relation.tags @> ARRAY['associatedStreet'] AND array_upper(relation.members, 1) IS NOT NULL THEN
1499             FOR i IN 1..array_upper(relation.members, 1) BY 2 LOOP
1500               IF NEW.parent_place_id IS NULL AND relation.members[i+1] = 'street' THEN
1501 --RAISE WARNING 'way that is in a relation %',relation;
1502                 SELECT place_id from placex where osm_type='W' and osm_id = substring(relation.members[i],2,200)::bigint
1503                   and rank_search = 26 INTO NEW.parent_place_id;
1504               END IF;
1505             END LOOP;
1506           END IF;
1507         END LOOP;
1508       END IF;
1509       
1510 --RAISE WARNING 'x3 %',NEW.parent_place_id;
1511
1512       IF NEW.parent_place_id IS NULL AND NEW.street IS NOT NULL THEN
1513         address_street_word_id := get_name_id(make_standard_name(NEW.street));
1514         IF address_street_word_id IS NOT NULL THEN
1515           FOR location IN SELECT * from getNearestNamedRoadFeature(NEW.partition, place_centroid, address_street_word_id) LOOP
1516               NEW.parent_place_id := location.place_id;
1517           END LOOP;
1518         END IF;
1519       END IF;
1520
1521       IF NEW.parent_place_id IS NULL AND NEW.addr_place IS NOT NULL THEN
1522         address_street_word_id := get_name_id(make_standard_name(NEW.addr_place));
1523         IF address_street_word_id IS NOT NULL THEN
1524           FOR location IN SELECT * from getNearestNamedPlaceFeature(NEW.partition, place_centroid, address_street_word_id) LOOP
1525             NEW.parent_place_id := location.place_id;
1526           END LOOP;
1527         END IF;
1528       END IF;
1529
1530 --RAISE WARNING 'x4 %',NEW.parent_place_id;
1531       -- Still nothing, just use the nearest road
1532       IF NEW.parent_place_id IS NULL THEN
1533         FOR location IN SELECT place_id FROM getNearestRoadFeature(NEW.partition, place_centroid) LOOP
1534           NEW.parent_place_id := location.place_id;
1535         END LOOP;
1536       END IF;
1537
1538 --return NEW;
1539 --RAISE WARNING 'x6 %',NEW.parent_place_id;
1540
1541       -- If we didn't find any road fallback to standard method
1542       IF NEW.parent_place_id IS NOT NULL THEN
1543
1544         -- Add the street to the address as zero distance to force to front of list
1545 --        INSERT INTO place_addressline VALUES (NEW.place_id, NEW.parent_place_id, true, true, 0, 26);
1546         address_havelevel[26] := true;
1547
1548         -- Import address details from parent, reclculating distance in process
1549 --        INSERT INTO place_addressline select NEW.place_id, x.address_place_id, x.fromarea, x.isaddress, ST_distance(NEW.geometry, placex.geometry), placex.rank_address
1550 --          from place_addressline as x join placex on (address_place_id = placex.place_id)
1551 --          where x.place_id = NEW.parent_place_id and x.address_place_id != NEW.parent_place_id;
1552
1553         -- Get the details of the parent road
1554         select * from search_name where place_id = NEW.parent_place_id INTO location;
1555         NEW.calculated_country_code := location.country_code;
1556
1557 --RAISE WARNING '%', NEW.name;
1558         -- If there is no name it isn't searchable, don't bother to create a search record
1559         IF NEW.name is NULL THEN
1560           return NEW;
1561         END IF;
1562
1563         -- Merge address from parent
1564         nameaddress_vector := array_merge(nameaddress_vector, location.nameaddress_vector);
1565         nameaddress_vector := array_merge(nameaddress_vector, location.name_vector);
1566 --return NEW;
1567         -- Performance, it would be more acurate to do all the rest of the import process but it takes too long
1568         -- Just be happy with inheriting from parent road only
1569
1570         IF NEW.rank_search <= 25 THEN
1571           result := add_location(NEW.place_id, NEW.calculated_country_code, NEW.partition, name_vector, NEW.rank_search, NEW.rank_address, NEW.geometry);
1572         END IF;
1573
1574         result := insertSearchName(NEW.partition, NEW.place_id, NEW.calculated_country_code, name_vector, nameaddress_vector, NEW.rank_search, NEW.rank_address, NEW.importance, place_centroid, NEW.geometry);
1575
1576         return NEW;
1577       END IF;
1578
1579     END IF;
1580
1581 -- RAISE WARNING '  INDEXING Started:';
1582 -- RAISE WARNING '  INDEXING: %',NEW;
1583
1584     IF NEW.osm_type = 'R' AND NEW.rank_search < 26 THEN
1585
1586       -- see if we have any special relation members
1587       select members from planet_osm_rels where id = NEW.osm_id INTO relation_members;
1588
1589 -- RAISE WARNING 'get_osm_rel_members, label';
1590       IF relation_members IS NOT NULL THEN
1591         FOR relMember IN select get_osm_rel_members(relation_members,ARRAY['label']) as member LOOP
1592
1593           FOR linkedPlacex IN select * from placex where osm_type = upper(substring(relMember.member,1,1))::char(1) 
1594             and osm_id = substring(relMember.member,2,10000)::bigint order by rank_search desc limit 1 LOOP
1595
1596             -- If we don't already have one use this as the centre point of the geometry
1597             IF NEW.centroid IS NULL THEN
1598               NEW.centroid := coalesce(linkedPlacex.centroid,st_centroid(linkedPlacex.geometry));
1599             END IF;
1600
1601             -- merge in the label name, re-init word vector
1602             IF NOT linkedPlacex.name IS NULL THEN
1603               NEW.name := linkedPlacex.name || NEW.name;
1604               name_vector := array_merge(name_vector, make_keywords(linkedPlacex.name));
1605             END IF;
1606
1607             -- merge in extra tags
1608             NEW.extratags := hstore(linkedPlacex.class, linkedPlacex.type) || coalesce(linkedPlacex.extratags, ''::hstore) || coalesce(NEW.extratags, ''::hstore);
1609
1610             -- mark the linked place (excludes from search results)
1611             UPDATE placex set linked_place_id = NEW.place_id where place_id = linkedPlacex.place_id;
1612
1613             -- keep a note of the node id in case we need it for wikipedia in a bit
1614             linked_node_id := linkedPlacex.osm_id;
1615           END LOOP;
1616
1617         END LOOP;
1618
1619         IF NEW.centroid IS NULL THEN
1620
1621           FOR relMember IN select get_osm_rel_members(relation_members,ARRAY['admin_center','admin_centre']) as member LOOP
1622
1623             FOR linkedPlacex IN select * from placex where osm_type = upper(substring(relMember.member,1,1))::char(1) 
1624               and osm_id = substring(relMember.member,2,10000)::bigint order by rank_search desc limit 1 LOOP
1625
1626               -- For an admin centre we also want a name match - still not perfect, for example 'new york, new york'
1627               -- But that can be fixed by explicitly setting the label in the data
1628               IF make_standard_name(NEW.name->'name') = make_standard_name(linkedPlacex.name->'name') 
1629                 AND NEW.rank_address = linkedPlacex.rank_address THEN
1630
1631                 -- If we don't already have one use this as the centre point of the geometry
1632                 IF NEW.centroid IS NULL THEN
1633                   NEW.centroid := coalesce(linkedPlacex.centroid,st_centroid(linkedPlacex.geometry));
1634                 END IF;
1635
1636                 -- merge in the name, re-init word vector
1637                 IF NOT linkedPlacex.name IS NULL THEN
1638                   NEW.name := linkedPlacex.name || NEW.name;
1639                   name_vector := make_keywords(NEW.name);
1640                 END IF;
1641
1642                 -- merge in extra tags
1643                 NEW.extratags := hstore(linkedPlacex.class, linkedPlacex.type) || coalesce(linkedPlacex.extratags, ''::hstore) || coalesce(NEW.extratags, ''::hstore);
1644
1645                 -- mark the linked place (excludes from search results)
1646                 UPDATE placex set linked_place_id = NEW.place_id where place_id = linkedPlacex.place_id;
1647
1648                 -- keep a note of the node id in case we need it for wikipedia in a bit
1649                 linked_node_id := linkedPlacex.osm_id;
1650               END IF;
1651
1652             END LOOP;
1653
1654           END LOOP;
1655
1656         END IF;
1657       END IF;
1658
1659     END IF;
1660
1661     -- Name searches can be done for ways as well as relations
1662     IF NEW.osm_type in ('W','R') AND NEW.rank_search < 26 THEN
1663
1664       -- not found one yet? how about doing a name search
1665       IF NEW.centroid IS NULL AND (NEW.name->'name') is not null and make_standard_name(NEW.name->'name') != '' THEN
1666
1667         FOR linkedPlacex IN select placex.* from placex WHERE
1668           make_standard_name(name->'name') = make_standard_name(NEW.name->'name')
1669           AND placex.rank_address = NEW.rank_address
1670           AND placex.place_id != NEW.place_id
1671           AND placex.osm_type = 'N'::char(1) AND placex.rank_search < 26
1672           AND st_covers(NEW.geometry, placex.geometry)
1673         LOOP
1674
1675           -- If we don't already have one use this as the centre point of the geometry
1676           IF NEW.centroid IS NULL THEN
1677             NEW.centroid := coalesce(linkedPlacex.centroid,st_centroid(linkedPlacex.geometry));
1678           END IF;
1679
1680           -- merge in the name, re-init word vector
1681           NEW.name := linkedPlacex.name || NEW.name;
1682           name_vector := make_keywords(NEW.name);
1683
1684           -- merge in extra tags
1685           NEW.extratags := hstore(linkedPlacex.class, linkedPlacex.type) || coalesce(linkedPlacex.extratags, ''::hstore) || coalesce(NEW.extratags, ''::hstore);
1686
1687           -- mark the linked place (excludes from search results)
1688           UPDATE placex set linked_place_id = NEW.place_id where place_id = linkedPlacex.place_id;
1689
1690           -- keep a note of the node id in case we need it for wikipedia in a bit
1691           linked_node_id := linkedPlacex.osm_id;
1692         END LOOP;
1693       END IF;
1694
1695       IF NEW.centroid IS NOT NULL THEN
1696         place_centroid := NEW.centroid;
1697         -- Place might have had only a name tag before but has now received translations
1698         -- from the linked place. Make sure a name tag for the default language exists in
1699         -- this case. 
1700         IF NEW.name is not null AND array_upper(akeys(NEW.name),1) > 1 THEN
1701           default_language := get_country_language_code(NEW.calculated_country_code);
1702           IF default_language IS NOT NULL THEN
1703             IF NEW.name ? 'name' AND NOT NEW.name ? ('name:'||default_language) THEN
1704               NEW.name := NEW.name || hstore(('name:'||default_language), (NEW.name -> 'name'));
1705             ELSEIF NEW.name ? ('name:'||default_language) AND NOT NEW.name ? 'name' THEN
1706               NEW.name := NEW.name || hstore('name', (NEW.name -> ('name:'||default_language)));
1707             END IF;
1708           END IF;
1709         END IF;
1710       END IF;
1711
1712       -- Did we gain a wikipedia tag in the process? then we need to recalculate our importance
1713       IF NEW.importance is null THEN
1714         select language||':'||title,importance from get_wikipedia_match(NEW.extratags, NEW.calculated_country_code) INTO NEW.wikipedia,NEW.importance;
1715       END IF;
1716       -- Still null? how about looking it up by the node id
1717       IF NEW.importance IS NULL THEN
1718         select language||':'||title,importance from wikipedia_article where osm_type = 'N'::char(1) and osm_id = linked_node_id order by importance desc limit 1 INTO NEW.wikipedia,NEW.importance;
1719       END IF;
1720
1721     END IF;
1722
1723     -- make sure all names are in the word table
1724     IF NEW.admin_level = 2 AND NEW.class = 'boundary' AND NEW.type = 'administrative' AND NEW.country_code IS NOT NULL THEN
1725       perform create_country(NEW.name, lower(NEW.country_code));
1726     END IF;
1727
1728     NEW.parent_place_id = 0;
1729     parent_place_id_rank = 0;
1730
1731     -- convert isin to array of tokenids
1732     isin_tokens := '{}'::int[];
1733     IF NEW.isin IS NOT NULL THEN
1734       isin := regexp_split_to_array(NEW.isin, E'[;,]');
1735       IF array_upper(isin, 1) IS NOT NULL THEN
1736         FOR i IN 1..array_upper(isin, 1) LOOP
1737           address_street_word_id := get_name_id(make_standard_name(isin[i]));
1738           IF address_street_word_id IS NOT NULL AND NOT(ARRAY[address_street_word_id] <@ isin_tokens) THEN
1739             nameaddress_vector := array_merge(nameaddress_vector, ARRAY[address_street_word_id]);
1740             isin_tokens := isin_tokens || address_street_word_id;
1741           END IF;
1742
1743           -- merge word into address vector
1744           address_street_word_id := get_word_id(make_standard_name(isin[i]));
1745           IF address_street_word_id IS NOT NULL THEN
1746             nameaddress_vector := array_merge(nameaddress_vector, ARRAY[address_street_word_id]);
1747           END IF;
1748         END LOOP;
1749       END IF;
1750     END IF;
1751     IF NEW.postcode IS NOT NULL THEN
1752       isin := regexp_split_to_array(NEW.postcode, E'[;,]');
1753       IF array_upper(isin, 1) IS NOT NULL THEN
1754         FOR i IN 1..array_upper(isin, 1) LOOP
1755           address_street_word_id := get_name_id(make_standard_name(isin[i]));
1756           IF address_street_word_id IS NOT NULL AND NOT(ARRAY[address_street_word_id] <@ isin_tokens) THEN
1757             nameaddress_vector := array_merge(nameaddress_vector, ARRAY[address_street_word_id]);
1758             isin_tokens := isin_tokens || address_street_word_id;
1759           END IF;
1760
1761           -- merge into address vector
1762           address_street_word_id := get_word_id(make_standard_name(isin[i]));
1763           IF address_street_word_id IS NOT NULL THEN
1764             nameaddress_vector := array_merge(nameaddress_vector, ARRAY[address_street_word_id]);
1765           END IF;
1766         END LOOP;
1767       END IF;
1768     END IF;
1769
1770     -- for the USA we have an additional address table.  Merge in zip codes from there too
1771     IF NEW.rank_search = 26 AND NEW.calculated_country_code = 'us' THEN
1772       FOR location IN SELECT distinct postcode from location_property_tiger where parent_place_id = NEW.place_id LOOP
1773         address_street_word_id := get_name_id(make_standard_name(location.postcode));
1774         nameaddress_vector := array_merge(nameaddress_vector, ARRAY[address_street_word_id]);
1775         isin_tokens := isin_tokens || address_street_word_id;
1776
1777         -- also merge in the single word version
1778         address_street_word_id := get_word_id(make_standard_name(location.postcode));
1779         nameaddress_vector := array_merge(nameaddress_vector, ARRAY[address_street_word_id]);
1780       END LOOP;
1781     END IF;
1782
1783 -- RAISE WARNING 'ISIN: %', isin_tokens;
1784
1785     -- Process area matches
1786     location_rank_search := 0;
1787     location_distance := 0;
1788     location_parent := NULL;
1789     -- added ourself as address already
1790     address_havelevel[NEW.rank_address] := true;
1791     -- RAISE WARNING '  getNearFeatures(%,''%'',%,''%'')',NEW.partition, place_centroid, search_maxrank, isin_tokens;
1792     FOR location IN SELECT * from getNearFeatures(NEW.partition, place_centroid, search_maxrank, isin_tokens) LOOP
1793
1794 --RAISE WARNING '  AREA: %',location;
1795
1796       IF location.rank_address != location_rank_search THEN
1797         location_rank_search := location.rank_address;
1798         location_distance := location.distance * 1.5;
1799       END IF;
1800
1801       IF location.distance < location_distance OR NOT location.isguess THEN
1802
1803         location_isaddress := NOT address_havelevel[location.rank_address];
1804         IF location_isaddress AND location.isguess AND location_parent IS NOT NULL THEN
1805             location_isaddress := ST_Contains(location_parent,location.centroid);
1806         END IF;
1807
1808         -- RAISE WARNING '% isaddress: %', location.place_id, location_isaddress;
1809         -- Add it to the list of search terms
1810         IF location.rank_search > 4 THEN
1811             nameaddress_vector := array_merge(nameaddress_vector, location.keywords::integer[]);
1812         END IF;
1813         INSERT INTO place_addressline VALUES (NEW.place_id, location.place_id, true, location_isaddress, location.distance, location.rank_address);
1814
1815         IF location_isaddress THEN
1816
1817           address_havelevel[location.rank_address] := true;
1818           IF NOT location.isguess THEN
1819             SELECT geometry FROM placex WHERE place_id = location.place_id INTO location_parent;
1820           END IF;
1821
1822           IF location.rank_address > parent_place_id_rank THEN
1823             NEW.parent_place_id = location.place_id;
1824             parent_place_id_rank = location.rank_address;
1825           END IF;
1826
1827         END IF;
1828
1829 --RAISE WARNING '  Terms: (%) %',location, nameaddress_vector;
1830
1831       END IF;
1832
1833     END LOOP;
1834
1835     -- try using the isin value to find parent places
1836     IF array_upper(isin_tokens, 1) IS NOT NULL THEN
1837       FOR i IN 1..array_upper(isin_tokens, 1) LOOP
1838 --RAISE WARNING '  getNearestNamedFeature: % % % %',NEW.partition, place_centroid, search_maxrank, isin_tokens[i];
1839         IF NOT ARRAY[isin_tokens[i]] <@ nameaddress_vector THEN
1840
1841           FOR location IN SELECT * from getNearestNamedFeature(NEW.partition, place_centroid, search_maxrank, isin_tokens[i]) LOOP
1842
1843   --RAISE WARNING '  ISIN: %',location;
1844
1845             IF location.rank_search > 4 THEN
1846                 nameaddress_vector := array_merge(nameaddress_vector, location.keywords::integer[]);
1847                 INSERT INTO place_addressline VALUES (NEW.place_id, location.place_id, false, NOT address_havelevel[location.rank_address], location.distance, location.rank_address);
1848                 address_havelevel[location.rank_address] := true;
1849
1850                 IF location.rank_address > parent_place_id_rank THEN
1851                   NEW.parent_place_id = location.place_id;
1852                   parent_place_id_rank = location.rank_address;
1853                 END IF;
1854             END IF;
1855           END LOOP;
1856
1857         END IF;
1858
1859       END LOOP;
1860     END IF;
1861
1862     -- for long ways we should add search terms for the entire length
1863     IF st_length(NEW.geometry) > 0.05 THEN
1864
1865       location_rank_search := 0;
1866       location_distance := 0;
1867
1868       FOR location IN SELECT * from getNearFeatures(NEW.partition, NEW.geometry, search_maxrank, isin_tokens) LOOP
1869
1870         IF location.rank_address != location_rank_search THEN
1871           location_rank_search := location.rank_address;
1872           location_distance := location.distance * 1.5;
1873         END IF;
1874
1875         IF location.rank_search > 4 AND location.distance < location_distance THEN
1876
1877           -- Add it to the list of search terms
1878           nameaddress_vector := array_merge(nameaddress_vector, location.keywords::integer[]);
1879           INSERT INTO place_addressline VALUES (NEW.place_id, location.place_id, true, false, location.distance, location.rank_address); 
1880
1881         END IF;
1882
1883       END LOOP;
1884
1885     END IF;
1886
1887     -- if we have a name add this to the name search table
1888     IF NEW.name IS NOT NULL THEN
1889
1890       IF NEW.rank_search <= 25 THEN
1891         result := add_location(NEW.place_id, NEW.calculated_country_code, NEW.partition, name_vector, NEW.rank_search, NEW.rank_address, NEW.geometry);
1892       END IF;
1893
1894       IF NEW.rank_search between 26 and 27 and NEW.class = 'highway' THEN
1895         result := insertLocationRoad(NEW.partition, NEW.place_id, NEW.calculated_country_code, NEW.geometry);
1896       END IF;
1897
1898       result := insertSearchName(NEW.partition, NEW.place_id, NEW.calculated_country_code, name_vector, nameaddress_vector, NEW.rank_search, NEW.rank_address, NEW.importance, place_centroid, NEW.geometry);
1899
1900     END IF;
1901
1902     -- If we've not managed to pick up a better one - default centroid
1903     IF NEW.centroid IS NULL THEN
1904       NEW.centroid := place_centroid;
1905     END IF;
1906
1907   END IF;
1908
1909   RETURN NEW;
1910 END;
1911 $$
1912 LANGUAGE plpgsql;
1913
1914 CREATE OR REPLACE FUNCTION placex_delete() RETURNS TRIGGER
1915   AS $$
1916 DECLARE
1917   b BOOLEAN;
1918   classtable TEXT;
1919 BEGIN
1920   -- RAISE WARNING 'placex_delete % %',OLD.osm_type,OLD.osm_id;
1921
1922   update placex set linked_place_id = null, indexed_status = 2 where linked_place_id = OLD.place_id and indexed_status = 0;
1923   --DEBUG: RAISE WARNING 'placex_delete:01 % %',OLD.osm_type,OLD.osm_id;
1924   update placex set linked_place_id = null where linked_place_id = OLD.place_id;
1925   --DEBUG: RAISE WARNING 'placex_delete:02 % %',OLD.osm_type,OLD.osm_id;
1926
1927   IF OLD.rank_address < 30 THEN
1928
1929     -- mark everything linked to this place for re-indexing
1930     --DEBUG: RAISE WARNING 'placex_delete:03 % %',OLD.osm_type,OLD.osm_id;
1931     UPDATE placex set indexed_status = 2 from place_addressline where address_place_id = OLD.place_id 
1932       and placex.place_id = place_addressline.place_id and indexed_status = 0 and place_addressline.isaddress;
1933
1934     --DEBUG: RAISE WARNING 'placex_delete:04 % %',OLD.osm_type,OLD.osm_id;
1935     DELETE FROM place_addressline where address_place_id = OLD.place_id;
1936
1937     --DEBUG: RAISE WARNING 'placex_delete:05 % %',OLD.osm_type,OLD.osm_id;
1938     b := deleteRoad(OLD.partition, OLD.place_id);
1939
1940     --DEBUG: RAISE WARNING 'placex_delete:06 % %',OLD.osm_type,OLD.osm_id;
1941     update placex set indexed_status = 2 where parent_place_id = OLD.place_id and indexed_status = 0;
1942     --DEBUG: RAISE WARNING 'placex_delete:07 % %',OLD.osm_type,OLD.osm_id;
1943
1944   END IF;
1945
1946   --DEBUG: RAISE WARNING 'placex_delete:08 % %',OLD.osm_type,OLD.osm_id;
1947
1948   IF OLD.rank_address < 26 THEN
1949     b := deleteLocationArea(OLD.partition, OLD.place_id, OLD.rank_search);
1950   END IF;
1951
1952   --DEBUG: RAISE WARNING 'placex_delete:09 % %',OLD.osm_type,OLD.osm_id;
1953
1954   IF OLD.name is not null THEN
1955     b := deleteSearchName(OLD.partition, OLD.place_id);
1956   END IF;
1957
1958   --DEBUG: RAISE WARNING 'placex_delete:10 % %',OLD.osm_type,OLD.osm_id;
1959
1960   DELETE FROM place_addressline where place_id = OLD.place_id;
1961
1962   --DEBUG: RAISE WARNING 'placex_delete:11 % %',OLD.osm_type,OLD.osm_id;
1963
1964   -- remove from tables for special search
1965   classtable := 'place_classtype_' || OLD.class || '_' || OLD.type;
1966   SELECT count(*)>0 FROM pg_tables WHERE tablename = classtable and schemaname = current_schema() INTO b;
1967   IF b THEN
1968     EXECUTE 'DELETE FROM ' || classtable::regclass || ' WHERE place_id = $1' USING OLD.place_id;
1969   END IF;
1970
1971   --DEBUG: RAISE WARNING 'placex_delete:12 % %',OLD.osm_type,OLD.osm_id;
1972
1973   RETURN OLD;
1974
1975 END;
1976 $$
1977 LANGUAGE plpgsql;
1978
1979 CREATE OR REPLACE FUNCTION place_delete() RETURNS TRIGGER
1980   AS $$
1981 DECLARE
1982   has_rank BOOLEAN;
1983 BEGIN
1984
1985   --DEBUG: RAISE WARNING 'delete: % % % %',OLD.osm_type,OLD.osm_id,OLD.class,OLD.type;
1986
1987   -- deleting large polygons can have a massive effect on the system - require manual intervention to let them through
1988   IF st_area(OLD.geometry) > 2 and st_isvalid(OLD.geometry) THEN
1989     SELECT bool_or(not (rank_address = 0 or rank_address > 26)) 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;
1990     IF has_rank THEN
1991       insert into import_polygon_delete values (OLD.osm_type,OLD.osm_id,OLD.class,OLD.type);
1992       RETURN NULL;
1993     END IF;
1994   END IF;
1995
1996   -- mark for delete
1997   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;
1998
1999   RETURN OLD;
2000
2001 END;
2002 $$
2003 LANGUAGE plpgsql;
2004
2005 CREATE OR REPLACE FUNCTION place_insert() RETURNS TRIGGER
2006   AS $$
2007 DECLARE
2008   i INTEGER;
2009   existing RECORD;
2010   existingplacex RECORD;
2011   existinggeometry GEOMETRY;
2012   existingplace_id BIGINT;
2013   result BOOLEAN;
2014   partition INTEGER;
2015 BEGIN
2016
2017   --DEBUG: RAISE WARNING '-----------------------------------------------------------------------------------';
2018   --DEBUG: RAISE WARNING 'place_insert: % % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type,st_area(NEW.geometry);
2019
2020   IF FALSE and NEW.osm_type = 'R' THEN
2021     select * from placex where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type INTO existingplacex;
2022     --DEBUG: RAISE WARNING '%', existingplacex;
2023   END IF;
2024
2025   -- remove operator tag for most places, messes too much with search_name indexes
2026   IF NEW.class not in ('amenity', 'shop') THEN
2027     NEW.name := delete(NEW.name, 'operator');
2028   END IF;
2029
2030   -- Just block these - lots and pointless
2031   IF NEW.class in ('landuse','natural') and NEW.name is null THEN
2032     -- if the name tag was removed, older versions might still be lurking in the place table
2033     DELETE FROM place where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type;
2034     RETURN null;
2035   END IF;
2036
2037   IF ST_IsEmpty(NEW.geometry) OR NOT ST_IsValid(NEW.geometry) OR ST_X(ST_Centroid(NEW.geometry))::text in ('NaN','Infinity','-Infinity') OR ST_Y(ST_Centroid(NEW.geometry))::text in ('NaN','Infinity','-Infinity') THEN  
2038     INSERT INTO import_polygon_error values (NEW.osm_type, NEW.osm_id, NEW.class, NEW.type, NEW.name, NEW.country_code, 
2039       now(), ST_IsValidReason(NEW.geometry), null, NEW.geometry);
2040 --    RAISE WARNING 'Invalid Geometry: % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type;
2041     RETURN null;
2042   END IF;
2043
2044   -- Patch in additional country names
2045   IF NEW.admin_level = 2 AND NEW.type = 'administrative' AND NEW.country_code is not null THEN
2046     select coalesce(country_name.name || NEW.name,NEW.name) from country_name where country_name.country_code = lower(NEW.country_code) INTO NEW.name;
2047   END IF;
2048     
2049   -- Have we already done this place?
2050   select * from place where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type INTO existing;
2051
2052   -- Get the existing place_id
2053   select * from placex where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type INTO existingplacex;
2054
2055   -- Handle a place changing type by removing the old data
2056   -- My generated 'place' types are causing havok because they overlap with real keys
2057   -- TODO: move them to their own special purpose key/class to avoid collisions
2058   IF existing.osm_type IS NULL AND (NEW.type not in ('postcode','house','houses')) THEN
2059     DELETE FROM place where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type not in ('postcode','house','houses');
2060   END IF;
2061
2062   --DEBUG: RAISE WARNING 'Existing: %',existing.osm_id;
2063   --DEBUG: RAISE WARNING 'Existing PlaceX: %',existingplacex.place_id;
2064
2065   -- Log and discard 
2066   IF existing.geometry is not null AND st_isvalid(existing.geometry) 
2067     AND st_area(existing.geometry) > 0.02
2068     AND ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon')
2069     AND st_area(NEW.geometry) < st_area(existing.geometry)*0.5
2070     THEN
2071     INSERT INTO import_polygon_error values (NEW.osm_type, NEW.osm_id, NEW.class, NEW.type, NEW.name, NEW.country_code, now(), 
2072       'Area reduced from '||st_area(existing.geometry)||' to '||st_area(NEW.geometry), existing.geometry, NEW.geometry);
2073     RETURN null;
2074   END IF;
2075
2076   DELETE from import_polygon_error where osm_type = NEW.osm_type and osm_id = NEW.osm_id;
2077   DELETE from import_polygon_delete where osm_type = NEW.osm_type and osm_id = NEW.osm_id;
2078
2079   -- To paraphrase, if there isn't an existing item, OR if the admin level has changed
2080   IF existingplacex.osm_type IS NULL OR
2081     (coalesce(existingplacex.admin_level, 15) != coalesce(NEW.admin_level, 15) AND existingplacex.class = 'boundary' AND existingplacex.type = 'administrative')
2082   THEN
2083
2084     IF existingplacex.osm_type IS NOT NULL THEN
2085       -- sanity check: ignore admin_level changes on places with too many active children
2086       -- or we end up reindexing entire countries because somebody accidentally deleted admin_level
2087       --LIMIT INDEXING: SELECT count(*) FROM (SELECT 'a' FROM placex , place_addressline where address_place_id = existingplacex.place_id and placex.place_id = place_addressline.place_id and indexed_status = 0 and place_addressline.isaddress LIMIT 100001) sub INTO i;
2088       --LIMIT INDEXING: IF i > 100000 THEN
2089       --LIMIT INDEXING:  RETURN null;
2090       --LIMIT INDEXING: END IF;
2091     END IF;
2092
2093     IF existing.osm_type IS NOT NULL THEN
2094       -- pathological case caused by the triggerless copy into place during initial import
2095       -- force delete even for large areas, it will be reinserted later
2096       UPDATE place set geometry = ST_SetSRID(ST_Point(0,0), 4326) where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type;
2097       DELETE from place where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type;
2098     END IF;
2099
2100     -- No - process it as a new insertion (hopefully of low rank or it will be slow)
2101     insert into placex (osm_type, osm_id, class, type, name, admin_level, housenumber, 
2102       street, addr_place, isin, postcode, country_code, extratags, geometry)
2103       values (NEW.osm_type
2104         ,NEW.osm_id
2105         ,NEW.class
2106         ,NEW.type
2107         ,NEW.name
2108         ,NEW.admin_level
2109         ,NEW.housenumber
2110         ,NEW.street
2111         ,NEW.addr_place
2112         ,NEW.isin
2113         ,NEW.postcode
2114         ,NEW.country_code
2115         ,NEW.extratags
2116         ,NEW.geometry
2117         );
2118
2119     --DEBUG: RAISE WARNING 'insert done % % % % %',NEW.osm_type,NEW.osm_id,NEW.class,NEW.type,NEW.name;
2120
2121     RETURN NEW;
2122   END IF;
2123
2124   -- Various ways to do the update
2125
2126   -- Debug, what's changed?
2127   IF FALSE THEN
2128     IF coalesce(existing.name::text, '') != coalesce(NEW.name::text, '') THEN
2129       RAISE WARNING 'update details, name: % % % %',NEW.osm_type,NEW.osm_id,existing.name::text,NEW.name::text;
2130     END IF;
2131     IF coalesce(existing.housenumber, '') != coalesce(NEW.housenumber, '') THEN
2132       RAISE WARNING 'update details, housenumber: % % % %',NEW.osm_type,NEW.osm_id,existing.housenumber,NEW.housenumber;
2133     END IF;
2134     IF coalesce(existing.street, '') != coalesce(NEW.street, '') THEN
2135       RAISE WARNING 'update details, street: % % % %',NEW.osm_type,NEW.osm_id,existing.street,NEW.street;
2136     END IF;
2137     IF coalesce(existing.addr_place, '') != coalesce(NEW.addr_place, '') THEN
2138       RAISE WARNING 'update details, street: % % % %',NEW.osm_type,NEW.osm_id,existing.addr_place,NEW.addr_place;
2139     END IF;
2140     IF coalesce(existing.isin, '') != coalesce(NEW.isin, '') THEN
2141       RAISE WARNING 'update details, isin: % % % %',NEW.osm_type,NEW.osm_id,existing.isin,NEW.isin;
2142     END IF;
2143     IF coalesce(existing.postcode, '') != coalesce(NEW.postcode, '') THEN
2144       RAISE WARNING 'update details, postcode: % % % %',NEW.osm_type,NEW.osm_id,existing.postcode,NEW.postcode;
2145     END IF;
2146     IF coalesce(existing.country_code, '') != coalesce(NEW.country_code, '') THEN
2147       RAISE WARNING 'update details, country_code: % % % %',NEW.osm_type,NEW.osm_id,existing.country_code,NEW.country_code;
2148     END IF;
2149   END IF;
2150
2151   -- Special case for polygon shape changes because they tend to be large and we can be a bit clever about how we handle them
2152   IF existing.geometry::text != NEW.geometry::text 
2153      AND ST_GeometryType(existing.geometry) in ('ST_Polygon','ST_MultiPolygon')
2154      AND ST_GeometryType(NEW.geometry) in ('ST_Polygon','ST_MultiPolygon') 
2155      THEN 
2156
2157     -- Get the version of the geometry actually used (in placex table)
2158     select geometry from placex where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type into existinggeometry;
2159
2160     -- Performance limit
2161     IF st_area(NEW.geometry) < 0.000000001 AND st_area(existinggeometry) < 1 THEN
2162
2163       -- re-index points that have moved in / out of the polygon, could be done as a single query but postgres gets the index usage wrong
2164       update placex set indexed_status = 2 where indexed_status = 0 and 
2165           (st_covers(NEW.geometry, placex.geometry) OR ST_Intersects(NEW.geometry, placex.geometry))
2166           AND NOT (st_covers(existinggeometry, placex.geometry) OR ST_Intersects(existinggeometry, placex.geometry))
2167           AND rank_search > existingplacex.rank_search AND (rank_search < 28 or name is not null);
2168
2169       update placex set indexed_status = 2 where indexed_status = 0 and 
2170           (st_covers(existinggeometry, placex.geometry) OR ST_Intersects(existinggeometry, placex.geometry))
2171           AND NOT (st_covers(NEW.geometry, placex.geometry) OR ST_Intersects(NEW.geometry, placex.geometry))
2172           AND rank_search > existingplacex.rank_search AND (rank_search < 28 or name is not null);
2173
2174     END IF;
2175
2176   END IF;
2177
2178   -- Special case - if we are just adding extra words we hack them into the search_name table rather than reindexing
2179   IF FALSE AND existingplacex.rank_search < 26
2180      AND coalesce(existing.housenumber, '') = coalesce(NEW.housenumber, '')
2181      AND coalesce(existing.street, '') = coalesce(NEW.street, '')
2182      AND coalesce(existing.addr_place, '') = coalesce(NEW.addr_place, '')
2183      AND coalesce(existing.isin, '') = coalesce(NEW.isin, '')
2184      AND coalesce(existing.postcode, '') = coalesce(NEW.postcode, '')
2185      AND coalesce(existing.country_code, '') = coalesce(NEW.country_code, '')
2186      AND coalesce(existing.name::text, '') != coalesce(NEW.name::text, '') 
2187      THEN
2188
2189     IF NOT update_location_nameonly(existingplacex.place_id, NEW.name) THEN
2190
2191       IF st_area(NEW.geometry) < 0.5 THEN
2192         UPDATE placex set indexed_status = 2 from place_addressline where address_place_id = existingplacex.place_id 
2193           and placex.place_id = place_addressline.place_id and indexed_status = 0
2194           and (rank_search < 28 or name is not null);
2195       END IF;
2196
2197     END IF;
2198   
2199   ELSE
2200
2201     -- Anything else has changed - reindex the lot
2202     IF coalesce(existing.name::text, '') != coalesce(NEW.name::text, '')
2203         OR coalesce(existing.housenumber, '') != coalesce(NEW.housenumber, '')
2204         OR coalesce(existing.street, '') != coalesce(NEW.street, '')
2205         OR coalesce(existing.addr_place, '') != coalesce(NEW.addr_place, '')
2206         OR coalesce(existing.isin, '') != coalesce(NEW.isin, '')
2207         OR coalesce(existing.postcode, '') != coalesce(NEW.postcode, '')
2208         OR coalesce(existing.country_code, '') != coalesce(NEW.country_code, '') THEN
2209
2210       -- performance, can't take the load of re-indexing a whole country / huge area
2211       IF st_area(NEW.geometry) < 0.5 THEN
2212 --        UPDATE placex set indexed_status = 2 from place_addressline where address_place_id = existingplacex.place_id 
2213 --          and placex.place_id = place_addressline.place_id and indexed_status = 0;
2214       END IF;
2215
2216     END IF;
2217
2218   END IF;
2219
2220   -- refuse to update multiplpoygons with too many objects, too much of a performance hit
2221   IF ST_NumGeometries(NEW.geometry) > 2000 THEN
2222     RAISE WARNING 'Dropping update of % % because of geometry complexity.', NEW.osm_type, NEW.osm_id;
2223     RETURN NULL;
2224   END IF;
2225
2226   IF coalesce(existing.name::text, '') != coalesce(NEW.name::text, '')
2227      OR coalesce(existing.extratags::text, '') != coalesce(NEW.extratags::text, '')
2228      OR coalesce(existing.housenumber, '') != coalesce(NEW.housenumber, '')
2229      OR coalesce(existing.street, '') != coalesce(NEW.street, '')
2230      OR coalesce(existing.addr_place, '') != coalesce(NEW.addr_place, '')
2231      OR coalesce(existing.isin, '') != coalesce(NEW.isin, '')
2232      OR coalesce(existing.postcode, '') != coalesce(NEW.postcode, '')
2233      OR coalesce(existing.country_code, '') != coalesce(NEW.country_code, '')
2234      OR coalesce(existing.admin_level, 15) != coalesce(NEW.admin_level, 15)
2235      OR existing.geometry::text != NEW.geometry::text
2236      THEN
2237
2238     update place set 
2239       name = NEW.name,
2240       housenumber  = NEW.housenumber,
2241       street = NEW.street,
2242       addr_place = NEW.addr_place,
2243       isin = NEW.isin,
2244       postcode = NEW.postcode,
2245       country_code = NEW.country_code,
2246       extratags = NEW.extratags,
2247       admin_level = NEW.admin_level,
2248       geometry = NEW.geometry
2249       where osm_type = NEW.osm_type and osm_id = NEW.osm_id and class = NEW.class and type = NEW.type;
2250
2251     IF NEW.class in ('place','boundary') AND NEW.type in ('postcode','postal_code') THEN
2252         IF NEW.postcode IS NULL THEN
2253             -- postcode was deleted, no longer retain in placex
2254             DELETE FROM placex where place_id = existingplacex.place_id;
2255             RETURN NULL;
2256         END IF;
2257
2258         NEW.name := hstore('ref', NEW.postcode);
2259     END IF;
2260
2261     update placex set 
2262       name = NEW.name,
2263       housenumber = NEW.housenumber,
2264       street = NEW.street,
2265       addr_place = NEW.addr_place,
2266       isin = NEW.isin,
2267       postcode = NEW.postcode,
2268       country_code = NEW.country_code,
2269       parent_place_id = null,
2270       extratags = NEW.extratags,
2271       admin_level = CASE WHEN NEW.admin_level > 15 THEN 15 ELSE NEW.admin_level END,
2272       indexed_status = 2,    
2273       geometry = NEW.geometry
2274       where place_id = existingplacex.place_id;
2275
2276   END IF;
2277
2278   -- Abort the add (we modified the existing place instead)
2279   RETURN NULL;
2280
2281 END; 
2282 $$ LANGUAGE plpgsql;
2283
2284 CREATE OR REPLACE FUNCTION get_name_by_language(name hstore, languagepref TEXT[]) RETURNS TEXT
2285   AS $$
2286 DECLARE
2287   search TEXT[];
2288   found BOOLEAN;
2289 BEGIN
2290
2291   IF name is null THEN
2292     RETURN null;
2293   END IF;
2294
2295   search := languagepref;
2296
2297   FOR j IN 1..array_upper(search, 1) LOOP
2298     IF name ? search[j] AND trim(name->search[j]) != '' THEN
2299       return trim(name->search[j]);
2300     END IF;
2301   END LOOP;
2302
2303   -- anything will do as a fallback - just take the first name type thing there is
2304   search := avals(name);
2305   RETURN search[1];
2306 END;
2307 $$
2308 LANGUAGE plpgsql IMMUTABLE;
2309
2310 CREATE OR REPLACE FUNCTION get_connected_ways(way_ids INTEGER[]) RETURNS SETOF planet_osm_ways
2311   AS $$
2312 DECLARE
2313   searchnodes INTEGER[];
2314   location RECORD;
2315   j INTEGER;
2316 BEGIN
2317
2318   searchnodes := '{}';
2319   FOR j IN 1..array_upper(way_ids, 1) LOOP
2320     FOR location IN 
2321       select nodes from planet_osm_ways where id = way_ids[j] LIMIT 1
2322     LOOP
2323       IF not (ARRAY[location.nodes] <@ searchnodes) THEN
2324         searchnodes := searchnodes || location.nodes;
2325       END IF;
2326     END LOOP;
2327   END LOOP;
2328
2329   RETURN QUERY select * from planet_osm_ways where nodes && searchnodes and NOT ARRAY[id] <@ way_ids;
2330 END;
2331 $$
2332 LANGUAGE plpgsql IMMUTABLE;
2333
2334 CREATE OR REPLACE FUNCTION get_address_postcode(for_place_id BIGINT) RETURNS TEXT
2335   AS $$
2336 DECLARE
2337   result TEXT[];
2338   search TEXT[];
2339   for_postcode TEXT;
2340   found INTEGER;
2341   location RECORD;
2342 BEGIN
2343
2344   found := 1000;
2345   search := ARRAY['ref'];
2346   result := '{}';
2347
2348   select postcode from placex where place_id = for_place_id limit 1 into for_postcode;
2349
2350   FOR location IN 
2351     select rank_address,name,distance,length(name::text) as namelength 
2352       from place_addressline join placex on (address_place_id = placex.place_id) 
2353       where place_addressline.place_id = for_place_id and rank_address in (5,11)
2354       order by rank_address desc,rank_search desc,fromarea desc,distance asc,namelength desc
2355   LOOP
2356     IF array_upper(search, 1) IS NOT NULL AND array_upper(location.name, 1) IS NOT NULL THEN
2357       FOR j IN 1..array_upper(search, 1) LOOP
2358         FOR k IN 1..array_upper(location.name, 1) LOOP
2359           IF (found > location.rank_address AND location.name[k].key = search[j] AND location.name[k].value != '') AND NOT result @> ARRAY[trim(location.name[k].value)] AND (for_postcode IS NULL OR location.name[k].value ilike for_postcode||'%') THEN
2360             result[(100 - location.rank_address)] := trim(location.name[k].value);
2361             found := location.rank_address;
2362           END IF;
2363         END LOOP;
2364       END LOOP;
2365     END IF;
2366   END LOOP;
2367
2368   RETURN array_to_string(result,', ');
2369 END;
2370 $$
2371 LANGUAGE plpgsql;
2372
2373 CREATE OR REPLACE FUNCTION get_address_by_language(for_place_id BIGINT, languagepref TEXT[]) RETURNS TEXT
2374   AS $$
2375 DECLARE
2376   result TEXT[];
2377   currresult TEXT;
2378   prevresult TEXT;
2379   location RECORD;
2380 BEGIN
2381
2382   result := '{}';
2383   prevresult := '';
2384
2385   FOR location IN select * from get_addressdata(for_place_id) where isaddress order by rank_address desc LOOP
2386     currresult := trim(get_name_by_language(location.name, languagepref));
2387     IF currresult != prevresult AND currresult IS NOT NULL AND result[(100 - location.rank_address)] IS NULL THEN
2388       result[(100 - location.rank_address)] := trim(get_name_by_language(location.name, languagepref));
2389       prevresult := currresult;
2390     END IF;
2391   END LOOP;
2392
2393   RETURN array_to_string(result,', ');
2394 END;
2395 $$
2396 LANGUAGE plpgsql;
2397
2398 DROP TYPE IF EXISTS addressline CASCADE;
2399 create type addressline as (
2400   place_id BIGINT,
2401   osm_type CHAR(1),
2402   osm_id BIGINT,
2403   name HSTORE,
2404   class TEXT,
2405   type TEXT,
2406   admin_level INTEGER,
2407   fromarea BOOLEAN,  
2408   isaddress BOOLEAN,  
2409   rank_address INTEGER,
2410   distance FLOAT
2411 );
2412
2413 CREATE OR REPLACE FUNCTION get_addressdata(in_place_id BIGINT) RETURNS setof addressline 
2414   AS $$
2415 DECLARE
2416   for_place_id BIGINT;
2417   result TEXT[];
2418   search TEXT[];
2419   found INTEGER;
2420   location RECORD;
2421   countrylocation RECORD;
2422   searchcountrycode varchar(2);
2423   searchhousenumber TEXT;
2424   searchhousename HSTORE;
2425   searchrankaddress INTEGER;
2426   searchpostcode TEXT;
2427   searchclass TEXT;
2428   searchtype TEXT;
2429   countryname HSTORE;
2430   hadcountry BOOLEAN;
2431 BEGIN
2432
2433   select parent_place_id,'us', housenumber, 30, postcode, null, 'place', 'house' from location_property_tiger 
2434     WHERE place_id = in_place_id 
2435     INTO for_place_id,searchcountrycode, searchhousenumber, searchrankaddress, searchpostcode, searchhousename, searchclass, searchtype;
2436
2437   IF for_place_id IS NULL THEN
2438     select parent_place_id,'us', housenumber, 30, postcode, null, 'place', 'house' from location_property_aux
2439       WHERE place_id = in_place_id 
2440       INTO for_place_id,searchcountrycode, searchhousenumber, searchrankaddress, searchpostcode, searchhousename, searchclass, searchtype;
2441   END IF;
2442
2443   IF for_place_id IS NULL THEN
2444     select parent_place_id, calculated_country_code, housenumber, rank_search, postcode, name, class, type from placex 
2445       WHERE place_id = in_place_id and rank_address = 30 
2446       INTO for_place_id, searchcountrycode, searchhousenumber, searchrankaddress, searchpostcode, searchhousename, searchclass, searchtype;
2447   END IF;
2448
2449   IF for_place_id IS NULL THEN
2450     for_place_id := in_place_id;
2451     select calculated_country_code, housenumber, rank_search, postcode, null from placex where place_id = for_place_id 
2452       INTO searchcountrycode, searchhousenumber, searchrankaddress, searchpostcode, searchhousename;
2453   END IF;
2454
2455 --RAISE WARNING '% % % %',searchcountrycode, searchhousenumber, searchrankaddress, searchpostcode;
2456
2457   found := 1000;
2458   hadcountry := false;
2459   FOR location IN 
2460     select placex.place_id, osm_type, osm_id,
2461       CASE WHEN class = 'place' and type = 'postcode' THEN hstore('name', postcode) ELSE name END as name,
2462       class, type, admin_level, true as fromarea, true as isaddress,
2463       CASE WHEN rank_address = 0 THEN 100 WHEN rank_address = 11 THEN 5 ELSE rank_address END as rank_address,
2464       0 as distance, calculated_country_code
2465       from placex
2466       where place_id = for_place_id 
2467   LOOP
2468 --RAISE WARNING '%',location;
2469     IF searchcountrycode IS NULL AND location.calculated_country_code IS NOT NULL THEN
2470       searchcountrycode := location.calculated_country_code;
2471     END IF;
2472     IF searchpostcode IS NOT NULL and location.type = 'postcode' THEN
2473       location.isaddress := FALSE;
2474     END IF;
2475     IF location.rank_address = 4 AND location.isaddress THEN
2476       hadcountry := true;
2477     END IF;
2478     IF location.rank_address < 4 AND NOT hadcountry THEN
2479       select name from country_name where country_code = searchcountrycode limit 1 INTO countryname;
2480       IF countryname IS NOT NULL THEN
2481         countrylocation := ROW(null, null, null, countryname, 'place', 'country', null, true, true, 4, 0)::addressline;
2482         RETURN NEXT countrylocation;
2483       END IF;
2484     END IF;
2485     countrylocation := ROW(location.place_id, location.osm_type, location.osm_id, location.name, location.class, 
2486                            location.type, location.admin_level, location.fromarea, location.isaddress, location.rank_address, 
2487                            location.distance)::addressline;
2488     RETURN NEXT countrylocation;
2489     found := location.rank_address;
2490   END LOOP;
2491
2492   FOR location IN 
2493     select placex.place_id, osm_type, osm_id,
2494       CASE WHEN class = 'place' and type = 'postcode' THEN hstore('name', postcode) ELSE name END as name,
2495       class, type, admin_level, fromarea, isaddress,
2496       CASE WHEN address_place_id = for_place_id AND rank_address = 0 THEN 100 WHEN rank_address = 11 THEN 5 ELSE rank_address END as rank_address,
2497       distance,calculated_country_code,postcode
2498       from place_addressline join placex on (address_place_id = placex.place_id) 
2499       where place_addressline.place_id = for_place_id 
2500       and (cached_rank_address > 0 AND cached_rank_address < searchrankaddress)
2501       and address_place_id != for_place_id
2502       and (placex.calculated_country_code IS NULL OR searchcountrycode IS NULL OR placex.calculated_country_code = searchcountrycode)
2503       order by rank_address desc,isaddress desc,fromarea desc,distance asc,rank_search desc
2504   LOOP
2505 --RAISE WARNING '%',location;
2506     IF searchcountrycode IS NULL AND location.calculated_country_code IS NOT NULL THEN
2507       searchcountrycode := location.calculated_country_code;
2508     END IF;
2509     IF searchpostcode IS NOT NULL and location.type = 'postcode' THEN
2510       location.isaddress := FALSE;
2511     END IF;
2512     IF searchpostcode IS NULL and location.isaddress and location.type != 'postcode' and location.postcode IS NOT NULL THEN
2513       searchpostcode := location.postcode;
2514     END IF;
2515     IF location.rank_address = 4 AND location.isaddress THEN
2516       hadcountry := true;
2517     END IF;
2518     IF location.rank_address < 4 AND NOT hadcountry THEN
2519       select name from country_name where country_code = searchcountrycode limit 1 INTO countryname;
2520       IF countryname IS NOT NULL THEN
2521         countrylocation := ROW(null, null, null, countryname, 'place', 'country', null, true, true, 4, 0)::addressline;
2522         RETURN NEXT countrylocation;
2523       END IF;
2524     END IF;
2525     countrylocation := ROW(location.place_id, location.osm_type, location.osm_id, location.name, location.class, 
2526                            location.type, location.admin_level, location.fromarea, location.isaddress, location.rank_address, 
2527                            location.distance)::addressline;
2528     RETURN NEXT countrylocation;
2529     found := location.rank_address;
2530   END LOOP;
2531
2532   IF found > 4 THEN
2533     select name from country_name where country_code = searchcountrycode limit 1 INTO countryname;
2534 --RAISE WARNING '% % %',found,searchcountrycode,countryname;
2535     IF countryname IS NOT NULL THEN
2536       location := ROW(null, null, null, countryname, 'place', 'country', null, true, true, 4, 0)::addressline;
2537       RETURN NEXT location;
2538     END IF;
2539   END IF;
2540
2541   IF searchcountrycode IS NOT NULL THEN
2542     location := ROW(null, null, null, hstore('ref', searchcountrycode), 'place', 'country_code', null, true, false, 4, 0)::addressline;
2543     RETURN NEXT location;
2544   END IF;
2545
2546   IF searchhousename IS NOT NULL THEN
2547     location := ROW(in_place_id, null, null, searchhousename, searchclass, searchtype, null, true, true, 29, 0)::addressline;
2548 --    location := ROW(in_place_id, null, null, searchhousename, 'place', 'house_name', null, true, true, 29, 0)::addressline;
2549     RETURN NEXT location;
2550   END IF;
2551
2552   IF searchhousenumber IS NOT NULL THEN
2553     location := ROW(in_place_id, null, null, hstore('ref', searchhousenumber), 'place', 'house_number', null, true, true, 28, 0)::addressline;
2554     RETURN NEXT location;
2555   END IF;
2556
2557   IF searchpostcode IS NOT NULL THEN
2558     location := ROW(null, null, null, hstore('ref', searchpostcode), 'place', 'postcode', null, true, true, 5, 0)::addressline;
2559     RETURN NEXT location;
2560   END IF;
2561
2562   RETURN;
2563 END;
2564 $$
2565 LANGUAGE plpgsql;
2566
2567 CREATE OR REPLACE FUNCTION get_place_boundingbox(search_place_id BIGINT) RETURNS place_boundingbox
2568   AS $$
2569 DECLARE
2570   result place_boundingbox;
2571   numfeatures integer;
2572 BEGIN
2573   select * from place_boundingbox into result where place_id = search_place_id;
2574   IF result.place_id IS NULL THEN
2575 -- remove  isaddress = true because if there is a matching polygon it always wins
2576     select count(*) from place_addressline where address_place_id = search_place_id into numfeatures;
2577     insert into place_boundingbox select place_id,
2578              ST_Y(ST_PointN(ExteriorRing(ST_Box2D(geometry)),4)),ST_Y(ST_PointN(ExteriorRing(ST_Box2D(geometry)),2)),
2579              ST_X(ST_PointN(ExteriorRing(ST_Box2D(geometry)),1)),ST_X(ST_PointN(ExteriorRing(ST_Box2D(geometry)),3)),
2580              numfeatures, ST_Area(geometry),
2581              geometry as area from location_area where place_id = search_place_id;
2582     select * from place_boundingbox into result where place_id = search_place_id;
2583   END IF;
2584   IF result.place_id IS NULL THEN
2585 -- TODO 0.0001
2586     insert into place_boundingbox select address_place_id,
2587              min(ST_Y(ST_Centroid(geometry))) as minlon,max(ST_Y(ST_Centroid(geometry))) as maxlon,
2588              min(ST_X(ST_Centroid(geometry))) as minlat,max(ST_X(ST_Centroid(geometry))) as maxlat,
2589              count(*), ST_Area(ST_Buffer(ST_Convexhull(ST_Collect(geometry)),0.0001)) as area,
2590              ST_Buffer(ST_Convexhull(ST_Collect(geometry)),0.0001) as boundary 
2591              from (select * from place_addressline where address_place_id = search_place_id order by cached_rank_address limit 4000) as place_addressline join placex using (place_id) 
2592              where address_place_id = search_place_id
2593 --               and (isaddress = true OR place_id = search_place_id)
2594                and (st_length(geometry) < 0.01 or place_id = search_place_id)
2595              group by address_place_id limit 1;
2596     select * from place_boundingbox into result where place_id = search_place_id;
2597   END IF;
2598   return result;
2599 END;
2600 $$
2601 LANGUAGE plpgsql;
2602
2603 -- don't do the operation if it would be slow
2604 CREATE OR REPLACE FUNCTION get_place_boundingbox_quick(search_place_id BIGINT) RETURNS place_boundingbox
2605   AS $$
2606 DECLARE
2607   result place_boundingbox;
2608   numfeatures integer;
2609   rank integer;
2610 BEGIN
2611   select * from place_boundingbox into result where place_id = search_place_id;
2612   IF result IS NULL AND rank > 14 THEN
2613     select count(*) from place_addressline where address_place_id = search_place_id and isaddress = true into numfeatures;
2614     insert into place_boundingbox select place_id,
2615              ST_Y(ST_PointN(ExteriorRing(ST_Box2D(geometry)),4)),ST_Y(ST_PointN(ExteriorRing(ST_Box2D(geometry)),2)),
2616              ST_X(ST_PointN(ExteriorRing(ST_Box2D(geometry)),1)),ST_X(ST_PointN(ExteriorRing(ST_Box2D(geometry)),3)),
2617              numfeatures, ST_Area(geometry),
2618              geometry as area from location_area where place_id = search_place_id;
2619     select * from place_boundingbox into result where place_id = search_place_id;
2620   END IF;
2621   IF result IS NULL THEN
2622     select rank_search from placex where place_id = search_place_id into rank;
2623     IF rank > 20 THEN
2624 -- TODO 0.0001
2625       insert into place_boundingbox select address_place_id,
2626              min(ST_Y(ST_Centroid(geometry))) as minlon,max(ST_Y(ST_Centroid(geometry))) as maxlon,
2627              min(ST_X(ST_Centroid(geometry))) as minlat,max(ST_X(ST_Centroid(geometry))) as maxlat,
2628              count(*), ST_Area(ST_Buffer(ST_Convexhull(ST_Collect(geometry)),0.0001)) as area,
2629              ST_Buffer(ST_Convexhull(ST_Collect(geometry)),0.0001) as boundary 
2630              from place_addressline join placex using (place_id) 
2631              where address_place_id = search_place_id 
2632                and (isaddress = true OR place_id = search_place_id)
2633                and (st_length(geometry) < 0.01 or place_id = search_place_id)
2634              group by address_place_id limit 1;
2635       select * from place_boundingbox into result where place_id = search_place_id;
2636     END IF;
2637   END IF;
2638   return result;
2639 END;
2640 $$
2641 LANGUAGE plpgsql;
2642
2643 CREATE OR REPLACE FUNCTION update_place(search_place_id BIGINT) RETURNS BOOLEAN
2644   AS $$
2645 DECLARE
2646   result place_boundingbox;
2647   numfeatures integer;
2648 BEGIN
2649   update placex set 
2650       name = place.name,
2651       housenumber = place.housenumber,
2652       street = place.street,
2653       addr_place = place.addr_place,
2654       isin = place.isin,
2655       postcode = place.postcode,
2656       country_code = place.country_code,
2657       parent_place_id = null
2658       from place
2659       where placex.place_id = search_place_id 
2660         and place.osm_type = placex.osm_type and place.osm_id = placex.osm_id
2661         and place.class = placex.class and place.type = placex.type;
2662   update placex set indexed_status = 2 where place_id = search_place_id;
2663   update placex set indexed_status = 0 where place_id = search_place_id;
2664   return true;
2665 END;
2666 $$
2667 LANGUAGE plpgsql;
2668
2669 CREATE OR REPLACE FUNCTION get_searchrank_label(rank INTEGER) RETURNS TEXT
2670   AS $$
2671 DECLARE
2672 BEGIN
2673   IF rank < 2 THEN
2674     RETURN 'Continent';
2675   ELSEIF rank < 4 THEN
2676     RETURN 'Sea';
2677   ELSEIF rank < 8 THEN
2678     RETURN 'Country';
2679   ELSEIF rank < 12 THEN
2680     RETURN 'State';
2681   ELSEIF rank < 16 THEN
2682     RETURN 'County';
2683   ELSEIF rank = 16 THEN
2684     RETURN 'City';
2685   ELSEIF rank = 17 THEN
2686     RETURN 'Town / Island';
2687   ELSEIF rank = 18 THEN
2688     RETURN 'Village / Hamlet';
2689   ELSEIF rank = 20 THEN
2690     RETURN 'Suburb';
2691   ELSEIF rank = 21 THEN
2692     RETURN 'Postcode Area';
2693   ELSEIF rank = 22 THEN
2694     RETURN 'Croft / Farm / Locality / Islet';
2695   ELSEIF rank = 23 THEN
2696     RETURN 'Postcode Area';
2697   ELSEIF rank = 25 THEN
2698     RETURN 'Postcode Point';
2699   ELSEIF rank = 26 THEN
2700     RETURN 'Street / Major Landmark';
2701   ELSEIF rank = 27 THEN
2702     RETURN 'Minory Street / Path';
2703   ELSEIF rank = 28 THEN
2704     RETURN 'House / Building';
2705   ELSE
2706     RETURN 'Other: '||rank;
2707   END IF;
2708   
2709 END;
2710 $$
2711 LANGUAGE plpgsql;
2712
2713 CREATE OR REPLACE FUNCTION get_addressrank_label(rank INTEGER) RETURNS TEXT
2714   AS $$
2715 DECLARE
2716 BEGIN
2717   IF rank = 0 THEN
2718     RETURN 'None';
2719   ELSEIF rank < 2 THEN
2720     RETURN 'Continent';
2721   ELSEIF rank < 4 THEN
2722     RETURN 'Sea';
2723   ELSEIF rank = 5 THEN
2724     RETURN 'Postcode';
2725   ELSEIF rank < 8 THEN
2726     RETURN 'Country';
2727   ELSEIF rank < 12 THEN
2728     RETURN 'State';
2729   ELSEIF rank < 16 THEN
2730     RETURN 'County';
2731   ELSEIF rank = 16 THEN
2732     RETURN 'City';
2733   ELSEIF rank = 17 THEN
2734     RETURN 'Town / Village / Hamlet';
2735   ELSEIF rank = 20 THEN
2736     RETURN 'Suburb';
2737   ELSEIF rank = 21 THEN
2738     RETURN 'Postcode Area';
2739   ELSEIF rank = 22 THEN
2740     RETURN 'Croft / Farm / Locality / Islet';
2741   ELSEIF rank = 23 THEN
2742     RETURN 'Postcode Area';
2743   ELSEIF rank = 25 THEN
2744     RETURN 'Postcode Point';
2745   ELSEIF rank = 26 THEN
2746     RETURN 'Street / Major Landmark';
2747   ELSEIF rank = 27 THEN
2748     RETURN 'Minory Street / Path';
2749   ELSEIF rank = 28 THEN
2750     RETURN 'House / Building';
2751   ELSE
2752     RETURN 'Other: '||rank;
2753   END IF;
2754   
2755 END;
2756 $$
2757 LANGUAGE plpgsql;
2758
2759 CREATE OR REPLACE FUNCTION get_word_suggestion(srcword TEXT) RETURNS TEXT
2760   AS $$
2761 DECLARE
2762   trigramtoken TEXT;
2763   result TEXT;
2764 BEGIN
2765
2766   trigramtoken := regexp_replace(make_standard_name(srcword),E'([^0-9])\\1+',E'\\1','g');
2767   SELECT word FROM word WHERE word_trigram like ' %' and word_trigram % trigramtoken ORDER BY similarity(word_trigram, trigramtoken) DESC, word limit 1 into result;
2768
2769   return result;
2770 END;
2771 $$
2772 LANGUAGE plpgsql;
2773
2774 CREATE OR REPLACE FUNCTION get_word_suggestions(srcword TEXT) RETURNS TEXT[]
2775   AS $$
2776 DECLARE
2777   trigramtoken TEXT;
2778   result TEXT[];
2779   r RECORD;
2780 BEGIN
2781
2782   trigramtoken := regexp_replace(make_standard_name(srcword),E'([^0-9])\\1+',E'\\1','g');
2783
2784   FOR r IN SELECT word,similarity(word_trigram, trigramtoken) as score FROM word 
2785     WHERE word_trigram like ' %' and word_trigram % trigramtoken ORDER BY similarity(word_trigram, trigramtoken) DESC, word limit 4
2786   LOOP
2787     result[coalesce(array_upper(result,1)+1,1)] := r.word;
2788   END LOOP;
2789
2790   return result;
2791 END;
2792 $$
2793 LANGUAGE plpgsql;
2794
2795 CREATE OR REPLACE FUNCTION aux_create_property(pointgeo GEOMETRY, in_housenumber TEXT, 
2796   in_street TEXT, in_isin TEXT, in_postcode TEXT, in_countrycode char(2)) RETURNS INTEGER
2797   AS $$
2798 DECLARE
2799
2800   newpoints INTEGER;
2801   place_centroid GEOMETRY;
2802   out_partition INTEGER;
2803   out_parent_place_id BIGINT;
2804   location RECORD;
2805   address_street_word_id INTEGER;  
2806   out_postcode TEXT;
2807
2808 BEGIN
2809
2810   place_centroid := ST_Centroid(pointgeo);
2811   out_partition := get_partition(in_countrycode);
2812   out_parent_place_id := null;
2813
2814   address_street_word_id := get_name_id(make_standard_name(in_street));
2815   IF address_street_word_id IS NOT NULL THEN
2816     FOR location IN SELECT * from getNearestNamedRoadFeature(out_partition, place_centroid, address_street_word_id) LOOP
2817       out_parent_place_id := location.place_id;
2818     END LOOP;
2819   END IF;
2820
2821   IF out_parent_place_id IS NULL THEN
2822     FOR location IN SELECT place_id FROM getNearestRoadFeature(out_partition, place_centroid) LOOP
2823       out_parent_place_id := location.place_id;
2824     END LOOP;    
2825   END IF;
2826
2827   out_postcode := in_postcode;
2828   IF out_postcode IS NULL THEN
2829     SELECT postcode from placex where place_id = out_parent_place_id INTO out_postcode;
2830   END IF;
2831   IF out_postcode IS NULL THEN
2832     out_postcode := getNearestPostcode(out_partition, place_centroid);
2833   END IF;
2834
2835   newpoints := 0;
2836   insert into location_property_aux (place_id, partition, parent_place_id, housenumber, postcode, centroid)
2837     values (nextval('seq_place'), out_partition, out_parent_place_id, in_housenumber, out_postcode, place_centroid);
2838   newpoints := newpoints + 1;
2839
2840   RETURN newpoints;
2841 END;
2842 $$
2843 LANGUAGE plpgsql;
2844
2845 CREATE OR REPLACE FUNCTION get_osm_rel_members(members TEXT[], member TEXT) RETURNS TEXT[]
2846   AS $$
2847 DECLARE
2848   result TEXT[];
2849   i INTEGER;
2850 BEGIN
2851
2852   FOR i IN 1..ARRAY_UPPER(members,1) BY 2 LOOP
2853     IF members[i+1] = member THEN
2854       result := result || members[i];
2855     END IF;
2856   END LOOP;
2857
2858   return result;
2859 END;
2860 $$
2861 LANGUAGE plpgsql;
2862
2863 CREATE OR REPLACE FUNCTION get_osm_rel_members(members TEXT[], memberLabels TEXT[]) RETURNS SETOF TEXT
2864   AS $$
2865 DECLARE
2866   i INTEGER;
2867 BEGIN
2868
2869   FOR i IN 1..ARRAY_UPPER(members,1) BY 2 LOOP
2870     IF members[i+1] = ANY(memberLabels) THEN
2871       RETURN NEXT members[i];
2872     END IF;
2873   END LOOP;
2874
2875   RETURN;
2876 END;
2877 $$
2878 LANGUAGE plpgsql;
2879
2880 -- See: http://stackoverflow.com/questions/6410088/how-can-i-mimic-the-php-urldecode-function-in-postgresql
2881 CREATE OR REPLACE FUNCTION decode_url_part(p varchar) RETURNS varchar 
2882   AS $$
2883 SELECT convert_from(CAST(E'\\x' || array_to_string(ARRAY(
2884     SELECT CASE WHEN length(r.m[1]) = 1 THEN encode(convert_to(r.m[1], 'SQL_ASCII'), 'hex') ELSE substring(r.m[1] from 2 for 2) END
2885     FROM regexp_matches($1, '%[0-9a-f][0-9a-f]|.', 'gi') AS r(m)
2886 ), '') AS bytea), 'UTF8');
2887 $$ 
2888 LANGUAGE SQL IMMUTABLE STRICT;
2889
2890 CREATE OR REPLACE FUNCTION catch_decode_url_part(p varchar) RETURNS varchar
2891   AS $$
2892 DECLARE
2893 BEGIN
2894   RETURN decode_url_part(p);
2895 EXCEPTION
2896   WHEN others THEN return null;
2897 END;
2898 $$
2899 LANGUAGE plpgsql IMMUTABLE;
2900
2901 DROP TYPE wikipedia_article_match CASCADE;
2902 create type wikipedia_article_match as (
2903   language TEXT,
2904   title TEXT,
2905   importance FLOAT
2906 );
2907
2908 CREATE OR REPLACE FUNCTION get_wikipedia_match(extratags HSTORE, country_code varchar(2)) RETURNS wikipedia_article_match
2909   AS $$
2910 DECLARE
2911   langs TEXT[];
2912   i INT;
2913   wiki_article TEXT;
2914   wiki_article_title TEXT;
2915   wiki_article_language TEXT;
2916   result wikipedia_article_match;
2917 BEGIN
2918   langs := ARRAY['english','country','ar','bg','ca','cs','da','de','en','es','eo','eu','fa','fr','ko','hi','hr','id','it','he','lt','hu','ms','nl','ja','no','pl','pt','kk','ro','ru','sk','sl','sr','fi','sv','tr','uk','vi','vo','war','zh'];
2919   i := 1;
2920   WHILE langs[i] IS NOT NULL LOOP
2921     wiki_article := extratags->(case when langs[i] in ('english','country') THEN 'wikipedia' ELSE 'wikipedia:'||langs[i] END);
2922     IF wiki_article is not null THEN
2923       wiki_article := regexp_replace(wiki_article,E'^(.*?)([a-z]{2,3}).wikipedia.org/wiki/',E'\\2:');
2924       wiki_article := regexp_replace(wiki_article,E'^(.*?)([a-z]{2,3}).wikipedia.org/w/index.php\\?title=',E'\\2:');
2925       wiki_article := regexp_replace(wiki_article,E'^(.*?)/([a-z]{2,3})/wiki/',E'\\2:');
2926       wiki_article := regexp_replace(wiki_article,E'^(.*?)([a-z]{2,3})[=:]',E'\\2:');
2927       wiki_article := replace(wiki_article,' ','_');
2928       wiki_article_title := trim(split_part(wiki_article, ':', 2));
2929       IF wiki_article_title IS NULL OR wiki_article_title = '' THEN
2930         wiki_article_title := trim(wiki_article);
2931         wiki_article_language := CASE WHEN langs[i] = 'english' THEN 'en' WHEN langs[i] = 'country' THEN get_country_language_code(country_code) ELSE langs[i] END;
2932       ELSE
2933         wiki_article_language := lower(trim(split_part(wiki_article, ':', 1)));
2934       END IF;
2935
2936       select wikipedia_article.language,wikipedia_article.title,wikipedia_article.importance
2937         from wikipedia_article 
2938         where language = wiki_article_language and 
2939         (title = wiki_article_title OR title = catch_decode_url_part(wiki_article_title) OR title = replace(catch_decode_url_part(wiki_article_title),E'\\',''))
2940       UNION ALL
2941       select wikipedia_article.language,wikipedia_article.title,wikipedia_article.importance
2942         from wikipedia_redirect join wikipedia_article on (wikipedia_redirect.language = wikipedia_article.language and wikipedia_redirect.to_title = wikipedia_article.title)
2943         where wikipedia_redirect.language = wiki_article_language and 
2944         (from_title = wiki_article_title OR from_title = catch_decode_url_part(wiki_article_title) OR from_title = replace(catch_decode_url_part(wiki_article_title),E'\\',''))
2945       order by importance desc limit 1 INTO result;
2946
2947       IF result.language is not null THEN
2948         return result;
2949       END IF;
2950     END IF;
2951     i := i + 1;
2952   END LOOP;
2953   RETURN NULL;
2954 END;
2955 $$
2956 LANGUAGE plpgsql;
2957
2958 CREATE OR REPLACE FUNCTION quad_split_geometry(geometry GEOMETRY, maxarea FLOAT, maxdepth INTEGER) 
2959   RETURNS SETOF GEOMETRY
2960   AS $$
2961 DECLARE
2962   xmin FLOAT;
2963   ymin FLOAT;
2964   xmax FLOAT;
2965   ymax FLOAT;
2966   xmid FLOAT;
2967   ymid FLOAT;
2968   secgeo GEOMETRY;
2969   secbox GEOMETRY;
2970   seg INTEGER;
2971   geo RECORD;
2972   area FLOAT;
2973   remainingdepth INTEGER;
2974   added INTEGER;
2975   
2976 BEGIN
2977
2978 --  RAISE WARNING 'quad_split_geometry: maxarea=%, depth=%',maxarea,maxdepth;
2979
2980   IF (ST_GeometryType(geometry) not in ('ST_Polygon','ST_MultiPolygon') OR NOT ST_IsValid(geometry)) THEN
2981     RETURN NEXT geometry;
2982     RETURN;
2983   END IF;
2984
2985   remainingdepth := maxdepth - 1;
2986   area := ST_AREA(geometry);
2987   IF remainingdepth < 1 OR area < maxarea THEN
2988     RETURN NEXT geometry;
2989     RETURN;
2990   END IF;
2991
2992   xmin := st_xmin(geometry);
2993   xmax := st_xmax(geometry);
2994   ymin := st_ymin(geometry);
2995   ymax := st_ymax(geometry);
2996   secbox := ST_SetSRID(ST_MakeBox2D(ST_Point(ymin,xmin),ST_Point(ymax,xmax)),4326);
2997
2998   -- if the geometry completely covers the box don't bother to slice any more
2999   IF ST_AREA(secbox) = area THEN
3000     RETURN NEXT geometry;
3001     RETURN;
3002   END IF;
3003
3004   xmid := (xmin+xmax)/2;
3005   ymid := (ymin+ymax)/2;
3006
3007   added := 0;
3008   FOR seg IN 1..4 LOOP
3009
3010     IF seg = 1 THEN
3011       secbox := ST_SetSRID(ST_MakeBox2D(ST_Point(xmin,ymin),ST_Point(xmid,ymid)),4326);
3012     END IF;
3013     IF seg = 2 THEN
3014       secbox := ST_SetSRID(ST_MakeBox2D(ST_Point(xmin,ymid),ST_Point(xmid,ymax)),4326);
3015     END IF;
3016     IF seg = 3 THEN
3017       secbox := ST_SetSRID(ST_MakeBox2D(ST_Point(xmid,ymin),ST_Point(xmax,ymid)),4326);
3018     END IF;
3019     IF seg = 4 THEN
3020       secbox := ST_SetSRID(ST_MakeBox2D(ST_Point(xmid,ymid),ST_Point(xmax,ymax)),4326);
3021     END IF;
3022
3023     IF st_intersects(geometry, secbox) THEN
3024       secgeo := st_intersection(geometry, secbox);
3025       IF NOT ST_IsEmpty(secgeo) AND ST_GeometryType(secgeo) in ('ST_Polygon','ST_MultiPolygon') THEN
3026         FOR geo IN select quad_split_geometry(secgeo, maxarea, remainingdepth) as geom LOOP
3027           IF NOT ST_IsEmpty(geo.geom) AND ST_GeometryType(geo.geom) in ('ST_Polygon','ST_MultiPolygon') THEN
3028             added := added + 1;
3029             RETURN NEXT geo.geom;
3030           END IF;
3031         END LOOP;
3032       END IF;
3033     END IF;
3034   END LOOP;
3035
3036   RETURN;
3037 END;
3038 $$
3039 LANGUAGE plpgsql;
3040
3041 CREATE OR REPLACE FUNCTION split_geometry(geometry GEOMETRY) 
3042   RETURNS SETOF GEOMETRY
3043   AS $$
3044 DECLARE
3045   geo RECORD;
3046 BEGIN
3047   -- 10000000000 is ~~ 1x1 degree
3048   FOR geo IN select quad_split_geometry(geometry, 0.25, 20) as geom LOOP
3049     RETURN NEXT geo.geom;
3050   END LOOP;
3051   RETURN;
3052 END;
3053 $$
3054 LANGUAGE plpgsql;
3055
3056
3057 CREATE OR REPLACE FUNCTION place_force_delete(placeid BIGINT) RETURNS BOOLEAN
3058   AS $$
3059 DECLARE
3060     osmid BIGINT;
3061     osmtype character(1);
3062     pclass text;
3063     ptype text;
3064 BEGIN
3065   SELECT osm_type, osm_id, class, type FROM placex WHERE place_id = placeid INTO osmtype, osmid, pclass, ptype;
3066   DELETE FROM import_polygon_delete where osm_type = osmtype and osm_id = osmid and class = pclass and type = ptype;
3067   DELETE FROM import_polygon_error where osm_type = osmtype and osm_id = osmid and class = pclass and type = ptype;
3068   -- force delete from place/placex by making it a very small geometry
3069   UPDATE place set geometry = ST_SetSRID(ST_Point(0,0), 4326) where osm_type = osmtype and osm_id = osmid and class = pclass and type = ptype;
3070   DELETE FROM place where osm_type = osmtype and osm_id = osmid and class = pclass and type = ptype;
3071
3072   RETURN TRUE;
3073 END;
3074 $$
3075 LANGUAGE plpgsql;
3076
3077 CREATE OR REPLACE FUNCTION place_force_update(placeid BIGINT) RETURNS BOOLEAN
3078   AS $$
3079 DECLARE
3080   placegeom GEOMETRY;
3081   geom GEOMETRY;
3082   diameter FLOAT;
3083   rank INTEGER;
3084 BEGIN
3085   UPDATE placex SET indexed_status = 2 WHERE place_id = placeid;
3086   SELECT geometry, rank_search FROM placex WHERE place_id = placeid INTO placegeom, rank;
3087   IF placegeom IS NOT NULL AND ST_IsValid(placegeom) THEN
3088     IF ST_GeometryType(placegeom) in ('ST_Polygon','ST_MultiPolygon') THEN
3089       FOR geom IN select split_geometry(placegeom) FROM placex WHERE place_id = placeid LOOP
3090         update placex set indexed_status = 2 where (st_covers(geom, placex.geometry) OR ST_Intersects(geom, placex.geometry)) 
3091         AND rank_search > rank and indexed_status = 0 and ST_geometrytype(placex.geometry) = 'ST_Point' and (rank_search < 28 or name is not null or (rank >= 16 and addr_place is not null));
3092         update placex set indexed_status = 2 where (st_covers(geom, placex.geometry) OR ST_Intersects(geom, placex.geometry)) 
3093         AND rank_search > rank and indexed_status = 0 and ST_geometrytype(placex.geometry) != 'ST_Point' and (rank_search < 28 or name is not null or (rank >= 16 and addr_place is not null));
3094       END LOOP;
3095     ELSE
3096         diameter := 0;
3097         IF rank = 11 THEN
3098           diameter := 0.05;
3099         ELSEIF rank < 18 THEN
3100           diameter := 0.1;
3101         ELSEIF rank < 20 THEN
3102           diameter := 0.05;
3103         ELSEIF rank = 21 THEN
3104           diameter := 0.001;
3105         ELSEIF rank < 24 THEN
3106           diameter := 0.02;
3107         ELSEIF rank < 26 THEN
3108           diameter := 0.002; -- 100 to 200 meters
3109         ELSEIF rank < 28 THEN
3110           diameter := 0.001; -- 50 to 100 meters
3111         END IF;
3112         IF diameter > 0 THEN
3113           IF rank >= 26 THEN
3114             -- roads may cause reparenting for >27 rank places
3115             update placex set indexed_status = 2 where indexed_status = 0 and rank_search > rank and ST_DWithin(placex.geometry, placegeom, diameter);
3116           ELSEIF rank >= 16 THEN
3117             -- up to rank 16, street-less addresses may need reparenting
3118             update placex set indexed_status = 2 where indexed_status = 0 and rank_search > rank and ST_DWithin(placex.geometry, placegeom, diameter) and (rank_search < 28 or name is not null or addr_place is not null);
3119           ELSE
3120             -- for all other places the search terms may change as well
3121             update placex set indexed_status = 2 where indexed_status = 0 and rank_search > rank and ST_DWithin(placex.geometry, placegeom, diameter) and (rank_search < 28 or name is not null);
3122           END IF;
3123         END IF;
3124     END IF;
3125     RETURN TRUE;
3126   END IF;
3127
3128   RETURN FALSE;
3129 END;
3130 $$
3131 LANGUAGE plpgsql;