diff options
Diffstat (limited to 'python/load_markit_data.py')
| -rw-r--r-- | python/load_markit_data.py | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/python/load_markit_data.py b/python/load_markit_data.py index 892bf2e5..7c7810a8 100644 --- a/python/load_markit_data.py +++ b/python/load_markit_data.py @@ -14,8 +14,10 @@ fields = ["LoanX ID", "Issuer", "Deal Name", "Facility", "Industry", \ "Final Maturity", "Initial Spread", "Bid", "Offer", "Depth", \ "Spread To Maturity"] -latestdate = common.cursor.execute("SELECT MAX(pricingdate) from markit_prices") -latestdate = common.cursor.fetchone()[0] +c = common.conn.cursor() +c.execute("SELECT MAX(pricingdate) from markit_prices") +latestdate = c.fetchone()[0] +c.close() sql_fields = ["LoanXID", "Issuer", "DealName", "Facility", "Industry", "SP", "Moodys", "Amount", "Maturity", "Spread", "Bid", "Offer", "Depth", @@ -43,11 +45,12 @@ for filename in os.listdir(os.path.join(root, "data", "markit")): pdb.set_trace() data.append(temp) + c = common.conn.cursor() for row in data: sqlstring = "INSERT INTO markit_prices({0}) " \ "VALUES({1})".format(",".join(sql_fields), ",".join(["%s"] * len(sql_fields))) - common.cursor.execute(sqlstring, tuple(row) + (date,)) + c.execute(sqlstring, tuple(row) + (date,)) common.conn.commit() -common.cursor.close() + c.close() common.conn.close() print("done") |