本篇文章主要介绍了使用pymysql在python中对mysql的增删改查操作,通过pymysql向数据库进行查删增改,具有一定的参考价值,有兴趣的可以了解一下。
这一次将使用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 %(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(” 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(“请选择操作”);
现在运行程序观察:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支php中文网。
更多详解使用pymysql在python中对mysql的增删改查操作(综合)相关文章请关注php中文网!