Здравствуйте уважаемые знатоки.
Немогу никак разобратся почему мой код не возвращает новые данные с базы данных,
вот код:
import pymysql
from pymysql.cursors import DictCursor
mysql_connections = None
def connection_to_mysql():
global mysql_connections
if mysql_connections == None or not mysql_connections.open:
try:
mysql_connections = pymysql.connect(host = db_host, user = db_username, password = db_password, db = db_dbname, charset = 'utf8mb4', cursorclass = DictCursor)
except pymysql.Error as err:
print('Mysql error: '+str(err.args[1]))
return False
return True
while True:
rows = []
if connection_to_mysql():
try:
with mysql_connections.cursor() as cursor:
sql = 'SELECT * FROM `test` WHERE `id` > 14 ORDER BY `id` ASC'
cursor.execute(sql)
rows = cursor.fetchall()
print(str(rows))
except pymysql.Error as err:
print('Mysql error: '+str(err.args[1]))
break
time.sleep(5)
Код каждые 5 сек запрашивает таблицу и вытаскивает все оттуда.
К приимеру в таблице 27 строк, запускаю код, он возвращает все 27 строк как положено, каждые 5 сек. одно и тоже по сути.
Потом я добавляю в таблицу еще одну или более строк. Но код по прежнему возвращает 27 строк как и раньше.
В чем дело кто знает?
