Python aiomysql 我遇到的异常情况

[nightstart]

问题描述 用我自己封装的这个模块 会出现好几个问题

1. insert 进去之后 select 然后会获取不到结果
2. 我在命令行操作 mysql delete 一些数据 select 不会立马反应过来

两者都在我重启项目之后正常了 我感觉是缓存的问题

1. 解决方案是在 insert 函数里面 尾部加入 cls.pool = None 相当于让这个 pool 失效了 下次重新建立 pool 读的是最新的数据。 但是这个解决方案对 2 没用 await cur.execute("commit;") await conn.commit() 这两者我都加了 但是感觉还是没起作用

那个 select 有缓存真的是醉了 读不到最新的数据 而且 cls.pool = None 就完全发挥不了连接池的作用了 求帮忙

class AioMysqlHelper:

    pool = None

    @classmethod
    async def get_pool(cls):

        if not cls.pool:
            cls.pool = await aiomysql.create_pool(**Config.mysql)

        return cls.pool

    @classmethod
    async def insert(cls, sql, params=None):
        params = params or []
        await cls.get_pool()
        async with cls.pool.acquire() as conn:
            async with conn.cursor() as cur:
                try:
                    await cur.execute(sql, params)
                    await cur.execute("commit;")
                    await conn.commit()
                except Exception as err:
                    await conn.rollback()
                    raise err
       	cls.pool = None

    @classmethod
    async def select(cls, sql, params=None, one=True):
        params = params or []
        await cls.get_pool()
        async with cls.pool.acquire() as conn:
            async with conn.cursor() as cur:
                try:
                    await cur.execute(sql, params)
                    return await (cur.fetchone() if one else cur.fetchall())
                except Exception as err:
                    conn.rollback()
                    raise err

[janxin]

考虑过脏读幻读问题么

[nightstart]

@janxin 幻读脏读应该是在并发比较大的情况下出现的吧。 我的操作是顺序操作 比如上面插入了一条记录 然后紧接着下一个操作是去把这条记录通过条件读出来 然后就遇到了这种情况

[Trim21]

我试了一下没法复现...
https://gist.github.com/Trim21/b5f77e819d7fdc0ccd1364c2f563ab4e

你具体调用这个库的代码和 Config.mysql 是什么样的

[pynix]

估计你没理解 aio

[GTim]

@pynix 同意楼上，你用同步思维的方式来写异步代码，insert 还没执行完的时候，select 就开始执行了，那就没数据了

[nightstart]

@Trim21 你好我弄了一个 demo 能百分百复现问题的 但是 V2EX 的帖子无法编辑 ....

[nightstart]

```
# -*- coding: utf-8 -*-
import time
import asyncio
from app.utils.aiomyob import AioMysqlHelper

async def select():
for _ in range(10):
await asyncio.sleep(1)
print(await AioMysqlHelper.select("SELECT * FROM test", one=False))

async def main():
await asyncio.gather(*[select() for _ in range(1)])

if __name__ == "__main__":
start = time.time()
loop = asyncio.get_event_loop()
loop.run_until_complete(AioMysqlHelper.init_pool())
loop.run_until_complete(main())
loop.close()
print(time.time() - start)
```

先在数据库里面手动插入一条数据
在十次 print 的过程中 挑个时间在数据库中手动执行 delete from test;
输出是这样的

```
[{'id': 24, 'name': 'wwww'}]
[{'id': 24, 'name': 'wwww'}]
[{'id': 24, 'name': 'wwww'}]
[{'id': 24, 'name': 'wwww'}]
()
[{'id': 24, 'name': 'wwww'}]
[{'id': 24, 'name': 'wwww'}]
[{'id': 24, 'name': 'wwww'}]
[{'id': 24, 'name': 'wwww'}]
()
```