python

超轻量级php框架startmvc

详解使用pymysql在python中对mysql的增删改查操作(综合)

更新时间:2020-04-26 21:00:01 作者:startmvc
这一次将使用pymysql来进行一次对MySQL的增删改查的全部操作,相当于对前五次的总结:先查

这一次将使用pymysql来进行一次对MySQL的增删改查的全部操作,相当于对前五次的总结:

先查阅数据库:

现在编写源码进行增删改查操作,源码为:


#!/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("请选择操作"); 

现在运行程序观察:

现在查询数据库:

可以看到数据库中新增了一条数据,现在进行更新数据:

现在我们不在查询数据库,直接在该程序中进行查询,如图:

可以看到已经将第四条数据的Name更新为bingwen,现在进行删除操作,删除第四条记录,如图:

现在我们在数据库中进行查询是否将该数据删除,如图:

可以看到删除操作已经成功进行,现在退出当前程序,如图:

如此,pymysql对mysql数据库的增删改查操作便完成了。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

pymysql 操作mysql pymysql连接mysql mysql pymysql