mysql table to pandas dataframe
import MySQLdb
import pandas as pd
#### EXECUTE MYSQL QUERY function
def dfquery( query , value_index_col ):
# get mysql connection
con = MySQLdb.connect(host='127.0.0.1',user='xxx',passwd='xxx')
# execute query and saving data in dataframe
try:
dfresult = pd.read_sql(query, con,index_col=value_index_col)
except:
dfresult = pd.read_sql(query, con)
# close mysql connection
con.close()
return dfresult
## MYSQL DATABASE TO DATAFRAME
# mysql query parameters
dbname = "database"
tablename = "table"
fieldname = "field"
# build query (simple select)
query = "SELECT id,time," + fieldname + " FROM " + dbname + "." + tablename
# execute query
dfinput = dfquery( query ,'id' )