第一步:
PyMySQL 安装:
pip3 install PyMySQL
第二步:
导入Python库:
import pymysql
第三步:
创建数据库连接对象:host默认一般是localhost,用户名和密码是自己创建数据库时所设定的,database为数据库名称
- db = pymysql.connect(host='localhost',
- user='root',
- password='123456',
- database='DB')
第四步:
创建表:
- # 创建游标对象 cursor
- cur = db.cursor()
-
- # 是否该表已经存在,若存在则删除
- cursor.execute("DROP TABLE IF EXISTS STUDENT")
-
- # 创建表的SQL语句(不唯一)
- sql = "CREATE TABLE STUDENT(NAME CHAR(20) NOT NULL,AGE INT,SEX CHAR(1),ID CHAR(20))"
-
- cursor.execute(sql)
第五步:
操作数据库:
1. 插入:
- # 插入的SQL语句(不唯一)
- sql = "INSERT INTO STUDENT(NAME,AGE, SEX, ID)VALUES ('ZYS', 20, 男,666666666)"
- #try语句防止连接数据库时发生错误
- try:
- # 执行sql语句
- cursor.execute(sql)
- # 提交到数据库执行
- db.commit()
- print("数据插入成功")
- except:
- # 如果发生错误则回滚
- db.rollback()
- print("数据插入失败")
2.查询:
- # 插入SQL语句(不唯一,此处为只查询名字为ZYS的数据)
- sql = "SELECT * FROM STUDENT WHERE NAME='ZYS'"
- try:
- # 执行SQL语句
- cursor.execute(sql)
- # 获取所有记录列表
- results = cursor.fetchall()
- for row in results:#遍历查询结果
- name = row[0]
- age = row[1]
- sex = row[2]
- id = row[3]
-
- # 打印结果
- print ("name:%s,age:%d,sex:%s,id:%s" % (name,age,sex,id))
- except:
- #若查询失败
- print ("查询失败")
3.更新:
- # 更新的SQL语句(不唯一)
- sql = "UPDATE STUDENT SET AGE = 20 WHERE SEX = '%s'" % ('女')
- try:
- # 执行SQL语句
- cursor.execute(sql)
- # 提交到数据库执行
- db.commit()
- print("数据更新成功")
- except:
- # 发生错误时回滚
- db.rollback()
- print("数据更新失败")
4. 删除:
- # 删除的SQL语句(不唯一)
- sql = "DELETE FROM STUDENT WHERE NAME='ZYS'"
- try:
- # 执行SQL语句
- cursor.execute(sql)
- # 提交修改
- db.commit()
- print("数据删除成功")
- except:
- # 发生错误时回滚
- db.rollback()
- print("数据删除失败")
至此,Python对数据库的基本操作