import pymysql
''''fetchone用法 (获取一条数据)'''
def selectmysql():
# 打开数据库连接
db=pymysql.connect("localhost","root","root","kettle")
#使用cursor()方法获取操作游标
cursor=db.cursor()
sql="select * from beijing"
#使用excute方法执行sql语句
cursor.execute(sql)
#使用fetchone()方法获取一条数据
data=cursor.fetchone()
print(data)
'''fetchall() 接收全部的返回结果行'''
def selectfetchall():
# 打开数据库连接
db = pymysql.connect("localhost", "root", "root", "kettle")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
sql = "select * from beijing"
try:
# 使用excute方法执行sql语句
cursor.execute(sql)
#获取所有记录列表
res=cursor.fetchall()
for row in res:
name=row[0]
num=row[1]
#打印结果
print("name=%s,num=%s"%(name,num))
except:
print("error")
#关闭数据库连接
db.close()
'''数据库插入操作'''
def insert():
# 打开数据库连接
db = pymysql.connect("localhost", "root", "root", "kettle")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
sql = "insert into beijing(name,num) VALUES ('吴林祥','666')"
try:
# 使用excute方法执行sql语句
cursor.execute(sql)
db.commit()
print("插入数据库成功!")
except:
db.rollback()
db.close()
'''数据库更新操作'''
def update():
# 打开数据库连接
db = pymysql.connect("localhost", "root", "root", "kettle")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
sql = "update beijing set num=8 WHERE name='延庆区'"
try:
# 使用excute方法执行sql语句
cursor.execute(sql)
db.commit()
print("更新数据库成功!")
except:
db.rollback()
db.close()
'''删除操作'''
def delete():
# 打开数据库连接
db = pymysql.connect("localhost", "root", "root", "kettle")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
sql = "delete from beijing where name='吴林祥'"
try:
# 使用excute方法执行sql语句
cursor.execute(sql)
db.commit()
print("删除数据成功!")
except:
db.rollback()
db.close()
if __name__ == '__main__':
selectmysql()
#insert()
#selectfetchall()
#update()
#delete()(编辑：雷林鹏 来源：网络|侵删)