triopg 0.2.1

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():
    conn = await triopg.connect()

    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.execute("SELECT * FROM users"))


trio_asyncio.run(main)