diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/markit_download.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/python/markit_download.py b/python/markit_download.py index 9a90a5b6..03809eb7 100644 --- a/python/markit_download.py +++ b/python/markit_download.py @@ -62,14 +62,14 @@ with open( facility_diff_filename, "wb") as fh: sqlstring = "INSERT INTO markit_facility(LoanXID, PMDID, IssuerName, dealname, facility_type," \
"loanx_facility_type, initial_amount, initial_spread, maturity, industry, modified_time)" \
"VALUES( {0} )".format( ",".join( ["%s"] * 11))
-with open(facility_diff_filename, "r") as fh:
- reader = csv.reader(fh)
- reader.next()
- for line in reader:
- newline = [convertToNone(v) for v in line] + [workdate]
- newline.pop(9) # remove the spread to maturity value
- common.cursor.execute(sqlstring, newline)
-common.conn.commit()
+if os.path.getsize(facility_diff_filename):
+ with open(facility_diff_filename, "r") as fh:
+ reader = csv.reader(fh)
+ for line in reader:
+ newline = [convertToNone(v) for v in line] + [workdate]
+ newline.pop(9) # remove the spread to maturity value
+ common.cursor.execute(sqlstring, newline)
+ common.conn.commit()
common.cursor.close()
common.conn.close()
|