Discord Bot aiopg example

aiopg-discordbot.py

import aiopg

#attach the pool to the bot
async def create_pool():
    connstring = 'dbname=databasename user=databaseuser password=databasepassword host=databasehost'
    pool = await aiopg.create_pool(connstring)
    return pool

async def start_bot():
    pool = await create_pool()
    client.pool = pool
    await client.start("token")

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(start_bot())

#in any command
@client.command()
async def test():
    async with client.pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute("SELECT 1;")
            result = await cur.fetchall()

#injection safe when using vars
myvar = "hello"
await cur.execute('SELECT * FROM table WHERE "column_value"=%s;', (myvar,))
#use a tuple to specify the values to use for %s
#%s is used also for integers, booleans and others