X. Utilisation du SGBD MySQL▲
X-A. Installation du module MySQLdb▲
Nous allons écrire des scripts utilisant une base de données MySQL :
Les fonctions Python de gestion d'une base de données MySQL sont encapsulées dans un module MySQLdb qui n'est pas intégré à la distribution initiale de Python. Il faut alors procéder au téléchargement et à l'installation du module. Voici une façon de procéder :
- dans le menu des programmes, prendre en [1] le gestionnaire de packages Python. La fenêtre de commandes [2] apparaît alors.
On recherche le mot-clé mysql dans les packages :
Sélectionnez
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.
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.
C:\Documents and Settings\st>pypm search mysql
Get: [pypm-be.activestate.com] :repository-index:
Get: [pypm-free.activestate.com] :repository-index:
autosync: synced 2 repositories
chartio Setup wizard and connection client for connecting
chartio-setup Setup wizard and connection client for connecting
cns.recipe.zmysqlda Recipe for installing ZMySQLDA
collective.recipe.zmysqlda Recipe for installing ZMySQLDA
django-mysql-manager DESCRIPTION_DESCRIPTION_DESCRIPTION
jaraco.mysql MySQLDB-compatible MySQL wrapper by Jason R. Coomb
lovely.testlayers mysql, postgres nginx, memcached cassandra test la
mtstat-mysql MySQL Plugins for mtstat
mysql-autodoc Generate HTML documentation from a mysql database
mysql-python Python interface to MySQL
mysqldbda MySQL Database adapter
products.zmysqlda MySQL Zope2 adapter.
pymysql Pure Python MySQL Driver
pymysql-sa PyMySQL dialect for SQLAlchemy.
pymysql3 Pure Python MySQL Driver
sa-mysql-dt Alternative implementation of DateTime column for
schemaobject Iterate over a MySQL database schema as a Python o
schemasync A MySQL Schema Synchronization Utility
simplestore A datastore layer built on top of MySQL in Python.
sqlbean A auto maping ORM for MYSQL and can bind with memc
sqlwitch sqlwitch offers idiomatic SQL generation on top of
tiddlywebplugins.mysql MySQL-based store for tiddlyweb
tiddlywebplugins.mysql2 MySQL-based store for tiddlyweb
zest.recipe.mysql A Buildout recipe to setup a MySQL database.
Ont été listés tous les modules dont le nom ou la description ont le mot-clé mysql. Celui qui nous intéresse est [mysql-python], ligne 14. Nous l'installons :
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
8.
2.
3.
4.
5.
6.
7.
8.
C:\Documents and Settings\st>pypm install mysql-python
The following packages will be installed into "%APPDATA%\Python" (2.7):
mysql-python-1.2.3
Hit: [pypm-free.activestate.com] mysql-python 1.2.3
Installing mysql-python-1.2.3
C:\Documents and Settings\st>echo %APPDATA%
C:\Documents and Settings\st\Application Data
- ligne 5 : le package mysql-python-1.2.3 a été installé dans le dossier "%APPDATA%\Python" où APPDATA est le dossier désigné ligne 8.
Cette opération peut échouer si :
- l'interpréteur Python utilisé est une version 64 bits ;
- le chemin %APPDATA% contient des caractères accentués.
X-B. Installation de MySQL▲
Il existe diverses façons d'installer le SGBD MySQL. Ici nous avons utilisé WampServer, un package réunissant plusieurs logiciels :
- un serveur Web Apache. Nous l'utiliserons pour l'écriture de scripts Web en Python ;
- le SGBD MySQL ;
- le langage de script PHP ;
- un outil d'administration du SGBD MySQL écrit en PHP : phpMyAdmin.
WampServer peut être téléchargé (juin 2011) à l'adresse suivante :
http://www.wampserver.com/download.php
- en [1], on télécharge la version de WampServer qui va bien ;
- en [2], une fois installé, on le lance. Cela va lancer le serveur Web Apache et le SGBD MySQL ;
- en [3], une fois lancé, WampServer peut être administré à partir d'une icône [3] placée en bas à droite de la barre des tâches ;
- en [4], on lance l'outil d'administration de MySQL.
On crée une base de données [dbpersonnes] :
On crée un utilisateur [admpersonnes] avec le mot de passe [nobody] :
- en [1], le nom de l'utilisateur ;
- en [2], la machine du SGBD sur laquelle on lui donne des droits ;
- en [3], son mot de passe [nobody] ;
- en [4], idem ;
- en [5], on ne donne aucun droit à cet utilisateur ;
- en [6], on le crée.
- en [7], on revient sur la page d'accueil de phpMyAdmin ;
- en [8], on utilise le lien [Privileges] de cette page pour aller modifier ceux de l'utilisateur [admpersonnes] [9].
- en [10], on indique qu'on veut donner à l'utilisateur [admpersonnes] des droits sur la base de données [dbpersonnes] ;
- en [11], on valide le choix.
- avec le lien [12] [Tout cocher], on accorde à l'utilisateur [admpersonnes] tous les droits sur la base de données [dbpersonnes] [13] ;
- on valide en [14].
Désormais nous avons :
- une base de données MySQL [dbpersonnes] ;
- un utilisateur [admpersonnes / nobody] qui a tous les droits sur cette base de données.
Nous allons écrire des scripts Python pour exploiter la base de données.
X-C. Connexion à une base MySQL - 1▲
Programme (mysqldb_01)
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
2.
3.
4.
5.
6.
7.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# connexion à une base MySql
....
Notes :
- lignes 2-4 : les scripts contenant des opérations avec le SGBD MySQL doivent importer le module MySQLdb. On se souvient que nous avons installé ce module dans le dossier [%APPDATA%\Python]. Le dossier [%APPDATA%\Python] est automatiquement exploré lorsqu'un code Python réclame un module. En fait ce sont tous les dossiers déclarés dans sys.path qui sont explorés. Voici un exemple qui affiche ces dossiers :
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
2.
3.
4.
5.
6.
7.
# -*- coding=utf-8 -*-
import sys
# affichage des dossiers de sys.path
for dossier in sys.path:
print dossier
L'affichage écran est le suivant :
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
D:\data\istia-1112\python\tutoriel
C:\Windows\system32\python27.zip
D:\Programs\ActivePython\Python2.7.2\DLLs
D:\Programs\ActivePython\Python2.7.2\lib
D:\Programs\ActivePython\Python2.7.2\lib\plat-win
D:\Programs\ActivePython\Python2.7.2\lib\lib-tk
D:\Programs\ActivePython\Python2.7.2
C:\Users\Serge TahÚ\AppData\Roaming\Python\Python27\site-packages
D:\Programs\ActivePython\Python2.7.2\lib\site-packages
D:\Programs\ActivePython\Python2.7.2\lib\site-packages\win32
D:\Programs\ActivePython\Python2.7.2\lib\site-packages\win32\lib
D:\Programs\ActivePython\Python2.7.2\lib\site-packages\Pythonwin
D:\Programs\ActivePython\Python2.7.2\lib\site-packages\setuptools-0.6c11-py2.7.egg-info
Ligne 8, le dossier [site-packages] où MySQLdb avait été installé initialement. Nous déplaçons le dossier [site-packages] qui est le dossier où l'utilitaire pypm installe les modules Python. Pour ajouter un nouveau dossier que Python explorera à la recherche des modules, on l'ajoute à la liste sys.path :
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
2.
3.
4.
5.
6.
7.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# connexion à une base MySql
....
Ligne 3, on ajoute le dossier où a été déplacé le module MySQLdb.
Le code complet de l'exemple est le suivant :
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# connexion à une base MySql
# l'identité de l'utilisateur est (admpersonnes,nobody)
user="admpersonnes"
pwd="nobody"
host="localhost"
connexion=None
try:
print "connexion..."
# connexion
connexion=MySQLdb.connect(host=host,user=user,passwd=pwd)
# suivi
print "Connexion a MySQL reussie sous l'identite host={0},user={1},passwd={2}".format(host,user,pwd)
except MySQLdb.OperationalError,message:
print "Erreur : {0}".format(message)
finally:
try:
connexion.close()
except:
pass
- lignes 8-11 : le script va connecter (ligne 15) l'utilisateur [admpersonnes / nobody] au SGBD MySQL de la machine [localhost]. On ne le connecte pas à une base de données précise ;
- lignes 12-24 : la connexion peut échouer. Aussi la fait-on dans un try / except / finally ;
- ligne 15 : la méthode connect du module MySQLdb admet différents paramètres nommés :
- user : utilisateur propriétaire de la connexion [admpersonnes],
- pwd : mot de passe de l'utilisateur [nobody],
- host : machine du SGBD MySQL [localhost],
- db : la base de données à laquelle on se connecte. Optionnel ;
- ligne 18 : si une exception est lancée, elle est de type [ MySQLdb.OperationalError] et le message d'erreur associé sera trouvé dans la variable [message] ;
- lignes 20-23 : dans la clause [finally], on ferme la connexion. En cas d'exception, on l'intercepte (ligne 23) mais on ne fait rien avec (ligne 24).
Résultats
Sélectionnez
1.
2.
2.
connexion...
Connexion a MySQL reussie sous l'identite host=localhost,user=admpersonnes,passwd=nobody
X-D. Connexion à une base MySQL - 2▲
Programme (mysqldb_02)
Sélectionnez
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.
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.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# ---------------------------------------------------------------------------------
def testeConnexion(hote,login,pwd):
# connecte puis déconnecte (login,pwd) du SGBD mysql du serveur hote
# lance l'exception MySQLdb.operationalError
# connexion
connexion=MySQLdb.connect(host=hote,user=login,passwd=pwd)
print "Connexion a MySQL reussie sous l'identite (%s,%s,%s)" % (hote,login,passwd)
# on ferme la connexion
connexion.close()
print "Fermeture connexion MySql reussie\n"
# ---------------------------------------------- main
# connexion à la base MySql
# l'identité de l'utilisateur
user="admpersonnes"
passwd="nobody"
host="localhost"
# test connexion
try:
testeConnexion(host,user,passwd)
except MySQLdb.OperationalError,message:
print message
# avec un utilisateur inexistant
try:
testeConnexion(host,"xx","xx")
except MySQLdb.OperationalError,message:
print message
Notes :
- lignes 7-15 : une fonction qui tente de connecter puis de déconnecter un utilisateur à un SGBD MySQL. Affiche le résultat ;
- lignes 18-34 : programme principal - appelle deux fois la méthode testeConnexion et affiche les éventuelles exceptions.
Résultats
Sélectionnez
1.
2.
3.
4.
2.
3.
4.
Connexion a MySQL reussie sous l'identite (localhost,admpersonnes,nobody)
Fermeture connexion MySql reussie
Echec de la connexion a MySQL : (1045, "Access denied for user 'xx'@'localhost'(using password: YES)")
X-E. Création d'une table MySQL▲
Maintenant qu'on sait créer une connexion avec un SGBD MySQL, on commence à émettre des ordres SQL sur cette connexion. Pour cela, nous allons nous connecter à la base créée [dbpersonnes] et utiliser la connexion pour créer une table dans la base.
Programme (mysqldb_03)
Sélectionnez
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.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
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.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# ---------------------------------------------------------------------------------
def executeSQL(connexion,update):
# exécute une requête update de mise à jour sur la connexion
# on demande un curseur
curseur=connexion.cursor()
# exécute la requête SQL sur la connexion
try:
curseur.execute(update)
connexion.commit()
except Exception, erreur:
connexion.rollback()
raise
finally:
curseur.close()
# ---------------------------------------------- main
# connexion à la base MySql
# l'identité de l'utilisateur
ID="admpersonnes"
PWD="nobody"
# la machine hôte du SGBD
HOTE="localhost"
# identité de la base
BASE="dbpersonnes"
# connexion
try:
connexion=MySQLdb.connect(host=HOTE,user=ID,passwd=PWD,db=BASE)
except MySQLdb.OperationalError,message:
print message
sys.exit()
# suppression de la table personnes si elle existe
# si elle n'existe pas, une erreur se produira
# on l'ignore
requete="drop table personnes"
try:
executeSQL(connexion,requete)
except:
pass
# création de la table personnes
requete="create table personnes (prenom varchar(30) NOT NULL, nom varchar(30) NOT NULL, age integer NOT NULL, primary key(nom,prenom))"
try:
executeSQL(connexion,requete)
except MySQLdb.OperationalError,message:
print message
sys.exit()
# on se deconnecte et on quitte
try:
connexion.close()
except MySQLdb.OperationalError,message:
print message
sys.exit()
Notes :
- ligne 7 : la fonction executeSQL exécute une requête SQL sur une connexion ouverte ;
- ligne 10 : les opérations SQL sur la connexion se font au travers d'un objet particulier appelé curseur ;
- ligne 10 : obtention d'un curseur ;
- ligne 13 : exécution de la requête SQL ;
- ligne 14 : la transaction courante est validée ;
- ligne 15 : en cas d'exception, le message d'erreur est récupéré dans la variable erreur ;
- ligne 16 : la transaction courante est invalidée ;
- ligne 17 : l'exception est relancée ;
- ligne 19 : qu'il y ait erreur ou non, le curseur est fermé. Cela libère les ressources qui lui sont associées.
Résultats
Sélectionnez
1.
create table personnes (prenom varchar(30) NOT NULL, nom varchar(30) NOT NULL, age integer NOT NULL, primary key(nom,prenom)) : requete reussie
Vérification avec phpMyAdmin :
- la base de données [dbpersonnes] [1] a une table [personnes] [2] qui a la structure [3] et la clé primaire [4].
X-F. Remplissage de la table [personnes]▲
Après avoir créé précédemment la table [personnes], maintenant nous la remplissons.
Programme (mysqldb_04)
Sélectionnez
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.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
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.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# autres modules
import re
# ---------------------------------------------------------------------------------
def executerCommandes(HOTE,ID,PWD,BASE,SQL,suivi=False,arret=True):
# utilise la connexion (HOTE,ID,PWD,BASE)
# exécute sur cette connexion les commandes SQL contenues dans le fichier texte SQL
# ce fichier est un fichier de commandes SQL à exécuter à raison d'une par ligne
# si suivi=True alors chaque exécution d'un ordre SQL fait l'objet d'un affichage indiquant sa réussite ou son échec
# si arret=True, la fonction s'arrête sur la 1re erreur rencontrée sinon elle exécute toutes les commandes SQL
# la fonction rend une liste (nb d'erreurs, erreur1, erreur2...)
# on vérifie la présence du fichier SQL
data=None
try:
data=open(SQL,"r")
except:
return [1,"Le fichier %s n'existe pas" % (SQL)]
# connexion
try:
connexion=MySQLdb.connect(host=HOTE,user=ID,passwd=PWD,db=BASE)
except MySQLdb.OperationalError,erreur:
return [1,"Erreur lors de la connexion a MySql sous l'identite (%s,%s,%s,%s) : %s" % (HOTE, ID, PWD, BASE, erreur)]
# on demande un curseur
curseur=connexion.cursor()
# exécution des requêtes SQL contenues dans le fichier SQL
# on les met dans un tableau
requetes=data.readlines()
# on les exécute une à une - au départ pas d'erreur
erreurs=[0]
for i in range(len(requetes)):
# on mémorise la requête courante
requete=requetes[i]
# a-t-on une requête vide ? Si oui, on passe à la requête suivante
if re.match(r"^\s*$",requete):
continue
# exécution de la requête i
erreur=""
try:
curseur.execute(requete)
except Exception, erreur:
pass
#y a-t-il eu une erreur ?
if erreur:
# une erreur de plus
erreurs[0]+=1
# msg d'erreur
msg="%s : Erreur (%s)" % (requete,erreur)
erreurs.append(msg)
# suivi écran ou non ?
if suivi:
print msg
# on s'arrête ?
if arret:
return erreurs
else:
if suivi:
print "%s : Execution reussie" % (requete)
# fermeture connexion et libération des ressources
curseur.close()
connexion.commit()
# on se deconnecte
try:
connexion.close()
except MySQLdb.OperationalError,erreur:
# une erreur de plus
erreurs[0]+=1
# msg d'erreur
msg="%s : Erreur (%s)" % (requete,erreur)
erreurs.append(msg)
# retour
return erreurs
# ---------------------------------------------- main
# connexion à la base MySql
# l'identité de l'utilisateur
ID="admpersonnes"
PWD="nobody"
# la machine hôte du SGBD
HOTE="localhost"
# identité de la base
BASE="dbpersonnes"
# identité du fichier texte des commandes SQL à exécuter
TEXTE="sql.txt";
# création et remplissage de la table
erreurs=executerCommandes(HOTE,ID,PWD,BASE,TEXTE,True,False)
#affichage nombre d'erreurs
print "il y a eu %s erreur(s)" % (erreurs[0])
for i in range(1,len(erreurs)):
print erreurs[i]
Le fichier sql.txt
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
8.
9.
2.
3.
4.
5.
6.
7.
8.
9.
drop table personnes
create table personnes (prenom varchar(30) not null, nom varchar(30) not null, age integer not null, primary key (nom,prenom))
insert into personnes values('Paul','Langevin',48)
insert into personnes values ('Sylvie','Lefur',70)
xx
insert into personnes values ('Pierre','Nicazou',35)
insert into personnes values ('Geraldine','Colou',26)
insert into personnes values ('Paulette','Girond',56)
Une erreur a été volontairement insérée en ligne 5.
Les résultats écran
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
drop table personnes : Execution reussie
create table personnes (prenom varchar(30) not null, nom varchar(30) not null, age integer not null, primary key (nom,prenom)) : Execution reussie
insert into personnes values('Paul','Langevin',48) : Execution reussie
insert into personnes values ('Sylvie','Lefur',70) : Execution reussie
xx : Erreur ((1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'xx' at
line 1"))
insert into personnes values ('Pierre','Nicazou',35) : Execution reussie
insert into personnes values ('Geraldine','Colou',26) : Execution reussie
insert into personnes values ('Paulette','Girond',56) : Execution reussie
il y a eu 1 erreur(s)
xx : Erreur ((1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'xx' at line 1"))
Vérification avec phpMyAdmin :
- en [1], le lien [Afficher] permet d'avoir le contenu de la table [personnes] [2].
X-G. Exécution de requêtes SQL quelconques▲
Le script suivant permet d'exécuter un fichier de commandes SQL et d'afficher le résultat de chacune d'elles :
- le résultat du SELECT si l'ordre est un SELECT ;
- le nombre de lignes modifiées si l'ordre est INSERT, UPDATE, DELETE.
Programme (mysqldb_05)
Sélectionnez
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.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
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.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
# import du module MySQLdb
import sys
sys.path.append("D:\Programs\ActivePython\site-packages")
import MySQLdb
# autres modules
import re
def cutNewLineChar(ligne):
# on supprime la marque de fin de ligne de [ligne] si elle existe
l=len(ligne)
while(ligne[l-1]=="\n" or ligne[l-1]=="\r"):
l-=1
return(ligne[0:l])
# ---------------------------------------------------------------------------------
def afficherInfos(curseur):
# affiche le résultat d'une requête SQL
# s'agissait-il d'un select ?
if curseur.description:
# il y a une description - donc c'est un select
# description[i] est la description de la colonne n° i du select
# description[i][0] est le nom de la colonne n° i du select
# on affiche le nom des champs
titre=""
for i in range(len(curseur.description)):
titre+=curseur.description[i][0]+","
# on affiche la liste des champs sans la virgule de fin
print titre[0:len(titre)-1]
# ligne séparatrice
print "-"*(len(titre)-1)
# ligne courante du select
ligne=curseur.fetchone()
while ligne:
print ligne
# ligne suivante du select
ligne=curseur.fetchone()
else:
# il n'y a pas de champ - ce n'était pas un select
print "%s lignes(s) a (ont) ete modifiee(s)" % (curseur.rowcount)
# ---------------------------------------------------------------------------------
def executerCommandes(HOTE,ID,PWD,BASE,SQL,suivi=False,arret=True):
# utilise la connexion (HOTE,ID,PWD,BASE)
# exécute sur cette connexion les commandes SQL contenues dans le fichier texte SQL
# ce fichier est un fichier de commandes SQL à exécuter à raison d'une par ligne
# si suivi=1 alors chaque exécution d'un ordre SQL fait l'objet d'un affichage indiquant sa réussite ou son échec
# si arret=1, la fonction s'arrête sur la 1re erreur rencontrée sinon elle exécute toutes les commandes SQL
# la fonction rend un tableau (nb d'erreurs, erreur1, erreur2...)
# on vérifie la présence du fichier SQL
data=None
try:
data=open(SQL,"r")
except:
return [1,"Le fichier %s n'existe pas" % (SQL)]
# connexion
try:
connexion=MySQLdb.connect(host=HOTE,user=ID,passwd=PWD,db=BASE)
except MySQLdb.OperationalError,erreur:
return [1,"Erreur lors de la connexion a MySql sous l'identite (%s,%s,%s,%s) : %s" % (HOTE, ID, PWD, BASE, erreur)]
# on demande un curseur
curseur=connexion.cursor()
# exécution des requêtes SQL contenues dans le fichier SQL
# on les met dans un tableau
requetes=data.readlines()
# on les exécute une à une - au départ pas d'erreur
erreurs=[0]
for i in range(len(requetes)):
# on mémorise la requête courante
requete=requetes[i]
# a-t-on une requête vide ? Si oui, on passe à la requête suivante
if re.match(r"^\s*$",requete):
continue
# exécution de la requête i
erreur=""
try:
curseur.execute(requete)
except Exception, erreur:
pass
#y a-t-il eu une erreur ?
if erreur:
# une erreur de plus
erreurs[0]+=1
# msg d'erreur
msg="%s : Erreur (%s)" % (requete,erreur)
erreurs.append(msg)
# suivi écran ou non ?
if suivi:
print msg
# on s'arrête ?
if arret:
return erreurs
else:
if suivi:
print "%s : Execution reussie" % (requete)
# infos sur le résultat de la requête exécutée
afficherInfos(curseur)
# fermeture connexion et libération des ressources
curseur.close()
connexion.commit()
# on se deconnecte
try:
connexion.close()
except MySQLdb.OperationalError,erreur:
# une erreur de plus
erreurs[0]+=1
# msg d'erreur
msg="%s : Erreur (%s)" % (requete,erreur)
erreurs.append(msg)
# retour
return erreurs
# ---------------------------------------------- main
# connexion à la base MySql
# l'identité de l'utilisateur
ID="admpersonnes"
PWD="nobody"
# la machine hôte du SGBD
HOTE="localhost"
# identité de la base
BASE="dbpersonnes"
# identité du fichier texte des commandes SQL à exécuter
TEXTE="sql2.txt"
# création et remplissage de la table
erreurs=executerCommandes(HOTE,ID,PWD,BASE,TEXTE,True,False)
#affichage nombre d'erreurs
print "il y a eu %s erreur(s)" % (erreurs[0])
for i in range(1,len(erreurs)):
print erreurs[i]
Notes :
- la nouveauté est ligne 100 du script : après exécution d'un ordre SQL, on demande des informations sur le curseur utilisé par cette requête. Ces informations sont données par la fonction afficheInfos des lignes 16-40 ;
- lignes 19 et 39 : si la requête SQL exécutée était un SELECT, l'attribut [curseur.description] est un tableau dont l'élément n° i décrit le champ n° i du résultat du SELECT. Sinon, l'attribut [curseur.rowcount] (ligne 39) est le nombre de lignes modifiées par la requête INSERT, UPDATE ou DELETE ;
- lignes 32 et 36 : la méthode [curseur.fetchone] permet de récupérer la ligne courante du SELECT. Il existe une méthode [curseur.fetchall] qui permet de les récupérer d'un seul coup.
Le fichier des requêtes exécutées
Sélectionnez
1.
2.
3.
4.
5.
6.
7.
8.
9.
2.
3.
4.
5.
6.
7.
8.
9.
select * from personnes
select nom,prenom from personnes order by nom asc, prenom desc
select * from personnes where age between 20 and 40 order by age desc, nom asc, prenom asc
insert into personnes values('Josette','Bruneau',46)
update personnes set age=47 where nom='Bruneau'
select * from personnes where nom='Bruneau'
delete from personnes where nom='Bruneau'
select * from personnes where nom='Bruneau'
xselect * from personnes where nom='Bruneau'
Les résultats écran
Sélectionnez
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.
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.
select * from personnes : Execution reussie
prenom,nom,age
---------------
('Geraldine', 'Colou', 26L)
('Paulette', 'Girond', 56L)
('Paul', 'Langevin', 48L)
('Sylvie', 'Lefur', 70L)
('Pierre', 'Nicazou', 35L)
select nom,prenom from personnes order by nom asc, prenom desc : Execution reussie
nom,prenom
-----------
('Colou', 'Geraldine')
('Girond', 'Paulette')
('Langevin', 'Paul')
('Lefur', 'Sylvie')
('Nicazou', 'Pierre')
select * from personnes where age between 20 and 40 order by age desc, nom asc,prenom asc : Execution reussie
prenom,nom,age
---------------
('Pierre', 'Nicazou', 35L)
('Geraldine', 'Colou', 26L)
insert into personnes values('Josette','Bruneau',46) : Execution reussie
1 lignes(s) a (ont) ete modifiee(s)
update personnes set age=47 where nom='Bruneau' : Execution reussie
1 lignes(s) a (ont) ete modifiee(s)
select * from personnes where nom='Bruneau' : Execution reussie
prenom,nom,age
---------------
('Josette', 'Bruneau', 47L)
delete from personnes where nom='Bruneau' : Execution reussie
1 lignes(s) a (ont) ete modifiee(s)
select * from personnes where nom='Bruneau' : Execution reussie
prenom,nom,age
---------------
xselect * from personnes where nom='Bruneau' : Erreur ((1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'xselect * from personnes where nom='Bruneau'' at line 1"))
Vérification avec PhpMyadmin :
