X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/0add25e33500110a36458a0bb3fa292d408d2b85..57598a048e9124b905572ed8dc4fa9465b5d38a6:/src/nominatim_db/db/sql_preprocessor.py diff --git a/src/nominatim_db/db/sql_preprocessor.py b/src/nominatim_db/db/sql_preprocessor.py index 25faead4..4424b3d8 100644 --- a/src/nominatim_db/db/sql_preprocessor.py +++ b/src/nominatim_db/db/sql_preprocessor.py @@ -11,10 +11,11 @@ from typing import Set, Dict, Any, cast import jinja2 -from .connection import Connection, server_version_tuple, postgis_version_tuple +from .connection import Connection from ..config import Configuration from ..db.query_pool import QueryPool + def _get_partitions(conn: Connection) -> Set[int]: """ Get the set of partitions currently in use. """ @@ -35,6 +36,7 @@ def _get_tables(conn: Connection) -> Set[str]: return set((row[0] for row in list(cur))) + def _get_middle_db_format(conn: Connection, tables: Set[str]) -> str: """ Returns the version of the slim middle tables. """ @@ -67,14 +69,8 @@ def _setup_postgresql_features(conn: Connection) -> Dict[str, Any]: """ Set up a dictionary with various optional Postgresql/Postgis features that depend on the database version. """ - pg_version = server_version_tuple(conn) - postgis_version = postgis_version_tuple(conn) - pg11plus = pg_version >= (11, 0, 0) - ps3 = postgis_version >= (3, 0) - return { - 'has_index_non_key_column': pg11plus, - 'spgist_geom' : 'SPGIST' if pg11plus and ps3 else 'GIST' - } + return {} + class SQLPreprocessor: """ A environment for preprocessing SQL files from the @@ -102,7 +98,6 @@ class SQLPreprocessor: self.env.globals['db'] = db_info self.env.globals['postgres'] = _setup_postgresql_features(conn) - def run_string(self, conn: Connection, template: str, **kwargs: Any) -> None: """ Execute the given SQL template string on the connection. The keyword arguments may supply additional parameters @@ -114,7 +109,6 @@ class SQLPreprocessor: cur.execute(sql) conn.commit() - def run_sql_file(self, conn: Connection, name: str, **kwargs: Any) -> None: """ Execute the given SQL file on the connection. The keyword arguments may supply additional parameters for preprocessing. @@ -125,7 +119,6 @@ class SQLPreprocessor: cur.execute(sql) conn.commit() - async def run_parallel_sql_file(self, dsn: str, name: str, num_threads: int = 1, **kwargs: Any) -> None: """ Execute the given SQL files using parallel asynchronous connections.