Discussion :

[franck.massart]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[Arioch]

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.

[Sve@r]

Bonjour

Et maintenant un peu de code:

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...

[tsuji]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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()

[wiztricks]

@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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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

[franck.massart]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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à !