使用pd.io.sql.to_sql 将数据导入到mysql数据库

首先导入需要的包

# 导入需要的包
import pandas as pd
import sqlalchemy import create_engine

初始化数据库,导入数据

db_info = {'user':'root', 
'password':'123456',
'host' : 'localhost',
'port': 3306,
database':'mystcok'
}

# engine创建方法一:
engine = create_engine('mysql+pymysql://%(user)s:%(password)s@%(host)s:%(port)d/%(database)s?charset=utf8' % db_info, enconding = 'utf-8') 

# engine创建方法二:
engine = create_engine('mysql+pymysql://root:123456@localhost:3306/mystock?charset=utf-8', enconding = 'utf-8')

# 读取本地excel文件
df = pd.read_excel("D:/workfold/机构持仓.xlsx", sheet_name = '2016-2019', converters = {'股票代码: str})

# 将数据存储进mysql数据库
pd.io.sql.to_sql(df, '机构持仓', con = engine, index = False, if_exists = 'append')

补充说明

pd.io.sql.to_sql参数

index = False:不导入索引列

'机构持仓' :mysql中插入数据的表名称

con = engine 的另一种写法 <===> con = engine.connect()

if_exists:如果表存在就将数据插入,如果表不存在就新建一个表格。如果参数指定为replace,则将原来存在的表删除,新建一个表格,将数据插入。

 

 

 

 



版权声明:本文为Terry0424原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。