Connection¶

class asyncpg.connection.Connection¶

conn = await asyncpg.connection(DSN)

fetch(sql)¶

Возвращает список записей asyncpg.Record()

rows = conn.fetch('select * from "persons"')
rows = conn.fetch('select * from "persons" where "id" = $1', 2)

transaction()¶

async with conn.transaction():
    async conn.fetch()