在常规中重新运行同一查询时无法获取最新行

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

尝试：

connection.commit()

而不是断开和重新连接，看看它是否解决了你的问题。你知道吗

Answer 2

在SELECT查询中传递SQL_NO_CACHE，或在会话级别将其关闭：

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

希望有帮助。你知道吗