mysql table to pandas dataframe

mysql_pandas.py

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' )