这一次将使用pymysql来进行一次对MySQL的增删改查的全部操作,相当于对前五次的总结:
先查阅数据库:
现在编写源码进行增删改查操作,源码为:
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
|
#!/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数据库的增删改查操作便完成了。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:http://blog.csdn.net/u012734441/article/details/42047715