在pandas read_sql(')中将数据从变量发送到sql查询

Question

我想从 2 个单独的变量将开始日期和结束日期值发送到我的 sql 查询中。认为， 我将 start_date = '2020-05-14' 和 end_date = '2020-07-08' 存储在一个变量中。现在我的查询是：

db_connection_str = 'mysql+pymysql://username:password@host/table_name'
db_connection = create_engine(db_connection_str)
def myfunc(start_date, end_date):
    sql_syn = "SELECT col_id, col_a, col_b, date, FROM en_stat where date between :start_date and :end_date"
    sql_df = pd.read_sql(sql_syn, con=db_connection, chunksize=100)

如何为此特定代码动态传递 start_date 和 end_date 值。

Answer 1

使用python3f-strings：

def myfunc(start_date, end_date):
    sql_syn = f"SELECT col_id, col_a, col_b, date, FROM en_stat where date between {start_date} and {end_date}"
    sql_df = pd.read_sql(sql_syn, con=db_connection, chunksize=100)