diff options
Diffstat (limited to 'python/markit')
| -rw-r--r-- | python/markit/import_quotes.py | 22 |
1 files changed, 13 insertions, 9 deletions
diff --git a/python/markit/import_quotes.py b/python/markit/import_quotes.py index fe0d20a0..37062b22 100644 --- a/python/markit/import_quotes.py +++ b/python/markit/import_quotes.py @@ -393,10 +393,11 @@ def insert_index(conn, workdate=None): data["source"] = "MKIT" sql_str = ( f"INSERT INTO index_quotes_pre({','.join(ext_cols)}) " - "VALUES % ON CONFLICT DO NOTHING" + "VALUES %s ON CONFLICT DO NOTHING" ) - with conn.cusor() as c: + with conn.cursor() as c: execute_values(c, sql_str, list(data[ext_cols].itertuples(index=False))) + conn.commit() def insert_tranche(conn, workdate=None): @@ -408,7 +409,9 @@ def insert_tranche(conn, workdate=None): """ basedir = BASE_DIR / "Tranche_data" / "Composite_reports" - index_version = pd.read_sql_table("index_version", conn, index_col="redindexcode") + index_version = pd.read_sql_query( + "SELECT * FROM index_version", conn, index_col="redindexcode" + ) for f in basedir.glob("Tranche Composites*"): if ( workdate is None @@ -451,9 +454,10 @@ def insert_tranche(conn, workdate=None): "index_price", ] ) - sql_str = ( - f"INSERT INTO markit_tranche_quotes({','.join(df.columns)}) " - "VALUES % ON CONFLICT DO NOTHING" - ) - with conn.cusor() as c: - execute_values(c, sql_str, list(df.itertuples(index=False))) + sql_str = ( + f"INSERT INTO markit_tranche_quotes({','.join(df.columns)}) " + "VALUES %s ON CONFLICT DO NOTHING" + ) + with conn.cursor() as c: + execute_values(c, sql_str, list(df.itertuples(index=False))) + conn.commit() |