import pymysql
# 连接数据库
connect = pymysql.Connect(
host=‘localhost‘,
port=3306,
user=‘root‘,
passwd=‘root‘,
db=‘python3‘,
charset=‘utf8‘
)
# 获取游标
cursor = connect.cursor()
# sql操作
# 增加数据操作
sql_1 = "insert into url_file(url,file) values(%s,%s)"
data = (‘aa‘, ‘bb‘)
cursor.execute(sql_1, data) # 生成增加sql语句
connect.commit() # 确认永久执行增加
# 查询数据操作(只有查询用的全是游标,其他3种操作,要用连接的提交commit)
sql_2 = "select * from url_file"
cursor.execute(sql_2) # 生成查询sql语句
ret = cursor.fetchall() # 执行查询
print("执行完毕")
print(ret)
print(type(ret))
# 修改数据操作
sql_3 = "update url_file set url=‘bbbbbbbbbbbb‘ where id = 2"
cursor.execute(sql_3) # 生成修改sql语句
connect.commit() # 确认永久执行修改
# 删除数据操作
sql_4 = "delete from url_file where id =12"
r1 = cursor.execute(sql_4) # 生成修改sql语句,临时执行
r2 = connect.commit() # 确认永久执行删除
print(r1)
print(r2)