python-db.py

async def insert_one(pool, sql, params):
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            try:
                await cur.execute(sql, params)
                value = await cur.fetchone()
            except Exception as e:
                await conn.rollback()
                raise e
            else:
                await conn.commit()
            return cur.lastrowid