summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/dialects/postgresql/asyncpg.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2023-05-03 22:33:28 -0400
committerMike Bayer <mike_mp@zzzcomputing.com>2023-05-04 08:47:11 -0400
commit667a9ca21417f5ae9d2c5bd031506cf40c8e5909 (patch)
tree0ef35a046e71989af619847a1a08cae9026b05d2 /lib/sqlalchemy/dialects/postgresql/asyncpg.py
parent228490ead7048f2e558c25b0f055bdb952272ec4 (diff)
downloadsqlalchemy-667a9ca21417f5ae9d2c5bd031506cf40c8e5909.tar.gz
add bind casts for BYTEA on asyncpg
Fixed another regression due to the "insertmanyvalues" change in 2.0.10 as part of :ticket:`9618`, in a similar way as regression :ticket:`9701`, where :class:`.LargeBinary` datatypes also need additional casts on when using the asyncpg driver specifically in order to work with the new bulk INSERT format. Fixes: #9739 Change-Id: I57370d269ea757f263c1f3a16c324ceae76fd4e8
Diffstat (limited to 'lib/sqlalchemy/dialects/postgresql/asyncpg.py')
-rw-r--r--lib/sqlalchemy/dialects/postgresql/asyncpg.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/postgresql/asyncpg.py b/lib/sqlalchemy/dialects/postgresql/asyncpg.py
index c879205e4..3f33600f9 100644
--- a/lib/sqlalchemy/dialects/postgresql/asyncpg.py
+++ b/lib/sqlalchemy/dialects/postgresql/asyncpg.py
@@ -182,6 +182,7 @@ from .base import PGExecutionContext
from .base import PGIdentifierPreparer
from .base import REGCLASS
from .base import REGCONFIG
+from .types import BYTEA
from ... import exc
from ... import pool
from ... import util
@@ -212,6 +213,10 @@ class AsyncpgTime(sqltypes.Time):
render_bind_cast = True
+class AsyncpgByteA(BYTEA):
+ render_bind_cast = True
+
+
class AsyncpgDate(sqltypes.Date):
render_bind_cast = True
@@ -986,6 +991,7 @@ class PGDialect_asyncpg(PGDialect):
sqltypes.Numeric: AsyncpgNumeric,
sqltypes.Float: AsyncpgFloat,
sqltypes.JSON: AsyncpgJSON,
+ sqltypes.LargeBinary: AsyncpgByteA,
json.JSONB: AsyncpgJSONB,
sqltypes.JSON.JSONPathType: AsyncpgJSONPathType,
sqltypes.JSON.JSONIndexType: AsyncpgJSONIndexType,