diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/bbg_prices.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/python/bbg_prices.py b/python/bbg_prices.py index d699b07b..2ce03894 100644 --- a/python/bbg_prices.py +++ b/python/bbg_prices.py @@ -26,9 +26,10 @@ df.reset_index(inplace=True) conn = engine.raw_connection() with conn.cursor() as c: - c.execute("UPDATE bloomberg_corp_ref SET defaulted = %(DEFAULTED)s, " \ - "default_date = %(DEFAULT_DATE)s, called= %(CALLED)s, called_date = %(CALLED_DT)s, " \ - "status = %(LN_ISSUE_STATUS)s WHERE id_bb_unique=%(ID_BB_UNIQUE)", df.to_dict('records')) + c.executemany("UPDATE bloomberg_corp_ref SET defaulted = %(DEFAULTED)s, " \ + "default_date = %(DEFAULT_DATE)s, called= %(CALLED)s, called_date = %(CALLED_DT)s, " \ + "status = %(LN_ISSUE_STATUS)s WHERE id_bb_unique=%(ID_BB_UNIQUE)s", + df.to_dict('records')) currentdata = pd.read_sql_query("SELECT id_bb_unique, pricingdate from bloomberg_corp", engine, |