loop.run_until_complete(test())

await www.orm.create_pool(user='root', password='', db='first_webapp')

loop = loop

conn = Connection(*args, **kwargs)

self._encoding = charset_by_name(self._charset).encoding

async def create_pool(loop=None, **kw):
    logging.info('create database connection pool...')
    global __pool
    __pool = await aiomysql.create_pool(
        host = kw.get('host', 'localhost'),
        port = kw.get('port', 3306),
        user = kw['user'],
        password = kw['password'],
        db = kw['db'],
        charset = kw.get('charset', 'utf-8'),
        autocommit = kw.get('autocommit', 'True'),
        maxsize = kw.get('maxsize', 10),
        minsize = kw.get('minsize', 1),
        loop = loop
    )

async def test():
    await www.orm.create_pool(user='root', password='', db='first_webapp')
    u = User(name='Test', email='test@example.com', passwd='1234567890', image='about:blank')
    await u.save()

loop = asyncio.get_event_loop()
loop.run_until_complete(test())
loop.close()