mirror of
https://github.com/osm-search/Nominatim.git
synced 2024-12-28 23:42:59 +03:00
14f777da18
Use the SQL formatting supplied with psycopg whenever the query needs to be put together from snippets.
46 lines
1.1 KiB
Python
46 lines
1.1 KiB
Python
"""
|
|
Functions for removing unnecessary data from the database.
|
|
"""
|
|
from pathlib import Path
|
|
|
|
from psycopg2 import sql as pysql
|
|
|
|
UPDATE_TABLES = [
|
|
'address_levels',
|
|
'gb_postcode',
|
|
'import_osmosis_log',
|
|
'import_polygon_%',
|
|
'location_area%',
|
|
'location_road%',
|
|
'place',
|
|
'planet_osm_%',
|
|
'search_name_%',
|
|
'us_postcode',
|
|
'wikipedia_%'
|
|
]
|
|
|
|
def drop_update_tables(conn):
|
|
""" Drop all tables only necessary for updating the database from
|
|
OSM replication data.
|
|
"""
|
|
parts = (pysql.SQL("(tablename LIKE {})").format(pysql.Literal(t)) for t in UPDATE_TABLES)
|
|
|
|
with conn.cursor() as cur:
|
|
cur.execute(pysql.SQL("SELECT tablename FROM pg_tables WHERE ")
|
|
+ pysql.SQL(' or ').join(parts))
|
|
tables = [r[0] for r in cur]
|
|
|
|
for table in tables:
|
|
cur.drop_table(table, cascade=True)
|
|
|
|
conn.commit()
|
|
|
|
|
|
def drop_flatnode_file(fname):
|
|
""" Remove the flatnode file if it exists.
|
|
"""
|
|
if fname:
|
|
fpath = Path(fname)
|
|
if fpath.exists():
|
|
fpath.unlink()
|