create_engine和to_sql使用

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: 如果表存在,把数据插入,如果表不存在创建一个表

后续完善内容。。。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。