想 while 循环检查数据库字段的改变，发现不重新初始化数据库连接，不能查询到最新的数据库

...
做了一些事情，这些事情会导致数据库某个字段的值会改变
...

a=usermysql() # 自定义类的 __init__方法，pymysql.connect 和创建 cursor
while True:
	a.execute() 
    result = a.fetchone()
    if result == 'WORKING': # 执行语句，获取需要的字段的值，如果值变成了想要的，就退出循环，做接下来的任务
    	break

然而运行的时候，发现获取到的字段的值并不会变化，只有在 while 循环里初始化数据库的连接，才能获取到最新的数据库的值

请问这是为什么呢？

第 1 条附言 · 2017-08-17 12:55:53 +08:00

我创建的查询数据库的类是这样的

class MySQLQuery():
    def __init__(self, ip, username, password, database):
        '''
        初始化 MySQL 数据库
        '''
        self.__sql = pymysql.connect(host=ip, user=username, password=password, db=database)
        self.__cursor = self.__sql.cursor()

    def selectOneResult(self, sentence):
        '''
        返回的结果是一个 tuple
        如果不存在，返回结果是个 NoneType
        '''
        self.__cursor.execute(sentence)
        result = self.__cursor.fetchone()

        return result

初始化数据库连接是这样的

from lib.util.MySQLQuery import MySQLQuery
controllerDB = MySQLQuery(ip=MySQLIP, username=MySQLUserName, password=MySQLPassWord,
                          database='cloudplayer_controller_hometest')

使用这个的是另一个文件，使用的部分是这样的

from lib.util.GlobalVariable import controllerDB
def a():  
    # 做了一些事情...

    while True:
        sqlSentence = 'select instance_id from service where id = {selectid}'.format(selectid=selectID)
        instanceID = controllerDB.selectOneResult(sqlSentence)[0]

        newSqlSentence = 'select status from instance_status where instance_id = {instanceid}'.format(instanceid=instanceID)
        status = controllerDB.selectOneResult(newSqlSentence)[0]

        if status == 'WORKING':
            break
        time.sleep(3)

数据库

while

result

循环

6 条回复 • 2017-08-17 13:24:16 +08:00