asyncio异步编程之异步mysql

import asyncioimport aiomysqlasync def async_ope_mysql():sql_conn = await aiomysql.connect(host="", user="xx", password="!xx",db="xx", port=3306)cur = await sql_conn.cursor()sql = "select Host, User f

一起学python吧

890人浏览 · 2022-03-09 18:30:01

一起学python吧 · 2022-03-09 18:30:01 发布

import asyncio
import aiomysql


async def async_ope_mysql():
    sql_conn = await aiomysql.connect(host="", user="xx", password="!xx",
                 db="xx", port=3306)
    cur = await sql_conn.cursor()
    sql = "select Host, User from user;"
    await cur.execute(sql)
    u = await cur.fetchall()
    print(u)
    await cur.close()
    sql_conn.close()

async def main():
    tasks = [
        asyncio.ensure_future(async_ope_mysql()),
        asyncio.ensure_future(async_ope_mysql())
    ]
    await asyncio.wait(tasks)

if __name__ == '__main__':
    p = asyncio.get_event_loop()
    p.run_until_complete(main())