python3使用pymysql库连接MySQL的常用操作

Posted 2021-02-12 冷枫孤雪

#导入pymysql模块
import pymysql

#连接数据库
connect = pymysql.connect(
 host=‘localhost‘,
    port=3306,
    user=‘root‘,
    password=‘root‘,
    db=‘shop‘,
    charset=‘utf8‘
)

#获取游标
cursor = connect.cursor()
"""
游标默认获取的数据是元组类型，如果想要字典类型的数据
可以使用  connect.cursor(cursor=pymysql.cursors.DictCursor)
"""
#cursor = connect.cursor(cursor=pymysql.cursors.DictCursor)

#执行SQL，并返回受影响的行数
effect_row = cursor.execute("select * from product")
print(effect_row)

#获取所有数据
rows = cursor.fetchall()
print(rows)

#获取第一行数据
row_1 = cursor.fetchone()
print(row_1
      
#获取前n行数据
row_n = cursor.fetchmany(3)
print(row_n)

#如果是修改，更新等操作，需要提交，
# 不然无法保存新建或者修改的数据
connect.commit()

#关闭游标
cursor.close()
#关闭连接
connect.close(