python - 定期重新运行相同查询时无法获取最新行

Question

我正在使用 Python MySQLdb 模块。我每 1 秒查询一次表。新行一直被添加到这个表中。代码如下；

def main(): 
    connectMySqlDb_tagem()

    while True:
        queryTable()
        time.sleep(1)

        closeDBconnection()   

代码的问题是查询没有返回最新的行。它总是返回相同的行。为了解决这个问题，我每次都必须关闭 MySQL 连接并重新建立一个新的 MySQL 连接。可行的代码如下所示；

def main(): 

    while True:
        connectMySqlDb_tagem()
        queryTable()
        closeDBconnection() 
        time.sleep(1)

如何避免每次都建立新的连接以获得最新的行？

Answer 1

通过 SQL_NO_CACHE在您的 SELECT 查询中，或在 session 级别将其关闭:

cursor.execute("SET SESSION query_cache_type = OFF")

另见:

• How to turn off MySQL query cache while using SQLAlchemy?
• MySQL - force not to use cache for testing speed of query

希望对您有所帮助。