У меня есть приведенные ниже коды для подключения к моей базе данных с помощью простого оператора select, который отлично работает. Однако, если бы я хотел прочитать из файла sql (скажем, имя «sqlcodes. sql»), а затем выполнить код для извлечения данных, как мне это сделать?
import pandas as pd
import numpy as np
import sqlalchemy as sqla
def new_connection():
print('creating new connection')
return sqla.create_engine(r"mssql+pyodbc://PROD_DSN",echo=False).connect()
if __name__ == "__main__":
#create DB connection
conn = new_connection()
sql = f"select * from Exp.RISK_FACTOR"
#Read into a DataFrame
df = pd.read_sql(sql,conn)