概述
使用pymysql进行增删改操作
实现步骤
1.导入pymysql包
import pymysql
2. 创建连接对象
connect = Connection = Connect 本质上是一个函数，使用这三个里面的任何一个函数都可以创建一个连接对象
- 1. host : 服务器的主机地址
- 2. port: mysql数据库的端口号
- 3. user： 用户名
- 4. password：密码
- 5. database: 操作的数据库
- 6. charset: 操作数据库使用的编码格式
conn = pymysql.connect(host="localhost", port=3306, user="root", password="mysql123456", database="python", charset="utf8")
3.获取游标
目的就是要执行sql语句
cursor = conn.cursor() sql ="insert into classes(name) values('pythona');"sql ="update classes set name = 'pythonhu' where id= 5;"sql ="delete from classes where id=5;"
4. 执行sql语句
cursor.execute(sql) # 提交修改的数据到数据库conn.commit() # 对修改的数据进行撤销，表示数据回滚（回到没有修改数据之前的状态）conn.rollback()
5. 关闭游标
cursor.close()
6. 关闭连接
conn.close()
代码实现
# 1. 导包import pymysql if __name__ =='__main__': # 2. 创建连接对象# connect = Connection = Connect 本质上是一个函数，使用这三个里面的任何一个函数都可以创建一个连接对象# 1. host : 服务器的主机地址# 2. port: mysql数据库的端口号# 3. user： 用户名# 4. password：密码# 5. database: 操作的数据库# 6. charset: 操作数据库使用的编码格式 conn = pymysql.connect(host="localhost", port=3306, user="root", password="mysql", database="python41", charset="utf8") # 3. 获取游标， 目的就是要执行sql语句 cursor = conn.cursor() # 准备sql, 之前在mysql客户端如何编写sql，在python程序里面还怎么编写# 注意点:对数据表完成添加、删除、修改操作，需要把修改的数据提交到数据库# sql = "insert into classes(name) values('python50');"# sql = "update classes set name = 'python45' where id= 5;" sql ="delete from classes where id=5;" try: # 4. 执行sql语句 cursor.execute(sql) # 提交修改的数据到数据库 conn.commit() except Exception as e: # 对修改的数据进行撤销，表示数据回滚（回到没有修改数据之前的状态） conn.rollback() finally: # 5. 关闭游标 cursor.close() # 6. 关闭连接 conn.close()
