[SQL] Index des données insérées

Version imprimable

Bonjour,

je suis en train de créer un petit script Python qui devra insérer des données dans une base de données MySQL.
Je gère la connexion à la base avec le fichier clsSQL.py donné ci-dessous :

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
37
###
# Methodes de connexion a la base MySQL
##
 
import MySQLdb
 
class clsSQL:
    def __init__(self, db, user, passwd, host, port=3306):
        try:
            self.connexion = MySQLdb.connect(db=db, user=user, passwd=passwd, host=host, port=port)
        except Exception, err:
            print 'Erreur de connexion SQL' % err
            self.echec = 1
        else:
            # Creation du curseur
            self.cursor = self.connexion.cursor()
            self.echec = 0
 
    def executequery (self,qry):
        try:
            self.cursor.execute(qry)
        except Exception, err:
            print 'Erreur execution SQL' % err
            return 0
        else:
            return 1
 
    def commit(self):
        if self.connexion:
            self.connexion.commit()
 
    def close(self):
        if self.connexion:
            self.connexion.close()
 
    def display_all(self):
         return self.cursor.fetchall()

Ma requête est exécutée ainsi (par exemple) :

Code:

1
2
3
4
5
bdd = clsSQL(db,user,passwd,host)
 
query = "INSERT INTO `mabase`.`matable` (`index` ,`champ1` ,`champ2` ,`champ3`) VALUES (NULL , '10' , '20', NULL);"
bdd.executequery(query)
bdd.display_all()

J'ai ensuite besoin de récupérer le champ index (qui est un entier auto-incrémenté) pour réaliser un traitement ultérieur.
Y a-t-il un moyen pour le faire ? Cela se ferait au niveau de Python ou par requête SQL ? (n'étant expert ni dans l'un ni dans l'autre...)

Merci pour vos réponses et bon week-end !

Alban

21/04/2008, 20h59
bestdomdom

Je pense qu'un LAST_INSERT_ID() pourrait t'aider. Il faut regarder dans les forums et la doc mysql. tu y trouveras peut-être la réponse.
Sous sqlalchemy, je sais que c'est faisable aussi.
Si ça peut t'aider...
Dominique
21/04/2008, 21h44
tasnim86

Salut
tu peux utiliser la requête sql SELECT: :mouarf:

Code:

SELECT max(index) FROM mabase.matable

Mais pour la sélection je vois que tu ne peux pas utiliser la fonction que tu as défini dans ta classe pour exécuter la requête car ta fonction retourne 1 s'il n'y a pas d'exception ==> donc tu ne peux pas récupérer le contenu du curseur sauf si tu définis une autre fonction qui peut le retourner :king:

Remarque: n'oublie pas que l'index sera dans : nom_curseur[0][0]

Bonne chance

Aussi j'ai oublié de mentionner que déclarer le curseur comme étant attribut de la classe peut causer des problèmes au niveau du curseur si tu utilises plus qu'une fois la méthode:

Code:

bdd.executequery(query)

donc je propose de déclarer le curseur comme étant une variable locale de la méthode executequery
Code:

1 2 3 4 5 6 7 8 9 10 def executequery (self,qry): cursor= self.connexion.cursor() try: cursor.execute(qry) except Exception, err: print 'Erreur execution SQL' % err return 0 else: return 1

22/04/2008, 00h27
alband85
Ok, merci pour toutes ces réponses !

Donc finalement, pas de méthode miracle : c'est bien une requête à part.

Mais dans ce cas, n'y a-t-il pas de problème si on a deux accès simultanés à la base ?
Exemple :
1. A insère des données -> index = 0
2. B insère des données -> index = 1
3. A récupère le dernier index -> index récupéré = 1
Du coup, A va travailler sur de mauvaises données.

Avant de vous faire chercher pour moi, je vais quand même voir s'il y a la possibilité d'utiliser des mutex au niveau de la base... (je ne sais même pas si ça existe).
22/04/2008, 08h13
bestdomdom

Voilà quelques liens:

http://dev.mysql.com/doc/refman/5.0/...insert-id.html

Apparemment, le dernier ID généré est conservé par le serveur pour chaque connexion.
Un autre client ne la modifiera donc pas, même s'il génère une autre valeur AUTO_INCREMENT.

Dominique
22/04/2008, 13h41
alband85

Parfait ! Merci :)

Avec SqlAlchemy, voilà ce que ça donne.

1) Création de la base

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
from sqlalchemy import *
 
db = create_engine('sqlite:///C:\\testDb.db')
db.echo = False
metadata = MetaData(db)
 
##### TABLE AND DATA CREATION
persons = Table('persons', metadata,
    Column('person_id', Integer, primary_key=True),
    Column('name', String(40)),
    Column('age', Integer)
)
persons.create()
 
i = persons.insert()
i.execute({'name': 'John', 'age': 42},
          {'name': 'Susan', 'age': 57},
          {'name': 'Carl', 'age': 33})
 
s = persons.select()
rs = s.execute()
 
for row in rs:
    print 'The userId of ',row.name,'is ',row.person_id, '. His age is ',row.age

2) Insertion d'une nouvelle personne et récupération de l'id inséré:

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
from sqlalchemy import *
from sqlalchemy.orm import mapper
from sqlalchemy.orm import sessionmaker
 
 
db = create_engine('sqlite:///C:\\testDb.db')
 
db.echo = False
 
metadata = MetaData(db)
persons = Table('persons', metadata, autoload=True)
 
class Person(object):
    def __init__(self, name = None, person_id = None):
        self.person_id = person_id
        self.name = name
 
personmapper = mapper(Person, persons)
 
Session = sessionmaker(bind=db, autoflush=True)
mysession = Session()
 
new_person = Person()
new_person.name = 'Michael'
 
mysession.save(new_person)
mysession.flush()
mysession.commit()
 
user = Person(person_id = new_person.person_id)
print 'user = ',user
print 'user.person_id = ',user.person_id
print 'user.name = ',user.name

Le site de sqlalchemy: http://www.sqlalchemy.org/
Un super tuto: http://www.rmunn.com/sqlalchemy-tutorial/tutorial.html
Attention: remplacer BoundMetaData(db) par MetaData(db) et d'autres petites choses car ce tuto n'est pas à jour.

Dominique