Problème d'insertion en base de données

Version imprimable

Bonjour à tous,

Je commence seulement à apprendre le langage et je rencontre un problème. J'ai essayé de chercher sur le web mais rien ne correspond à ce que je recherche.

Je fais une connexion sur une base de données, une requête de sélection et pour chaque ligne que me ramène ma requête de je veux faire une insertion dans une autre table, c'est là que se produit l'erreur.
Et maintenant un peu de code:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
import requests
from bs4 import BeautifulSoup
import datetime
import mysql.connector
 
# Déclartion / Initialisation des variables
# On récupère la date du jour, format YYY-MM-DD
myDatetime = datetime.datetime.now()
myDateString = myDatetime.strftime('%Y-%m-%d')
vCodeAction = ""
nomAction = ""
codeAction = ""
cours = 0
 
# Connexion à la base de données
connection = mysql.connector.connect(host='localhost',
                                     user='budget',
                                     password='Hnkjb87ay&',
                                     db='budget')
try:
    cursor = connection.cursor()
    querySelect="select col1, col2 from matable limit 0, 5"
    cursor.execute(querySelect)
    while True:
        row = cursor.fetchone()
        if row is None:
            break
        variable1 = row[1]
        varaible2 = row[0]
        queryInsert = "insert into maTableDeDestination (col1, col2) values (%s, %s)"
        params = (variable1, variable2)
        cursor.execute(queryInsert, params)
        connection.commit()
finally:
    # Closez la connexion (Close connection).
    connection.close()

C'est vraiment la ligne cursor.execute(queryInsert, params) qui pose problème dans la boucle while, si je la sors de la boucle elle exécute bien l'ordre d'insertion mais n'en fait qu'une seule au lieu des cinq lignes prévues.

L'erreur affichée est celle-ci

Code:

1
2
3
4
5
6
7
8
Traceback (most recent call last):
  File "D:\python\bourse\coursAction.py", line 49, in <module>
    cursor.execute(queryInsert, params)
  File "D:\python\bourse\env\lib\site-packages\mysql\connector\cursor_cext.py", line 243, in execute
    self._cnx.handle_unread_result()
  File "D:\python\bourse\env\lib\site-packages\mysql\connector\connection_cext.py", line 794, in handle_unread_result
    raise errors.InternalError("Unread result found")
mysql.connector.errors.InternalError: Unread result found

Je ne sais pas d'où peut venir le problème. Merci à tous.

05/03/2022, 21h25
Arioch

Citation:

Envoyé par franck.massart

Je ne sais pas d'où peut venir le problème. Merci à tous.

Moi non plus, vu ton code absolument pas indenté.

Enfin si, j'ai bien ma petite idée (si si, c'est vrai...) mais bon, là ton code est imbitable.

De rien.
05/03/2022, 22h05
Sve@r

Bonjour

Citation:

Envoyé par franck.massart

Et maintenant un peu de code:

:tagcode:

Citation:

Envoyé par franck.massart

C'est vraiment la ligne cursor.execute(queryInsert, params) qui pose problème dans la boucle while, si je la sors de la boucle elle exécute bien l'ordre d'insertion mais n'en fait qu'une seule au lieu des cinq lignes prévues.
Je ne sais pas d'où peut venir le problème.

Tu n'utilises qu'un seul curseur pour faire le select et le insert. A la seconde itération, quand tu demandes un fetchone() sur le curseur qui vient d'insérer...:?

@franck.massart
Vous trouverait moins couteux et plus de clarté, au lieu de boucle while, comme ça.

Code:

1
2
3
4
5
6
7
8
    querySelect="select col1, col2 from matable limit 0, 5"
    queryInsert = "insert into maTableDeDestination (col1, col2) values (%s, %s)"
    cursor.execute(querySelect)
    records=cursor.fetchall()
    for row in records:
        params = (row[0], row[1])
        cursor.execute(queryInsert, params)
        connection.commit()

Citation:

Envoyé par tsuji

@franck.massart
Vous trouverait moins couteux et plus de clarté, au lieu de boucle while, comme ça.

On devrait aussi pouvoir déléguer la boucle au pilote:
Code:

1 2 3 4 5 6 querySelect="select col1, col2 from matable limit 0, 5" queryInsert = "insert into maTableDeDestination (col1, col2) values (%s, %s)" cursor.execute(querySelect) if rows := cursor.fetchall(): cursor.executemany(queryInsert, rows) connection.commit()
Cela étant avec une base de donnée, on fait un schéma pour éviter de répliquer les données, histoire de ne pas avoir de soucis côté "cohérence" (si on met à jour une ligne de la table A, il va falloir ramer pour que sa copie dans la table B soit aussi à jour).

- W

Un grand merci

Citation:
Envoyé par tsuji
@franck.massart
Vous trouverait moins couteux et plus de clarté, au lieu de boucle while, comme ça.
Code:

1 2 3 4 5 6 7 8 querySelect="select col1, col2 from matable limit 0, 5" queryInsert = "insert into maTableDeDestination (col1, col2) values (%s, %s)" cursor.execute(querySelect) records=cursor.fetchall() for row in records: params = (row[0], row[1]) cursor.execute(queryInsert, params) connection.commit()
Un grand merci à tsuji. En fait j'avais également utilisé une boucle for mais pas de la même façon.
Code:

1 2 3 4 5 6 7 queryInsert = "insert into maTableDeDestination (col1, col2) values (%s, %s)" cursor.execute(querySelect) for row in cursor: params = (row[0], row[1]) cursor.execute(queryInsert, params) connection.commit()
Ce qui me faisait arriver au même résultat. J'ai pensé également que le fetchall pouvait poser un problème, notamment sur l'allocation mémoire, c'est la raison pour laquelle j'avais utilisé fetchone. Je pensais également que fetchone pouvait "libérer" le curseur le temps de faire une autre opération (insert) avec.

La nuit portant conseil j'avais envisagé de faire une list en vidant mon curseur dedans pour pouvoir ensuite le réutiliser, ce que fait votre records=cursor.fetchall().

J'avais bien compris qu'il s'agissait en fait d'une ressource utilisée et que cela générait un conflit, je l'avais compris en mettant une limite dans ma clause where ( limit 0, 1). J'avais également essayé de déclarer un second curseur pour le verbe INSERT mais sans résultat.

Encore merci à tous pour vos réponses et particulièrement à tsuji.

@franck.massart
Voulez-vous voir comment une boucle while s'est faite proprement ? pour se convaincre qu'elle soit plus couteuse et moins claire.

Code:

1
2
3
4
5
6
7
8
9
    cursor=connection.cursor(buffered=True)
    cursor2=connection.cursor()
    cursor.execute(querySelect)
    row=cursor.fetchone()
    while row is not None:
        params = (row[0], row[1])
        cursor2.execute(queryInsert, params)
        connection.commit()    
        row=cursor.fetchone()

Voilà !