Maison > Article > développement back-end > Trois méthodes Python pour faire fonctionner la base de données MySQL
Trois méthodes Python pour faire fonctionner la base de données MySQL
- 零到壹度original
- 2018-04-04 17:52:301522parcourir
Cet article présente principalement trois méthodes Python pour faire fonctionner la base de données MySQL. L'éditeur pense que c'est plutôt bon, je vais donc le partager avec vous maintenant et le donner comme référence. Suivons l'éditeur et jetons un coup d'œil
1 L'utilisation de MySQLdb
(1) Qu'est-ce que MySQLdb ?
MySQLdb est une interface permettant à Python de se connecter à la base de données MySQL. Il implémente la spécification de l'API de la base de données Python. V2.0, construit sur API MySQL C.
(2) Installation du code sourceMySQLdb : https://pypi.python.org/pypi/MySQL-python
$ tar zxvf MySQL-python-*.tar.gz $ cd MySQL-python-* $ python setup.py build $ python setup.py install
(3) Utilisation de MySQLdb de :
#!/usr/bin/env python
# coding=utf-8
import MySQLdbdef connectdb():
print('连接到mysql服务器...')
# 打开数据库连接
# 用户名:hp, 密码:Hp12345.,用户名和密码需要改成你自己的mysql用户名和密码，并且要创建数据库TESTDB，并在TESTDB数据库中创建好表Student
db = MySQLdb.connect("localhost","hp","Hp12345.","TESTDB")
print('连接上了!')
return db
def createtable(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 如果存在表Sutdent先删除
cursor.execute("DROP TABLE IF EXISTS Student")
sql = """CREATE TABLE Student (
ID CHAR(10) NOT NULL,
Name CHAR(8),
Grade INT )"""
# 创建Sutdent表
cursor.execute(sql)
def insertdb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = """INSERT INTO Student
VALUES ('001', 'CZQ', 70),
('002', 'LHQ', 80),
('003', 'MQ', 90),
('004', 'WH', 80),
('005', 'HP', 70),
('006', 'YF', 66),
('007', 'TEST', 100)"""
#sql = "INSERT INTO Student(ID, Name, Grade) \
# VALUES ('%s', '%s', '%d')" % \
# ('001', 'HP', 60)
try: # 执行sql语句
cursor.execute(sql) # 提交到数据库执行
db.commit() except: # Rollback in case there is any error
print '插入数据失败!'
db.rollback()def querydb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
#sql = "SELECT * FROM Student \
# WHERE Grade > '%d'" % (80)
sql = "SELECT * FROM Student"
try:
# 执行SQL语句
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
for row in results:
ID = row[0]
Name = row[1]
Grade = row[2] # 打印结果
print "ID: %s, Name: %s, Grade: %d" % \
(ID, Name, Grade)
except: print "Error: unable to fecth data"def deletedb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 删除语句
sql = "DELETE FROM Student WHERE Grade = '%d'" % (100) try: # 执行SQL语句
cursor.execute(sql) # 提交修改
db.commit() except: print '删除数据失败!'
# 发生错误时回滚
db.rollback()def updatedb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 更新语句
sql = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003') try: # 执行SQL语句
cursor.execute(sql) # 提交到数据库执行
db.commit() except: print '更新数据失败!'
# 发生错误时回滚
db.rollback()def closedb(db):
db.close()def main():
db = connectdb() # 连接MySQL数据库
createtable(db) # 创建表
insertdb(db) # 插入数据
print '\n插入数据后:'
querydb(db)
deletedb(db) # 删除数据
print '\n删除数据后:'
querydb(db)
updatedb(db) # 更新数据
print '\n更新数据后:'
querydb(db)
closedb(db) # 关闭数据库if __name__ == '__main__':
main()Résultats d'exécution :
2. Utilisation de PyMySQL
(1) Qu'est-ce que PyMySQL ?
PyMySQL est une bibliothèque en Python utilisée pour se connecter au serveur MySQL Elle suit l'API de la base de données Python. spécification V2 .0, et inclut la bibliothèque client pur-Python MySQL.
(2) Installez PyMysql :
pip install PyMysql
(3) Utilisez PyMySQL:
#!/usr/bin/env python# coding=utf-8import pymysqldef connectdb():
print('连接到mysql服务器...') # 打开数据库连接
# 用户名:hp, 密码:Hp12345.,用户名和密码需要改成你自己的mysql用户名和密码，并且要创建数据库TESTDB，并在TESTDB数据库中创建好表Student
db = pymysql.connect("localhost","hp","Hp12345.","TESTDB")
print('连接上了!') return dbdef createtable(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # 如果存在表Sutdent先删除
cursor.execute("DROP TABLE IF EXISTS Student")
sql = """CREATE TABLE Student (
ID CHAR(10) NOT NULL,
Name CHAR(8),
Grade INT )"""
# 创建Sutdent表
cursor.execute(sql)def insertdb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 插入语句
sql = """INSERT INTO Student
VALUES ('001', 'CZQ', 70),
('002', 'LHQ', 80),
('003', 'MQ', 90),
('004', 'WH', 80),
('005', 'HP', 70),
('006', 'YF', 66),
('007', 'TEST', 100)"""
#sql = "INSERT INTO Student(ID, Name, Grade) \
# VALUES ('%s', '%s', '%d')" % \
# ('001', 'HP', 60)
try: # 执行sql语句
cursor.execute(sql) # 提交到数据库执行
db.commit() except: # Rollback in case there is any error
print '插入数据失败!'
db.rollback()def querydb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 查询语句
#sql = "SELECT * FROM Student \
# WHERE Grade > '%d'" % (80)
sql = "SELECT * FROM Student"
try: # 执行SQL语句
cursor.execute(sql) # 获取所有记录列表
results = cursor.fetchall() for row in results:
ID = row[0]
Name = row[1]
Grade = row[2] # 打印结果
print "ID: %s, Name: %s, Grade: %d" % \
(ID, Name, Grade) except: print "Error: unable to fecth data"def deletedb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 删除语句
sql = "DELETE FROM Student WHERE Grade = '%d'" % (100) try: # 执行SQL语句
cursor.execute(sql) # 提交修改
db.commit() except: print '删除数据失败!'
# 发生错误时回滚
db.rollback()def updatedb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 更新语句
sql = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003') try: # 执行SQL语句
cursor.execute(sql) # 提交到数据库执行
db.commit() except: print '更新数据失败!'
# 发生错误时回滚
db.rollback()def closedb(db):
db.close()def main():
db = connectdb() # 连接MySQL数据库
createtable(db) # 创建表
insertdb(db) # 插入数据
print '\n插入数据后:'
querydb(db)
deletedb(db) # 删除数据
print '\n删除数据后:'
querydb(db)
updatedb(db) # 更新数据
print '\n更新数据后:'
querydb(db)
closedb(db) # 关闭数据库if __name__ == '__main__':
main()pour exécuter les résultats :
3. Utilisation de mysql.connector
(1) Qu'est-ce que mysql.connector?
Étant donné que le serveur MySQL fonctionne comme un processus indépendant et sert des services externes via le réseau, le pilote MySQL qui prend en charge Python est requis pour connectez-vous au serveur MySQL.
Actuellement, il existe deux pilotes MySQL :
mysql-connector-python : est le pur MySQLPython pilote ;
MySQL-python : C'est le pilote Python qui encapsule le pilote MySQL C.
(2) Installezmysql.connector:
pip install mysql-connector-pythonpip install MySQL-python(3) Utilisez
mysql.connector:
#!/usr/bin/env python# coding=utf-8import mysql.connectordef connectdb():
print('连接到mysql服务器...') # 打开数据库连接
# 用户名:hp, 密码:Hp12345.,用户名和密码需要改成你自己的mysql用户名和密码，并且要创建数据库TESTDB，并在TESTDB数据库中创建好表Student
db = mysql.connector.connect(user="hp", passwd="Hp12345.", database="TESTDB", use_unicode=True)
print('连接上了!') return dbdef createtable(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # 如果存在表Sutdent先删除
cursor.execute("DROP TABLE IF EXISTS Student")
sql = """CREATE TABLE Student (
ID CHAR(10) NOT NULL,
Name CHAR(8),
Grade INT )"""
# 创建Sutdent表
cursor.execute(sql)def insertdb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 插入语句
sql = """INSERT INTO Student
VALUES ('001', 'CZQ', 70),
('002', 'LHQ', 80),
('003', 'MQ', 90),
('004', 'WH', 80),
('005', 'HP', 70),
('006', 'YF', 66),
('007', 'TEST', 100)"""
#sql = "INSERT INTO Student(ID, Name, Grade) \
# VALUES ('%s', '%s', '%d')" % \
# ('001', 'HP', 60)
try: # 执行sql语句
cursor.execute(sql) # 提交到数据库执行
db.commit() except: # Rollback in case there is any error
print '插入数据失败!'
db.rollback()def querydb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 查询语句
#sql = "SELECT * FROM Student \
# WHERE Grade > '%d'" % (80)
sql = "SELECT * FROM Student"
try: # 执行SQL语句
cursor.execute(sql) # 获取所有记录列表
results = cursor.fetchall() for row in results:
ID = row[0]
Name = row[1]
Grade = row[2] # 打印结果
print "ID: %s, Name: %s, Grade: %d" % \
(ID, Name, Grade) except: print "Error: unable to fecth data"def deletedb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 删除语句
sql = "DELETE FROM Student WHERE Grade = '%d'" % (100) try: # 执行SQL语句
cursor.execute(sql) # 提交修改
db.commit() except: print '删除数据失败!'
# 发生错误时回滚
db.rollback()def updatedb(db):
# 使用cursor()方法获取操作游标
cursor = db.cursor() # SQL 更新语句
sql = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003') try: # 执行SQL语句
cursor.execute(sql) # 提交到数据库执行
db.commit() except: print '更新数据失败!'
# 发生错误时回滚
db.rollback()def closedb(db):
db.close()def main():
db = connectdb() # 连接MySQL数据库
createtable(db) # 创建表
insertdb(db) # 插入数据
print '\n插入数据后:'
querydb(db)
deletedb(db) # 删除数据
print '\n删除数据后:'
querydb(db)
updatedb(db) # 更新数据
print '\n更新数据后:'
querydb(db)
closedb(db) # 关闭数据库if __name__ == '__main__':
main()Exécuter les résultats :
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Déclaration：
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Article précédent：Comment créer une liste et ajouter des éléments à la liste en python_pythonArticle suivant：Comment créer une liste et ajouter des éléments à la liste en python_python
Articles Liés
Voir plus- Pourquoi ~2 est-il égal à -3 en Python ?
- Comment résoudre « ImportError : aucun module nommé « xyz » » lors de l'utilisation de PyInstaller ?
- Comment implémenter des champs de modèle dynamique dans une application Django multi-tenant ?
- Pourquoi est-ce que je reçois une erreur de nom après la saisie de l'utilisateur en Python ?
- Comment formater des valeurs à virgule flottante dans des DataFrames Pandas à l'aide d'une chaîne de format ?