update_reprisk.py

#!/usr/bin/env python3
from wrds2pg import wrds_update, make_engine

engine = make_engine()

updated = wrds_update("v2_company_identifiers", "reprisk")
if updated:
    process_sql("CREATE INDEX ON reprisk.v2_company_identifiers (primary_isin)",
                engine)
    process_sql("CREATE INDEX ON reprisk.v2_company_identifiers (reprisk_id)",
                engine)

updated = wrds_update("v2_risk_incidents", "reprisk")
if updated:
    process_sql("CREATE INDEX ON reprisk.v2_risk_incidents (reprisk_id)",
                engine)

updated = wrds_update("v2_metrics", "reprisk")
if updated:
    eprocess_sql("CREATE INDEX ON reprisk.v2_metrics (reprisk_id)", engine)

updated = wrds_update("v2_wrds_company_id_table", "reprisk")
if updated:
    eprocess_sql("CREATE INDEX ON reprisk.v2_wrds_company_id_table (reprisk_id)", engine)