You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Regarding #42 (which applies the type bind processors when adding parameters to the queries), I found that the reverse direction is not working yet — the type result processors (both for user-defined type decroators and dialect-specific types) are not invoked when reading the fetched rows.
I tried to fix this by myself, but it seems to be much more complicated than I first thought:
It requires major rewriting of the current SAConnection class so that compiled._result_columns are passed around. This is not trivial because we currently subclasses asyncpg.connection.Connection directly and extends its API by overrides, e.g., we need to know which methods are invoked by who (either the base class or our class).
Record and RecordGenerator classes should have reference to both the compiled._result_columns and _dialect.dbapi_type_map. So Record is no longer just a thin wrapper of the given "row" dict but an active post-processor of row fields, like in aiopg.
Whenever accessing the row values, we need to lookup and apply result processors based on the above two maps.
For custom types, maybe I need to fall back to aiopg for more complete SA functionality due to my time limits. It is unfortunate not to have public/documented SQLAlchemy APIs to make low-level adaptor libraries like asyncpgsa and aiopg. 😢
The text was updated successfully, but these errors were encountered:
So... 6 months later, it looks like I havent dug into this. I would love to, but apparently havent been able to find the time. I am adding this to my official backlog to hope I get to it. But in the meantime, PR's would be helpful if this is important for anyone.
Regarding #42 (which applies the type bind processors when adding parameters to the queries), I found that the reverse direction is not working yet — the type result processors (both for user-defined type decroators and dialect-specific types) are not invoked when reading the fetched rows.
I tried to fix this by myself, but it seems to be much more complicated than I first thought:
SAConnection
class so thatcompiled._result_columns
are passed around. This is not trivial because we currently subclassesasyncpg.connection.Connection
directly and extends its API by overrides, e.g., we need to know which methods are invoked by who (either the base class or our class).Record
andRecordGenerator
classes should have reference to both thecompiled._result_columns
and_dialect.dbapi_type_map
. SoRecord
is no longer just a thin wrapper of the given "row" dict but an active post-processor of row fields, like in aiopg.For custom types, maybe I need to fall back to aiopg for more complete SA functionality due to my time limits. It is unfortunate not to have public/documented SQLAlchemy APIs to make low-level adaptor libraries like asyncpgsa and aiopg. 😢
The text was updated successfully, but these errors were encountered: