使用aiomysql库操作mysql数据库,
在数据库连接管理器中已经创建好了数据库相关连接,
当连接以后,数据库数据手动修改,然后查询,发现查询到的数据仍是没修改之前的
从新对数据库进行连接,aiomysql.connect(),再查询,发现可以查询到修改后的数据,
请问,aiomysql.connect()所创建的连接,是否会保存当时的数据库表状态?还是别的原因,导致每次查询之前,必须从新连接才能查到最新数据
https://www.cnblogs.com/traditional/p/11326736.html
#要commit 一下, 不然conn会缓存上一次查询得内容
#要commit 一下, 不然conn会缓存上一次查询得内容
#要commit 一下, 不然conn会缓存上一次查询得内容
async def getCurosr(self):
conn = await self.pool.acquire()
cur = await conn.cursor()
return conn, cur
async def query(self, query, param=None):
conn, cur = await self.getCurosr()
try:
await cur.execute(query, param)
return await cur.fetchall()
except Exception as e:
logger.gLogger.NodeLog("query sql err: {}", e)
finally:
if cur:
await cur.close()
# 释放掉conn,将连接放回到连接池中
#要commit 一下, 不然conn会缓存上一次查询得内容
await conn.commit()
await self.pool.release(conn)