triopg
Welcome to triopg!
PostgreSQL client for Trio based on asyncpg
License: Your choice of MIT or Apache License 2.0
Quick example:
import trio_asyncio
import triopg
async def main():
async with triopg.connect() as conn:
await conn.execute(
"""
DROP TABLE IF EXISTS users;
CREATE TABLE IF NOT EXISTS users (
_id SERIAL PRIMARY KEY,
user_id VARCHAR(32) UNIQUE
)"""
)
async with conn.transaction():
await conn.execute("INSERT INTO users (user_id) VALUES (1)")
await conn.execute("INSERT INTO users (user_id) VALUES (2)")
await conn.execute("INSERT INTO users (user_id) VALUES (3)")
print(await conn.fetch("SELECT * FROM users"))
trio_asyncio.run(main)