我正在循環中運行SELECT查詢.
偶爾,數據庫表會更新(由另一個程序).
第一個SELECT檢索正確的數據,但循環中的其他調用返回第一個值.
如何檢索最新數據?
到目前為止我找到的唯一解決方法是在每次迭代時重新連接到數據庫!在我的例子中,取消注釋#1#和#2#的注釋.僅取消注釋#2#是不夠的(即,重新創建游標),結果仍然被緩存.
這是一個給出錯誤的工作示例.
import MySQLdb
from time import sleep
class DB:
def __init__(self):
self.connection = MySQLdb.connect(mysql_host, mysql_user, mysql_pass, mysql_db)
self.cursor = self.connection.cursor()
def get(self):
sql = ''' SELECT id, message FROM mps_messages
WHERE topic=%s ORDER BY id LIMIT 1 '''
#1# self.connect()
#2# self.cursor = self.connection.cursor()
self.cursor.execute(sql, ("topic",) )
rec = self.cursor.fetchone()
print rec
def loop(self):
while True:
self.get()
sleep(4)
db=DB()
db.loop()
> OS:ubuntu,
> python:2.7.4
> mysqldb:1.2.3
> mysql:5.5.34