python之pymysql库连接mysql实现增删改查

Posted 2021-02-28 Mrwhite86

安装第三方库pymysql

命令行cmd下通过pip install pymysql进行安装，安装完成后自行pip list可查看对应的版本信息

建立连接

1 #导入pymysql库
2 import pymysql
3 # 连接database
4 conn = pymysql.connect(host=\'127.0.0.1\', user=\'root\',password=\'baikang\',database=\'bookdb\',charset=\'utf8\')
5 # 得到一个可以执行SQL语句并且将结果作为字典返回的游标
6 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

原始表数据如下

定义要执行的SQL语句

1 sql1 =\' select * from users ; \'
2 sql2 = \'insert into users (id,username,password,email) VALUES (2,%s,123,%s);\'
3 sql3 = \'DELETE FROM users where username=%s;\'
4 sql4 = \'UPDATE users SET username=%s where id=1;\'

执行SQL语句(查)

1 cursor.execute(sql1)
2 #获取结果
3 data=cursor.fetchall()
4 print(\'查询结果\',data)

执行SQL语句(增)

1 cursor.execute(sql2,(\'java\',\'[e-mail]\'))
2 #提交操作
3 conn.commit()
4 #再次查询,获取结果
5 cursor.execute(sql1)
6 data=cursor.fetchall()
7 print(\'新增结果\',data)

执行SQL语句(删)

1 cursor.execute(sql3,\'java\')
2 #提交操作
3 conn.commit()
4 #再次查询,获取结果
5 cursor.execute(sql1)
6 data=cursor.fetchall()
7 print(\'删除结果\',data)

执行SQL语句(改)

1 cursor.execute(sql4,\'pythongood\')
2 #提交操作
3 conn.commit()
4 #再次查询,获获取结果
5 cursor.execute(sql1)
6 data=cursor.fetchall()
7 print(\'修改结果\',data)

关闭光标对象

1 cursor.close()

关闭数据库连接

1 conn.close()