X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/4fc61d260f1dbefeafff6e5b374852147f27afe0..3d58254462289cad257cb96d60b7a24f8e7fc8da:/nominatim/tools/country_info.py diff --git a/nominatim/tools/country_info.py b/nominatim/tools/country_info.py index 9ed666ff..f6a6293f 100644 --- a/nominatim/tools/country_info.py +++ b/nominatim/tools/country_info.py @@ -7,19 +7,19 @@ """ Functions for importing and managing static country information. """ -import json import psycopg2.extras from nominatim.db import utils as db_utils from nominatim.db.connection import connect + class _CountryInfo: """ Caches country-specific properties from the configuration file. """ def __init__(self): self._info = {} - + self._key_prefix = 'name' def load(self, config): """ Load the country properties from the configuration files, @@ -27,7 +27,6 @@ class _CountryInfo: """ if not self._info: self._info = config.load_sub_configuration('country_settings.yaml') - self._key_prefix = 'name' # Convert languages into a list for simpler handling. for prop in self._info.values(): if 'languages' not in prop: @@ -35,8 +34,8 @@ class _CountryInfo: elif not isinstance(prop['languages'], list): prop['languages'] = [x.strip() for x in prop['languages'].split(',')] - if 'names' not in prop: - prop['names'][self._key_prefix] = {} + if 'names' not in prop or prop['names'] is None: + prop['names'] = {self._key_prefix: {}} def items(self): """ Return tuples of (country_code, property dict) as iterable. @@ -44,7 +43,7 @@ class _CountryInfo: return self._info.items() def key_prefix(self): - """ Return the prefix that will be attached to the keys of the country + """ Return the prefix that will be attached to the keys of the country names values when storing them in the database """ return self._key_prefix @@ -52,6 +51,7 @@ class _CountryInfo: _COUNTRY_INFO = _CountryInfo() + def setup_country_config(config): """ Load country properties from the configuration file. Needs to be called before using any other functions in this @@ -82,12 +82,14 @@ def setup_country_tables(dsn, sql_dir, ignore_partitions=False): partition = 0 else: partition = props.get('partition') - lang = props['languages'][0] if len(props['languages']) == 1 else None - name = add_prefix_to_keys(props.get('names').get(_COUNTRY_INFO.key_prefix()), _COUNTRY_INFO.key_prefix()) - name = json.dumps(name, ensure_ascii=False, separators=(', ', '=>')) - params.append((ccode, name[1:-1], lang, partition)) + lang = props['languages'][0] if len( + props['languages']) == 1 else None + name = add_prefix_to_keys(props.get('names').get( + _COUNTRY_INFO.key_prefix()), _COUNTRY_INFO.key_prefix()) + params.append((ccode, name, lang, partition)) with connect(dsn) as conn: with conn.cursor() as cur: + psycopg2.extras.register_hstore(cur) cur.execute( """ CREATE TABLE public.country_name ( country_code character varying(2), @@ -114,7 +116,8 @@ def create_country_names(conn, tokenizer, languages=None): def _include_key(key): return key == _COUNTRY_INFO.key_prefix() or \ - (key.startswith(_COUNTRY_INFO.key_prefix()+':') and (not languages or key[len(_COUNTRY_INFO.key_prefix())+1:] in languages)) + (key.startswith(_COUNTRY_INFO.key_prefix()+':') and + (not languages or key[len(_COUNTRY_INFO.key_prefix())+1:] in languages)) with conn.cursor() as cur: psycopg2.extras.register_hstore(cur) @@ -131,7 +134,8 @@ def create_country_names(conn, tokenizer, languages=None): # country names (only in languages as provided) if name: - names.update(((k, v) for k, v in name.items() if _include_key(k))) + names.update(((k, v) + for k, v in name.items() if _include_key(k))) analyzer.add_country_names(code, names)