利用python把excel数据导入数据库

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
import pandas as pd
import pymysql
import datetime
from sqlalchemy import create_engine
begin_time=datetime.datetime.now()
print('读取文件',datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
# 读取文件
df = pd.read_excel('D://excel路径//xxx.xlsx')
# 修改列表
df.rename(columns={'excel列名1': '对应的数据库字段1','excel列名2': '对应的数据库字段2'}, inplace=True)
# 获取指定列名的数据
newData=pd.DataFrame(df, columns=['对应的数据库字段1','对应的数据库字段2'])
# 增加创建时间
newData['create_time']=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
# 连接数据库
connect = create_engine('mysql+pymysql://账号名:密码@ip地址:端口/数据库名?charset=utf8')
# 写入数据
print('写入数据',datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
pd.io.sql.to_sql(frame=newData,name='表名',con=connect,if_exists='append',schema='数据库名',index=False)
connect.dispose()
end_time=datetime.datetime.now()
print('完成',datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
print('ok')