Is it possible to use this method with Databases? I’ve tried passing the connection in, the connection url but it keeps failing when trying to access the cursor.
This does not answer the question, but does provide a simple alternative for those who stumble across this.
this_res = await db.fetch_all(this_sel) this_df = pd.DataFrame([dict(record) for record in this_res])
where this_sel is a sqlalch Select obj
con SQLAlchemy connectable (engine/connection) or database str URI
or DBAPI2 connection (fallback mode)’
Using SQLAlchemy makes it possible to use any DB supported by that library. If a DBAPI2 object, only sqlite3 is supported. The user is responsible for engine disposal and connection closure for the SQLAlchemy connectable. See here