old_contents: #!/usr/bin/env python3
  # -*- coding:utf-8 -*-
  
  __author__ = ""
  
  '''
  '''
  
  import asyncio,logging
  import aiomysql
  
  def log(sql,args=()):
      logging.info('SQL: %s' % sql)
  
  async def create_pool(loop,**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
      )
  
new_contents: #!/usr/bin/env python3
  # -*- coding:utf-8 -*-
  
  __author__ = ""
  
  '''
  '''
  
  import asyncio,logging
  logging.basicConfig(level=logging.INFO)
  import aiomysql
  
  def log(sql,args=()):
      logging.info('SQL: %s' % sql)
  
  async def create_pool(loop,**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 select(sql,args,size=None):
      log(sql,args)
      global _pool
      async with _pool.get() as conn:
          async with conn.cursor(aiomysql.DictCursor) as cur:
              await cur.execute(sql.replace('?','%s'),args or ())
              if size:
                  rs = await cur.fetchmany(size)
              else:
                  rs = await cur.fetchall()
          logging.info('rows returned: %s' % len(rs))
          return rs
  
  
subject: modify orm.py