Refs #33308 -- Added psycopg_any.sql.quote() hook.

2 files changed, 14 insertions, 7 deletions

diff --git a/django/db/backends/postgresql/psycopg_any.py b/django/db/backends/postgresql/psycopg_any.py
index 6dcd68f5eb..8e0d170867 100644
--- a/django/db/backends/postgresql/psycopg_any.py
+++ b/django/db/backends/postgresql/psycopg_any.py
@@ -1,6 +1,17 @@
-from psycopg2 import errors, extensions  # NOQA
+from psycopg2 import errors, extensions, sql  # NOQA
 from psycopg2.extras import DateRange, DateTimeRange, DateTimeTZRange, Inet  # NOQA
 from psycopg2.extras import Json as Jsonb  # NOQA
 from psycopg2.extras import NumericRange, Range  # NOQA
 
 RANGE_TYPES = (DateRange, DateTimeRange, DateTimeTZRange, NumericRange)
+
+
+def _quote(value, connection=None):
+    adapted = extensions.adapt(value)
+    if hasattr(adapted, "encoding"):
+        adapted.encoding = "utf8"
+    # getquoted() returns a quoted bytestring of the adapted value.
+    return adapted.getquoted().decode()
+
+
+sql.quote = _quote
diff --git a/django/db/backends/postgresql/schema.py b/django/db/backends/postgresql/schema.py
index 0c2043db35..cc0da85817 100644
--- a/django/db/backends/postgresql/schema.py
+++ b/django/db/backends/postgresql/schema.py
@@ -1,6 +1,6 @@
 from django.db.backends.base.schema import BaseDatabaseSchemaEditor
 from django.db.backends.ddl_references import IndexColumns
-from django.db.backends.postgresql.psycopg_any import extensions
+from django.db.backends.postgresql.psycopg_any import sql
 from django.db.backends.utils import strip_quotes
 
 
@@ -51,11 +51,7 @@ class DatabaseSchemaEditor(BaseDatabaseSchemaEditor):
     def quote_value(self, value):
         if isinstance(value, str):
             value = value.replace("%", "%%")
-        adapted = extensions.adapt(value)
-        if hasattr(adapted, "encoding"):
-            adapted.encoding = "utf8"
-        # getquoted() returns a quoted bytestring of the adapted value.
-        return adapted.getquoted().decode()
+        return sql.quote(value, self.connection.connection)
 
     def _field_indexes_sql(self, model, field):
         output = super()._field_indexes_sql(model, field)