使用pyodbc不断地从数据库中读取数据



我有一个不断更新的数据库(5s间隔值(,我的意图是读取数据库中更新的新数据,下面是我的第一个代码草案。然而,我设法读到了代码执行时的最后一行,然后它停止了。我需要代码不断运行,以便它获取新的数据条目(我们的数据库每5秒更新一次(。

import csv
import pyodbc
server = '*****' 
database = '******' 
username = '******' 
password = '*****' 
cnxn = pyodbc.connect('DRIVER={SQL SERVER};SERVER='+server+';DATABASE='+database+';UID='+username+';PWD='+ password)
cursor = cnxn.cursor()
cursor.execute("select * from marketc")
row = cursor.fetchone()
while row is not None:
row = cursor.fetchone()
print (row)

*这可能很难理解,但主要的一点是,我只想读取数据库中的最后一行,其中数据库每5秒不断更新一次。

设法对其进行了编码。我只导入时间包,然后循环它,并每隔6秒再次检查数据库,因为我知道每隔5秒就会在数据库中更新一个新值。

import csv
import pyodbc
import time
server = '*****' 
database = '******' 
username = '******' 
password = '*****' 
cnxn = pyodbc.connect('DRIVER={SQL SERVER};SERVER='+server+';DATABASE='+database+';UID='+username+';PWD='+ password)
cursor = cnxn.cursor()
cursor.execute("select * from marketc")
while True:
row = cursor.fetchone()
while row is not None:
row = cursor.fetchone()
print (row)
time.sleep(6)

相关内容

  • 没有找到相关文章

最新更新