sqlalchemy 连接SQL SERVER 及用pandas

sqlalchemy 连接SQL server方法

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
#创建连接数据库引擎
engine = create_engine('mssql+pymssql://sa:username@host:port/database?charset=utf8')
#连接数据库
con =engine.connect()
#执行sql语句
con.execute(sql)

使用pandas结合sqlalchemy读取和导入数据
DataFrame.to_sql(tablename, con, schema=None,
if_exists='fail', index=True, index_label=None,
chunksize=None, dtype=None, method=None)

import pandas as pd
#通过sqlalchemy 引擎读取数据库中的数据
df=pd.read_sql(sql,con=engine)
#使用sqlalchemy 引擎把数据导入到数据库中
df.to_sql(tablename,engine,if_exists='replace',index=False)

if_exists ='replace' 替换原有数据；
if_exists ='append' 新增数据；
if_exists = 'fail' 默认；创建一个表，目标表存在就失败；

index=True 默认，新增一列索引