Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import asyncio
- import asyncpg
- async def run():
- conn = await asyncpg.connect(user='user', password='password',
- database='database', host='127.0.0.1')
- values = await conn.fetch('''SELECT * FROM mytable''')
- await conn.close()
- loop = asyncio.get_event_loop()
- loop.run_until_complete(run())
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement