记录Python链接mysql数据的增删改查方法

一、添加方法

db = pymysql.connect(host='localhost',user='root',password='123456',db='python')
cursor = db.cursor()
sql ="""insert into EMPLOYEEVALUES('3','张','天爱',35,'F',8000)
"""
try:cursor.execute(sql)db.commit() #提交后，数据才会变
except:db.rollback()#数据异常时，回滚
db.close()

结果

二、修改

db = pymysql.connect(host='localhost',user='root',password='123456',db='python')
cursor = db.cursor()
sql ="""update EMPLOYEE set INCOME=18000 where EMPLOYEE_ID=1
"""
try:cursor.execute(sql)db.commit()
except:db.rollback()
db.close()

结果

三、删除

db = pymysql.connect(host='localhost',user='root',password='123456',db='python')
cursor = db.cursor()
sql ="""delete from EMPLOYEE  where EMPLOYEE_ID=1
"""
try:cursor.execute(sql)db.commit()
except:db.rollback()
db.close()

结果

四、查找

db = pymysql.connect(host='localhost',user='root',password='123456',db='python')
cursor = db.cursor()
sql ='select * from employee'
try:cursor.execute(sql)results = cursor.fetchall()for row in results:print(row)fname = row[1]lname = row[2]age = row[3]sex = row[4]income = row[5]print(f'我是{fname}{lname},今天{age}岁了,性别是{sex},工资是{income}')
except:print('查询数据出错')
db.close()

结果