实例:
import pymysql
import pandas as pd
import numpy as np from sqlalchemy import create_engine df = pd.DataFrame([[1,"Bob",0],
[2,"Kim",1]],columns=["id","name","sex"])
df id name sex
0 1 Bob 0
1 2 Kim 1 from sqlalchemy import create_engine
engine = create_engine("mysql://{}:{}@{}/{}?charset=utf8".format('username','password','host:port', 'database'))
con = engine.connect() df.to_sql(name='students', con=con, if_exists='append', index=False)
若表不存在,创建字段都是text,bigint等
df.to_sql参数介绍:
name:string
con:sqlalchemy.engine.Engine或sqlite3.Connection
schema:string,optional
if_exists:{'fail','replace','append'},默认'fail'
index:布尔值,默认为True
index_label:字符串或序列,默认为None
chunksize:int,可选
dtype:dict,可选