#!/usr/bin/env python

import csv
import pandas as pd
from sqlalchemy import create_engine

url = 'https://www.eia.gov/dnav/pet/xls/PET_PRI_SPT_S1_D.xls'
df = pd.read_excel(url,  sheetname=1, header=2, index_col=None)

df = df.drop(['Europe Brent Spot Price FOB (Dollars per Barrel)'],  axis=1)

df['sp_name_id'] = '1'
df['sp_region_id'] = '1'
df['unit_id'] = '1'

df.rename(index=str, columns={"Cushing, OK WTI Spot Price FOB (Dollars per Barrel)":"price"}, inplace=True)
df['Date'] = df.Date.map(lambda x: x.strftime('%Y-%m-%d'))

engine = create_engine("mysql://root:jGdttGR75!4T@127.0.0.1/nymex")
df.to_sql(name='spot_price',con=engine,if_exists='append', index=False)