asyncpgsa icon indicating copy to clipboard operation
asyncpgsa copied to clipboard

A wrapper around asyncpg for use with sqlalchemy

Results 16 asyncpgsa issues
Sort by recently updated
recently updated
newest added

Today caught issue with incompatibility asyncpgsa==0.26.1 with asyncpg==0.22.0 (but found that latest release works well!). So, i opened releases to see the diff between 0.26.1 and latest, but found the...

This works fine with asyncpgsa version 0.27.1 and sqlalchemy: 1.3.23, but fails when I upgrade to sqlalchemy 1.4.4. ```python import asyncpgsa import sqlalchemy as sa Thing = sa.Table("thing", sa.MetaData(), sa.Column("name",...

Please teach how to do `Table(autoload=True)` or `metadata.reflect()` with asyncpgsa properly. Tried passing `reflect(bind=asyncpgsa_connection)` and it's AttributeError game: needs connect then dialect, I feel like it's going in wrong direction....

Perhaps you could advice some fast fix or workaround for that? I need update for many different rows with different values. Previously used bindparam for that. ``` import asyncio from...

I need TypeDecorator for my data column, it is handled by SQLAlchemy + psycopg2 correctly. Is it possible to make it work with asyncpgsa? ``` import asyncio from datetime import...

## My envs ```shell - Python 3.6.3 - asyncpgsa==0.18.1 - asyncpg==0.12.0 - sqlalchemy==1.1.15 ``` ## My code sample ```python from asyncpgsa import PG from app import app DB_CONFIG = {...

Is there any way to get `rowcount` (updated rows amount) using `pg` singleton?

Hi, Im facing some problems when I insert a JSONB into a table, I get this error: ``` following exception: 'StrCompileDialect' object has no attribute '_json_serializer' Traceback (most recent call...

bug
important

Having field defined this way `Column('abc', JSON)`, I have to use `json.loads` to get dict: ``` rows = await pg.fetch(sql) async for row in rows: print(json.loads(row.abc)) ``` `row.abc` is string

bug

I have declared a connection pool and tried to call cursor like so: ```python pool = asyncpgsa.create_pool() async with pool.transaction() as t: async with t.query("SELECT * FROM whatever") as cursor:...

bug
help wanted