MySQLdb avec de multiples transactions par connexion

Est-il acceptable d'utiliser un seul MySQLdb de connexion pour plusieurs transactions sans fermer la connexion entre eux? En d'autres termes, quelque chose comme ceci:

conn = MySQLdb.connect(host="1.2.3.4", port=1234, user="root", passwd="x", db="test")

for i in range(10):
    try:
        cur = conn.cursor()
        query = "DELETE FROM SomeTable WHERE ID = %d" % i
        cur.execute(query)
        cur.close()
        conn.commit()

    except Exception:
        conn.rollback()

conn.close()

Il semble fonctionner ok, mais je voulais juste vérifier.

Dommage que vous ne laissez pas votre erreur. Je me suis vraiment confus avant de lire les révisions parce que je ne vois pas ce qu'était le malentendu Martijn Pieters a parlé.

InformationsquelleAutor d512 | 2012-09-11

18

Je pense qu'il y a un malentendu à propos de ce qui constitue une transaction ici.

Votre exemple ouvre une connexion, puis exécute un transaction sur elle. Vous exécuter plusieurs instructions SQL dans la transaction, mais de le fermer complètement après avoir commis. Bien sûr, c'est plus que bien.

De l'exécution de plusieurs transactions (plutôt que de simplement les instructions SQL), ressemble à ceci:
```
conn = MySQLdb.connect(host="1.2.3.4", port=1234, user="root", passwd="x", db="test")

for j in range(10):
    try:
        for i in range(10):
            cur = conn.cursor()
            query = "DELETE FROM SomeTable WHERE ID = %d" % i
            cur.execute(query)
            cur.close()
        conn.commit()
    except Exception:
        conn.rollback()

conn.close()
```
Le code ci-dessus s'engage transactions 10, composés chacun de 10 delete.

Et oui, vous devriez être en mesure de ré-utiliser la connexion ouverte pour que, sans problèmes, aussi longtemps que vous ne partagez pas cette connexion entre les threads.

Par exemple, SQLAlchemy ré-utilise les connexions par des mises en commun, en distribuant des connexions ouvertes en tant que de besoin à la demande. De nouvelles transactions et de nouvelles instructions sont exécutées sur ces connexions tout au long de la durée de vie d'une application, sans avoir besoin d'être fermé jusqu'à l'arrêt de l'application.
- Oui, vous avez raison. J'ai foiré mon exemple, alors que l'eau de la publier. Je vais corriger ça.
- Quel serait le problème avec le partage de connexions entre les threads sous mon scénario?
- À partir de la MySQLdb de documentation: "Si vous laissez les deux fils de connexion en même temps, la bibliothèque cliente MySQL sera probablement upchuck et mourir. Vous avez été averti.".
- C'est génial. Je vois ce que vous dites maintenant sur la façon dont les threads et les connexions doivent interagir les uns avec les autres. Merci pour l'astuce.
InformationsquelleAutor Martijn Pieters
0

Il serait préférable de créer une chaîne de requête, puis l'exécuter MySQL déclaration. Par exemple:
```
query = "DELETE FROM table_name WHERE id IN ("
for i in range(10):
    query = query + "'" + str(i) + "', "
query = query[:-2] + ')'

cur = conn.cursor()
cur.execute(query)
```
- C'est plus efficace, mais il ya des raisons pourquoi je ne suis pas le faire de cette façon.
- Descendre, juste vérifier.
InformationsquelleAutor Scott Bartell

Vous devez vous connecter pour publier un commentaire.