diff options
Diffstat (limited to 'python/load_markit_data.py')
| -rw-r--r-- | python/load_markit_data.py | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/python/load_markit_data.py b/python/load_markit_data.py index 7c7810a8..519149c4 100644 --- a/python/load_markit_data.py +++ b/python/load_markit_data.py @@ -4,7 +4,8 @@ import datetime from datetime import date import pdb import csv -import common +from db import conn +from common import root def convertToNone(s): return None if (s=='' or s=='NA') else s @@ -14,7 +15,7 @@ fields = ["LoanX ID", "Issuer", "Deal Name", "Facility", "Industry", \ "Final Maturity", "Initial Spread", "Bid", "Offer", "Depth", \ "Spread To Maturity"] -c = common.conn.cursor() +c = conn.cursor() c.execute("SELECT MAX(pricingdate) from markit_prices") latestdate = c.fetchone()[0] c.close() @@ -45,12 +46,12 @@ for filename in os.listdir(os.path.join(root, "data", "markit")): pdb.set_trace() data.append(temp) - c = common.conn.cursor() + c = conn.cursor() for row in data: sqlstring = "INSERT INTO markit_prices({0}) " \ "VALUES({1})".format(",".join(sql_fields), ",".join(["%s"] * len(sql_fields))) c.execute(sqlstring, tuple(row) + (date,)) - common.conn.commit() + conn.commit() c.close() -common.conn.close() +conn.close() print("done") |