orm.py 文件源码

def select(sql, args, size=None):
    log(sql, args)
    # ??????????????????with???????????conn?????????
    async with __pool.get() as conn:
        # ????????DictCursor????dict?????????????????????SQL
        async with conn.cursor(aiomysql.DictCursor) as cur:
            await cur.execute(sql.replace('?', '%s'), args)  # ?sql??'?'???'%s'???mysql????????%s
            # ????size
            if size:
                resultset = await cur.fetchmany(size)  # ???????????
            else:
                resultset = await cur.fetchall()      # ????????
        logging.info('rows returned: %s' % len(resultset))
        return resultset

# ??SQL?INSERT INTO?UPDATE?DELETE???execute???????????????