通过pd.io.sql.to_sql方法将pandas处理后的数据集结果,写入到数据库中:
##连接数据库,将数据集通过pd.io.sql.to_sql方法写入到数据库中
##通过create_engine方法连接数据库
from sqlalchemy import create_engine
conn = create_engine(‘mysql+mysqldb://root:123456@192.168.18.111:3306/aaa?charset=utf8‘)
##output_data为pandas处理后的数据集,如上图,,out_table为目标数据库的表明
##if_exists有三个参数: append:表存在,数据追加;表不存在,创建表,数据追加
##fail:表存在的话不操作 replace:表存在会将表删了重建,数据导入
pd.io.sql.to_sql(output_data,"out_table",con=conn,schema=‘aaa‘,if_exists=‘replace‘)
conn.dispose()
出现报错:ModuleNotFoundError: No module named ‘MySQLdb‘
解决方法: pymysql.install_as_MySQLdb()