df
import panda as pd
from sqlalchemy import create_engine
username='root'
pwd = ''
host='localhost'
port='3306'
db='astock'
engine = create_engine(f'mysql+pymysql://{username}:{pwd}@{host}:{port}/{db}', encoding='utf8')
"""
读取sql中的数据进pandas处理
sql =
"""select * from
daily_trade
where code=300793
"""
df = pd.read_sql(sql, engine)
"""
df.to_sql(name='table_name', con=engine, chunksize=1000, if_exists='replace', index=None)
chunksize一次存多少进去
if_exists表示有数据库同名表怎么办
replace 替换数据
append 追加数据
fail 抛出异常
index接收boolean值，表示是否将DataFrame的index也作为表的列存储进去
网友评论