3）使用pandas中的read_sql()方法，将提取到的数据直接转化为DataFrame进行操作
import pymysql import pandas as pd db = pymysql.connect(host='localhost',user='root',db='huangwei',password='123456',port=3306,charset='utf8') cursor = db.cursor() df1 = pd.read_sql("select * from student where ssex='男'",db) display(df1) df2 = pd.read_sql("select * from student where ssex='女'",db) display(df2)
结果如下：
6、插入数据…增
1）一次性插入一条数据
import pymysql db = pymysql.connect(host='localhost',user='root', password='123456',port=3306, db='huangwei', charset='utf8') cursor = db.cursor() # mysql中SQL语句怎么写，这里就怎么写； name = "猪八戒" age = 8000 sql = 'insert into person(name,age) values ("猪八戒",8000)' try: cursor.execute(sql) db.commit() print("插入成功") except: print("插入失败") db.rollback() db.close()
1.1）一次性插入一条数据
import pymysql db = pymysql.connect(host='localhost',user='root', password='123456',port=3306, db='huangwei', charset='utf8') cursor = db.cursor() # 插入数据 sql = 'insert into person(name,age) values(%s,%s)' try: cursor.execute(sql,('孙悟空',100000)) db.commit() print("插入成功") except: print("插入失败") db.rollback() db.close()
2）一次性插入多条数据
import pymysql db = pymysql.connect(host='localhost',user='root', password='123456',port=3306, db='huangwei', charset='utf8') cursor = db.cursor() # 插入数据 sql = 'insert into person(name,age) values(%s,%s)' # 注意：(('牛魔王',9000),('铁扇公主',8000),('玉皇大帝',6000))也可以，小括号都可以换为中括号 datas = [('牛魔王',9000),('铁扇公主',8000),('玉皇大帝',6000)] try: cursor.executemany(sql,datas) db.commit() print("插入成功") except: print("插入失败") db.rollback() db.close()
总结如下：
① pymysql模块是默认开启mysql的事务功能的，因此，进行 “增” “删” "改"的时候，一定要使用db.commit()提交事务，否则就看不见所插入的数据。
② 进行 “增”、“删”、"改"的时候，一定要使用try…except…语句，因为万一没插入成功，其余代码都无法执行。当语句执行不成功，我们就db.rollback()回滚到操作之前的状态；当语句执行成功，我们就db.commit()提交事务。
7、更新数据…改
import pymysql db = pymysql.connect(host='localhost',user='root', password='123456',port=3306, db='huangwei', charset='utf8') cursor = db.cursor() # 更新数据 sql = 'update person set age=%s where name=%s' try: cursor.execute(sql,[90000,"玉皇大帝"]) db.commit() print("更新成功") except: print("更新失败") db.rollback() db.close()
8、删除数据…删
import pymysql db = pymysql.connect(host='localhost',user='root', password='123456',port=3306, db='huangwei', charset='utf8') cursor = db.cursor() # 删除数据 sql = 'delete from person where age=8000' try: cursor.execute(sql) db.commit() print("删除成功") except: print("删除失败") db.rollback() db.close()
