#pymysql连接数据库的步骤 # 1. 导入pymysql # 2. 使用 pymysql.connect(host=地址, user=用户名, password=密码, port=端口, db=数据库名) 建立数据库的连接，得到连接对象 # 3. 获取游标对象：con.cursor(pymysql.cursors.DictCursot) # 4. 使用 cursor.excute(sql) 执行SQL语句 # 5. 如果是查询操作，则使用 fetchall、fetchone、fetchmany 来读取数据集 # 如果是增删改操作，则使用 commit() 提交操作 # 6. 增删改如果出现异常错误可以使用 rollback() 进行回滚操作 # 7. 关闭数据库连接：con.close() #查询操作 # 导入pymysql import pymysql # 连接数据库 # host 数据库主机地址 # user 数据库用户名 # password 数据库密码 # port 数据库端口号 # db 数据库的名称 con = pymysql.connect(host='127.0.0.1', user='root', password='123456', port=3306, db='pp') # 获取数据库游标(指定结果集中数据的类型是字典还是元组) # pymysql.cursors.DictCursor 指定结果集中的数据以字段类型的数据表示 cur = con.cursor(pymysql.cursors.DictCursor) # 创建SQL命令 sql = 'select * from teacher' # 执行SQL语句 cur.execute(sql) # 获取查询结果集 # fetchall 一次性将所有的查询结果获取出来 # fetchone 获取一条数据 # fetchmany(size=n) 获取指定数量的数据 results = cur.fetchall() # result = cur.fetchone() # result = cur.fetchmany(size=3) # print(result) for item in results: # 对每条数据执行操作代码 print(item) # 关闭数据库连接 con.close() #下面是插入、删除、修改数据 import pymysql con = pymysql.connect(host='127.0.0.1', user='root', password='123456', db='pp', port=3306) cur = con.cursor(pymysql.cursors.DictCursor) cur.execute('insert into class (name) values (%s)', ('二年十一班'))#插入数据 # cur.execute('update class set name="拉拉啊了" where id=25')#修改 # cur.execute('delete from class where id=24')#删除 # 判断增删改操作是否成功，应该通过受影响的行数来判断 print(con.affected_rows()) # 获取受影响的行数 con.commit() # 执行提交方法才会影响数据库 con.close() #知识来源于彭老师