python utilise pymysql pour faire fonctionner mysql

pymsql est un module en Python qui fait fonctionner MySQL. Son utilisation est presque la même que MySQLdb. Mais actuellement, pymysql prend en charge python3.x et ce dernier ne prend pas en charge la version 3.x.

Environnement applicable

version python>=2.6 ou 3.3

version mysql>=4.1

Installation

Vous pouvez utiliser pip pour installer ou télécharger et installer manuellement.

Utilisez pip pour installer, exécutez la commande suivante sur la ligne de commande :

pip install PyMySQL

Pour installer manuellement, veuillez d'abord télécharger. Adresse de téléchargement : https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X.

X.X est la version (la dernière version actuellement disponible est la 0.6.6).

Après le téléchargement, décompressez le package compressé. Entrez le répertoire décompressé sur la ligne de commande et exécutez les instructions suivantes :

python setup.py install

Il est recommandé d'utiliser pip pour installer.

Exemple d'utilisation

Connectez-vous à la base de données comme suit :

import pymysql.cursors
  
# Connect to the database
connection = pymysql.connect(host='127.0.0.1',
               port=3306,
               user='root',
               password='zhyea.com',
               db='employees',
               charset='utf8mb4',
               cursorclass=pymysql.cursors.DictCursor)

Vous pouvez également utiliser un dictionnaire pour gérer les paramètres de connexion, je pense que c'est plus élégant. :

import pymysql.cursors
  
config = {
     'host':'127.0.0.1',
     'port':3306,
     'user':'root',
     'password':'zhyea.com',
     'db':'employees',
     'charset':'utf8mb4',
     'cursorclass':pymysql.cursors.DictCursor,
     }
  
# Connect to the database
connection = pymysql.connect(**config)

Insérer des données :

Vous devez obtenir le curseur avant d'exécuter l'instruction SQL car la configuration par défaut est la soumission automatique. , vous devez prendre l'initiative après avoir exécuté l'instruction sql commit, n'oubliez pas de fermer la connexion à la fin :

from datetime import date, datetime, timedelta
import pymysql.cursors
  
#连接配置信息
config = {
     'host':'127.0.0.1',
     'port':3306,
     'user':'root',
     'password':'zhyea.com',
     'db':'employees',
     'charset':'utf8mb4',
     'cursorclass':pymysql.cursors.DictCursor,
     }
# 创建连接
connection = pymysql.connect(**config)
  
# 获取明天的时间
tomorrow = datetime.now().date() + timedelta(days=1)
  
# 执行sql语句
try:
  with connection.cursor() as cursor:
    # 执行sql语句，插入记录
    sql = 'INSERT INTO employees (first_name, last_name, hire_date, gender, birth_date) VALUES (%s, %s, %s, %s, %s)'
    cursor.execute(sql, ('Robin', 'Zhyea', tomorrow, 'M', date(1989, 6, 14)));
  # 没有设置默认自动提交，需要主动提交，以保存所执行的语句
  connection.commit()
  
finally:
  connection.close();

Exécutez le. requête :

import datetime
import pymysql.cursors
  
#连接配置信息
config = {
     'host':'127.0.0.1',
     'port':3306,
     'user':'root',
     'password':'zhyea.com',
     'db':'employees',
     'charset':'utf8mb4',
     'cursorclass':pymysql.cursors.DictCursor,
     }
# 创建连接
connection = pymysql.connect(**config)
  
# 获取雇佣日期
hire_start = datetime.date(1999, 1, 1)
hire_end = datetime.date(2016, 12, 31)
  
# 执行sql语句
try:
  with connection.cursor() as cursor:
    # 执行sql语句，进行查询
    sql = 'SELECT first_name, last_name, hire_date FROM employees WHERE hire_date BETWEEN %s AND %s'
    cursor.execute(sql, (hire_start, hire_end))
    # 获取查询结果
    result = cursor.fetchone()
    print(result)
  # 没有设置默认自动提交，需要主动提交，以保存所执行的语句
  connection.commit()
  
finally:
  connection.close();

Requête ici Un résultat de requête est récupéré, et le résultat de la requête est renvoyé sous la forme d'un dictionnaire :

Pour obtenir le nombre spécifié de enregistrements de l'ensemble de résultats, vous pouvez utiliser la méthode fetchmany :

result = curseur.fetchmany(2)

Cependant, il n'est pas recommandé de l'utiliser de cette façon. Il est préférable de définir. le nombre total d'enregistrements interrogés dans l'instruction SQL.

Pour obtenir l'intégralité du jeu de résultats, vous pouvez utiliser la méthode fetchall :

result = Cursor.fetchall()

Comme il n'y a que deux enregistrements, les deux méthodes de requête mentionné ci-dessus Les résultats trouvés sont les mêmes :

[{'last_name': 'Vanderkelen', 'hire_date': datetime.date(2015, 8, 12), 'first_name': 'Geert'}, {'last_name': 'Zhyea', 'hire_date': datetime.date(2015, 8, 21), 'first_name': 'Robin'}]

utilisé dans Django

utilisé dans Django était le but initial de ma recherche pour cela. Actuellement, il n'est pas facile de trouver un backend de base de données prenant en charge à la fois python3.4 et django1.8. C'est le meilleur que j'ai trouvé jusqu'à présent.

Le paramètre DATABASES n'est pas différent du paramètre MySQLdb officiellement recommandé :

DATABASES = {
'default' : {
'ENGINE' : 'django.db.backends. ',
'NOM' : 'montest',
'UTILISATEUR' : 'root',
'MOT DE PASSE' : 'zhyea.com',
'HÔTE' : '127.0.0.1' ,
'PORT' : '3306',
}
}

La clé est ici : il faut également ajouter le contenu suivant au fichier __init__.py du site :

import pymysql
pymysql.install_as_MySQLdb()

Enfin, je joindrai le code pour ajouter, supprimer, modifier et archiver pymysql. J'espère que vous l'aimerez.

#!/usr/bin/python
#coding:gbk
import pymysql
from builtins import int
 
#将MysqlHelper的几个函数写出来
 
def connDB():               #连接数据库
  conn=pymysql.connect(host="localhost",user="root",passwd="zx69728537",db="student");
  cur=conn.cursor();
  return (conn,cur);
 
def exeUpdate(conn,cur,sql):        #更新或插入操作
  sta=cur.execute(sql);
  conn.commit();
  return (sta);
 
def exeDelete(conn,cur,IDs):        #删除操作
  sta=0;
  for eachID in IDs.split(' '):
    sta+=cur.execute("delete from students where Id=%d"%(int(eachID)));
  conn.commit();
  return (sta);
     
def exeQuery(cur,sql):           #查找操作
  cur.execute(sql);
  return (cur);
   
def connClose(conn,cur):          #关闭连接，释放资源
  cur.close();
  conn.close();
 
result=True;
print("请选择以上四个操作：1、修改记录，2、增加记录，3、查询记录，4、删除记录.(按q为退出)");
conn,cur=connDB();
number=input();
while(result):
  if(number=='q'):
    print("结束操作");
    break;
  elif(int(number)==1):
    sql=input("请输入更新语句：");
    try:
      exeUpdate(conn, cur, sql);
      print("更新成功");
    except Exception:
      print("更新失败");
      raise;
  elif(int(number)==2):
      sql=input("请输入新增语句:");
      try:
        exeUpdate(conn, cur, sql);
        print("新增成功");
      except Exception:
        print("新增失败");
        raise;
  elif(int(number)==3):
    sql=input("请输入查询语句：");
    try:
      cur=exeQuery(cur, sql);
      for item in cur:
        print("Id="+str(item[0])+" name="+item[1]);
    except Exception:
      print("查询出错");
      raise;
  elif(int(number)==4):
    Ids=input("请输入Id，并用空格隔开");
    try:
      exeDelete(conn, cur, Ids);
      print("删除成功");
    except Exception:
      print("删除失败");
      raise;
  else:
    print("非法输入，将结束操作!");
    result=False;
    break;
  print("请选择以上四个操作：1、修改记录，2、增加记录，3、查询记录，4、删除记录.(按q为退出)");
  number=input("请选择操作");

Pour plus d'articles liés à Python utilisant pymysql pour faire fonctionner MySQL, veuillez faire attention au site Web PHP chinois !