首先,温习一个清空数据库表内容的命令
truncate table 表名
下面进入正题:
(1)导入包
import pandas as pd
import sqlalchemy
"""
SQLAlchemy是Python编程语言下的一款开源软件。提供了SQL工具包及对象关系映射(ORM)工具,使用MIT许可证发行。
"""
(2)sql语句及数据库连接
sql='select * from courses'
from sqlalchemy import create_engine
import pymysql
engine = create_engine('mysql+pymysql://用户名:密码@ip地址:端口/数据库名称')
df=pd.read_sql(sql,engine)
df.head()
(3)在数据库连接的表的内容
truncate table courses;
(4)再次在jupyter中查看表内容是否被清空
(5)重新对清空的表写入数据(注意:重新写入的字段名称要与原表保持一致,否则会报错)
df1=pd.DataFrame({'student':['mary','tom','bob']
,'class':['18','29','12']})
#写入数据到mysql
#参数 if_exists 表示:如果有数据则插入
df1.to_sql('courses',engine,index=False,if_exists='append')
完成!
网友评论