Pandas读取MySQL数据到DataFrame的方法
方法一:
#-*-coding:utf-8-*- fromsqlalchemyimportcreate_engine classmysql_engine(): user='******' passwd='******' host='******' port='******' db_name='******' engine=create_engine('mysql://{0}:{1}@{2}:{3}/{4}?charset=utf8'.format(user,passwd,host,port,db_name)) defget_data(sql): pg_enine=mysql_engine() try: withpg_enine.engine.connect()ascon,con.begin(): df=pd.read_sql(sql,con)#获取数据 con.close() except: df=None returndf
方法二:
conn=MySQLdb.connect(host="******",user="******",passwd="******",db='******',port=******,charset="utf8") sql="select*from******limit3" df=pd.read_sql(sql,conn,index_col="id") printdf
pd1.9以后的版本,除了sqllite,均需要通过sqlalchemy来设置
以上这篇Pandas读取MySQL数据到DataFrame的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。