1.安装引入模块
-
安装mysql模块
pip install PyMySQL;
-
文件中引入模块
import pymysql
2.认识Connection对象
-
用于建立与数据库的连接
-
创建对象:调用connect()方法
conn = pymysql.connect(host="主机",port=3306,user="用户名",passwd="密码",db="数据库名",charset="utf8")
如果是本机,host填'localhost',port端口号,默认3306,charset字符编码,默认是'gb2312',要求与数据库创建时指定的编码一致,否则中文会乱码
-
对象方法
- close()-------关闭连接
- commit()-----提交事务,使操作生效,在执行select查询任务时,则不需要这一步
- rollback()----回滚事务,放弃之前的操作
- cursor()------创建cursor对象,用于执行sql语句
3.认识Cursor对象
-
执行sql语句
-
创建对象,调用Connection对象的cursor()方法
cur = conn.cursor()
-
对象的方法:
- close()-----关闭
- execute(sql,[,parameters])-----执行语句,返回受影响的行数,第二个参数可选,元组或列表类型,参数化可以防止sql注入风险
- fetchone()-----执行查询语句时,获取查询结果集的第一个行数据,返回一个元组,未查到,则返回None。如果结果集不止一条数据,可以再次执行fetchone()获得第二个行数据,依此类推
- fetchall()-----执行查询时,获取结果集的所有行,一行构成一个元组,再将这些元组装入一个元组返回,未查到,则返回空元组()。
- scroll(value[,mode])-----将行指针移动到某个位置。mode表示移动的方式,默认值为'relative',value表示基于当前行向上(取负值)或向下(取正值)移动的行数。当mode的值为‘absolute’,value表示基于第一行数据(位置为0)向下移动的行数。
-
对象的属性:
- rowcount只读属性,表示最近一次execute()执行后受影响的行数
- connection获得当前连接对象
4.示例
-
增加、修改、删除一条学生表数据
# coding = utf-8 import pymysql con = pymysql.connect(host='localhost',port=3306,user='root',password='123',db='test',charset='utf8') # 创建connect对象 cur = conn.cursor() #创建cursor对象 name = input('请输入添加的学生姓名:') sql1 = 'insert into students(name) values(%s);' sql2 = 'delete from students where name = "老王";' sql3 = 'update students set name = “老张” where name = "老李";' try: cur.execute(sql1,[name]) #增加一条数据 cur.execute(sql2) #删除一条数据 cur.execute(sql3) #修改一条数据 except Exception as e: print(e) con.rollback() # 放弃之前的所有操作 else: con.commit() # 提交,使所有操作生效 cur.close() # 关闭cursor对象 con.close() # 关闭连接
-
查询一条学生表数据以及剩下的多行数据
# coding = utf-8 import pymysql con = pymysql.connect(host='localhost',port=3306,user='root',password='123',db='test',charset='utf8') # 创建connect对象 cur = conn.cursor() #创建cursor对象 try: sql = 'select * from students;' count = cur.execute(sql) data1 = cur.fetchone() #查找第一行数据 print(data1) data2 = cur.fetchall() # 查找剩下所有行数据 print(data2) except Exception as e: print(e) cur.close() con.close()