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???????????????
评论列表
文章目录