diff options
| author | Florian Apolloner <florian@apolloner.eu> | 2022-12-12 09:54:49 +0100 |
|---|---|---|
| committer | Mariusz Felisiak <felisiak.mariusz@gmail.com> | 2022-12-12 10:36:45 +0100 |
| commit | db7bb3b64e469fbb5c79e7b5b2fcb890434aa60f (patch) | |
| tree | fc995dec5ccb21baf840b2303b5e59df67e50bfa /django | |
| parent | 1d90c9b1132482d446ca8375c151e894002c9e8d (diff) | |
Refs #33308 -- Added DatabaseOperations.compose_sql() on PostgreSQL.
Diffstat (limited to 'django')
| -rw-r--r-- | django/contrib/postgres/search.py | 9 | ||||
| -rw-r--r-- | django/db/backends/postgresql/operations.py | 5 | ||||
| -rw-r--r-- | django/db/backends/postgresql/psycopg_any.py | 5 |
3 files changed, 10 insertions, 9 deletions
diff --git a/django/contrib/postgres/search.py b/django/contrib/postgres/search.py index 2b57156263..05c8f72f6f 100644 --- a/django/contrib/postgres/search.py +++ b/django/contrib/postgres/search.py @@ -1,5 +1,3 @@ -import psycopg2 - from django.db.models import ( CharField, Expression, @@ -309,14 +307,9 @@ class SearchHeadline(Func): options_sql = "" options_params = [] if self.options: - # getquoted() returns a quoted bytestring of the adapted value. options_params.append( ", ".join( - "%s=%s" - % ( - option, - psycopg2.extensions.adapt(value).getquoted().decode(), - ) + connection.ops.compose_sql(f"{option}=%s", [value]) for option, value in self.options.items() ) ) diff --git a/django/db/backends/postgresql/operations.py b/django/db/backends/postgresql/operations.py index e86628ede2..824e0c3e4b 100644 --- a/django/db/backends/postgresql/operations.py +++ b/django/db/backends/postgresql/operations.py @@ -3,7 +3,7 @@ from functools import lru_cache, partial from django.conf import settings from django.db.backends.base.operations import BaseDatabaseOperations -from django.db.backends.postgresql.psycopg_any import Inet, Jsonb +from django.db.backends.postgresql.psycopg_any import Inet, Jsonb, mogrify from django.db.backends.utils import split_tzname_delta from django.db.models.constants import OnConflict @@ -174,6 +174,9 @@ class DatabaseOperations(BaseDatabaseOperations): return name # Quoting once is enough. return '"%s"' % name + def compose_sql(self, sql, params): + return mogrify(sql, params, self.connection) + def set_time_zone_sql(self): return "SET TIME ZONE %s" diff --git a/django/db/backends/postgresql/psycopg_any.py b/django/db/backends/postgresql/psycopg_any.py index 83e8a9f4d3..e9bb84f313 100644 --- a/django/db/backends/postgresql/psycopg_any.py +++ b/django/db/backends/postgresql/psycopg_any.py @@ -24,3 +24,8 @@ def _quote(value, connection=None): sql.quote = _quote + + +def mogrify(sql, params, connection): + with connection.cursor() as cursor: + return cursor.mogrify(sql, params).decode() |
