1 import pymysql 2 3 conn = pymysql.connect(host='localhost',user='root',passwd='123456',db='jodb1',port=3307,charset='utf8') 4 # 172.31.10.225 5 6 # 查询EMPLOYEE表中salary(工资)字段大于1000的所有数据: 7 cursor = conn.cursor() 8 9 10 print('1---------------------------------------------------------------------')11 sql = 'select * from employee where income > 2500'12 cursor.execute(sql)13 results = cursor.fetchall()14 try:15 for row in results:16 fname = row[0]17 lname = row[1]18 age = row[2]19 sex = row[3]20 income = row[4]21 print('first_name={0},last_name={1},age={2},sex={3},income={4}'.format(fname,lname,age,sex,income))22 23 except:24 print('oh,there a exception!')25 conn.close()26 print('select successfully')27 28 29 30 print('2---------------------------------------------------------------------')31 32 # sql_update = 'update employee set age = 28 where sex ={0}'.format('F')33 sql2 = "update employee set age = 28 where sex = '%c'"%('M')34 try:35 cursor.execute(sql2)36 conn.commit()37 except:38 conn.rollback()39 print('Execute this statement')40 41 42 print('3---------------------------------------------------------------------')43 44 sql3 = "delete from employee where income = '%d'"%(3900)45 try:46 cursor.execute(sql3)47 conn.commit()48 except:49 conn.rollback()
执行其中一部分时将其他部分删除,否则会有错误