代码:
#coding=utf-8 #连接数据库测试 import pymysql #打开数据库 db = pymysql.connect(host="localhost",user="root",password="PENGsuoqun123",db="info") #使用cursor()方法获取操作游标 cur = db.cursor() #增加数据 sql1="insert into student1(id,name) values('11','q'),('12','qwe')" try: # 执行sql语句 cur.execute(sql1) db.commit() except Exception as a: raise a finally: db.close() #打开数据库 db = pymysql.connect(host="localhost",user="root",password="PENGsuoqun123",db="info") #使用cursor()方法获取操作游标 cur = db.cursor() #删除数据 sql2="delete from student1 where id='10'" try: # 执行sql语句 cur.execute(sql2) db.commit() except Exception as b: raise b finally: db.close() #打开数据库 db = pymysql.connect(host="localhost",user="root",password="PENGsuoqun123",db="info") #使用cursor()方法获取操作游标 cur = db.cursor() #修改数据 sql3= "update student1 set name='kai3' where id='2'" try: # 执行sql语句 cur.execute(sql3) db.commit() except Exception as c: raise c finally: db.close() #打开数据库 db = pymysql.connect(host="localhost",user="root",password="PENGsuoqun123",db="info") #使用cursor()方法获取操作游标 cur = db.cursor() #查询操作 sql = "select * from student1" try: # 执行sql语句 cur.execute(sql) results = cur.fetchall() #遍历结果 for rows in results: id = rows[0] name = rows[1] print("id: {}, name: {}".format(id,name)) except Exception as e: raise e finally: db.close()
标签:cur,python,改查,数据库,db,cursor,sql,增删,id From: https://www.cnblogs.com/pengsuoqun123/p/17316949.html