import pymysql

# 获取链接对象
conn = pymysql.connect(host="localhost", port=3306, user='root', password='cgroot', database='pymysqltest',
                       charset='utf8')

# 事务
conn.begin()
# conn.rollback()

# 获取游标对象
cursor = conn.cursor()
sql = 'select * from students;'
row_count = cursor.execute(sql)

print("执行结果", row_count)
# 取出结果元组一行数据
oneData = cursor.fetchone()
print("取出结果元组一行数据", type(oneData), oneData)
# 取出元组剩下的所有数据
allData = cursor.fetchall()
print("取出元组剩下所有数据", type(allData), allData)

name = input("请输入修改的用户名:")
# 修改
updateSql = "update students set gender = '男' where name =%s;"
# 使用%s占位符,防止sql注入
updateResult = cursor.execute(updateSql, [name])
print("修改结果:", updateResult)
# 涉及对数据库数据的修改,需要提交,否则不会生效
conn.commit()

row_count = cursor.execute(sql)
print("执行结果", row_count)
# 取出结果元组一行数据
oneData = cursor.fetchone()
print("取出结果元组一行数据", type(oneData), oneData)
# 取出元组剩下的所有数据
allData = cursor.fetchall()
print("取出元组剩下所有数据", type(allData), allData)

# 关闭游标
cursor.close()
# 关闭链接
conn.close()
Logo

汇聚全球AI编程工具,助力开发者即刻编程。

更多推荐