asyncpgsa
asyncpgsa copied to clipboard
Record proxy with type result processors
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 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. - 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. :cry:
I might be able to figure this out. I think you gave me enough information to pursue it.
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.