import pandas as pd
from sqlalchemy import create_engine
# 创建数据库引擎
engine = create_engine('mysql://root:password@localhost:3306/databasename?charset=utf8')
# 取数并读取为DataFrame
df = pd.read_sql_query("select * from dw_customer_order", con=engine)
# 对DataFrame操作完成后写入数据库
# 如果数据库不变,下面这句可以省略
engine = create_engine('mysql+mysqldb://root:password@localhost:3306/databasename?charset=utf8')
# 使用to_sql插入表
df.to_sql(tablename, con=engine, if_exists='repalce')
if_exists可选参数含义:
- fail: 如果表存在,啥也不做
- replace: 如果表存在,删了表,再建立一个新表,把数据插入
- append: 如果表存在,把数据插入,如果表不存在创建一个表
后续完善内容。。。