Récupération de données dynamiques à partir de MySQL à l'aide de requêtes Python

Lorsque vous interrogez périodiquement une base de données MySQL en évolution rapide à partir de Python, vous pouvez vous attendre à une requête basée sur une boucle approche pour récupérer systématiquement les dernières données. Cependant, vous pouvez rencontrer une situation dans laquelle les mêmes données sont renvoyées à plusieurs reprises.

Ce problème provient du niveau d'isolement par défaut de MySQL, REPEATABLE READ. Avec ce niveau, les lectures au sein d'une transaction utilisent un instantané des données telles qu'elles existaient au début de la transaction. Les requêtes suivantes au sein de la même transaction liront cet instantané plutôt que de le mettre à jour.

Pour résoudre ce problème, vous devez valider la connexion après chaque requête, en vous assurant que la transaction suivante récupérera les dernières données. Voici comment modifier votre code Python :

# Main loop
while True:

    # SQL query
    sql = "SELECT * FROM table"

    # Read the database, store as a dictionary
    mycursor = mydb.cursor(dictionary=True)
    mycursor.execute(sql)

    # Store data in rows
    myresult = mycursor.fetchall()

    # Transfer data into list
    for row in myresult:
        myList[int(row["rowID"])] = (row["a"], row["b"], row["c"])

        print(myList[int(row["rowID"])])

    # Commit !
    mydb.commit()
    print("---")
    sleep (0.1)

En ajoutant mydb.commit() après chaque requête, vous forcez MySQL à valider la transaction et à mettre à jour l'instantané. Cela permet aux requêtes ultérieures d'accéder aux données les plus récentes.