Examples of aiomysql usage

Below is a list of examples from aiomysql/examples

Every example is a correct tiny python program.

Low-level API

import asyncio
import aiomysql


loop = asyncio.get_event_loop()


@asyncio.coroutine
def test_example():
    conn = yield from aiomysql.connect(host='127.0.0.1', port=3306,
                                       user='root', passwd='', db='mysql',
                                       loop=loop)

    cur = conn.cursor()
    yield from cur.execute("SELECT Host,User FROM user")
    print(cur.description)
    r = yield from cur.fetchall()
    print(r)
    yield from cur.close()
    conn.close()

loop.run_until_complete(test_example())

Simple sqlalchemy usage

import asyncio
import sqlalchemy as sa

from aiomysql.sa import create_engine


metadata = sa.MetaData()

tbl = sa.Table('tbl', metadata,
   sa.Column('id', sa.Integer, primary_key=True),
   sa.Column('val', sa.String(255)))


@asyncio.coroutine
def go():
   engine = yield from create_engine(user='root',
                                     db='aiomysql',
                                     host='127.0.0.1',
                                     password='')

   with (yield from engine) as conn:
       yield from conn.execute(tbl.insert().values(val='abc'))

       res = yield from conn.execute(tbl.select())
       for row in res:
           print(row.id, row.val)


asyncio.get_event_loop().run_until_complete(go())