在一个循环中从db获取结果，该循环具有可完成的future

import asyncio
import aiomysql

async def fetch_results():
    # 创建数据库连接
    conn = await aiomysql.connect(host='localhost', port=3306,
                                  user='root', password='password',
                                  db='mydatabase')

    # 创建游标对象
    cursor = await conn.cursor()

    # 执行查询语句
    await cursor.execute('SELECT * FROM mytable')

    # 获取查询结果
    results = await cursor.fetchall()

    # 关闭游标和连接
    await cursor.close()
    conn.close()

    return results

async def main():
    # 创建事件循环
    loop = asyncio.get_event_loop()

    # 创建可完成的future
    future = asyncio.ensure_future(fetch_results())

    # 在循环中等待结果
    while not future.done():
        await asyncio.sleep(1)

    # 获取结果
    results = future.result()

    # 处理结果
    for row in results:
        # 进行处理操作
        pass

    # 关闭事件循环
    loop.close()

# 运行主函数
asyncio.run(main())